关于在go-zero中如何使用rocketmq的消费者？

1. 问题描述？

最近学习了go-zero和消息队列(RocketMq)，但是在写消费者的时候有些疑惑，
消费者的代码写完后应该放在哪启动，在搜了google和bing后感觉都是在说如何进行消费的，并没有说写完后在哪里启动他。
所以想请教一下大佬应该如何正确的去使用，是放在svc里面还是main方法里面去调用执行？
还是说单独出来在写一套专门针对消费者的应用之类的？

go go-zero RocketMQ 消息队列

Harvoc

课程读者 28 声望

waifu2x Linux Debian 爱好者！(然而并不熟练！)

0 人点赞

deatil

见习助教 762 声望

最佳答案

消费基本都是方向main里，用协程消费

7个月前评论

deatil （作者）

@Harvoc 这个问题问的好😏，通常go有一个优雅退出的处理，就是来解决这个问题的，go-zero的话暂时没怎么注意到，可以先看下文档，文档没有就用通用的处理

deatil （作者）

@Harvoc 关联字就是优雅退出这样，用的哪种框架就把框架名加上搜

anyua

@Harvoc 一般监听系统信号，搭配 sync.waitgroup 来优雅退出，当然具体问题具体分析

Harvoc （楼主）

大佬问下，main启动的话，如果主程序退出那么消费者也就退出了，消费到一半的任务该怎么办呢？

Harvoc （楼主）

@deatil 是不是就是退出的时候会给消费者的协程发信号并且等待其他的消费者退出然后自己 (main) 在退出？还是说在 main 退出时，其余的消费者任务还在进行等任务完了后会自己退出？在这块还是没想明白，大佬可以发个链接或者关键词吗？感激不尽 ( つ・̀ω・́) つ

讨论数量: 13

renxiaotu

377 声望

博客：go-zero 微服务实战系列（二、服务拆分）

这个是原作者关于服务拆分的，与其百度，不如直接看教程

7个月前评论

Harvoc （楼主）

我没看到又说启动的地方靓仔

tsin

课程读者 1.5k 声望

程序启动的时候注册上去

7个月前评论

tsin （作者）

@Harvoc 都行，独立封装一个包调用。消费者和生产者都有Shutdown方法，退出的时候找回对应的实例，调用Shutdown方法。

Harvoc （楼主）

是不是直接就把消费者代码在svc那里调用就可以了？

Harvoc （楼主）

@tsin 了解了，谢谢靓仔！

deatil

见习助教 762 声望

消费基本都是方向main里，用协程消费

7个月前评论

deatil （作者）

@Harvoc 这个问题问的好😏，通常go有一个优雅退出的处理，就是来解决这个问题的，go-zero的话暂时没怎么注意到，可以先看下文档，文档没有就用通用的处理

deatil （作者）

@Harvoc 关联字就是优雅退出这样，用的哪种框架就把框架名加上搜

anyua

@Harvoc 一般监听系统信号，搭配 sync.waitgroup 来优雅退出，当然具体问题具体分析

Harvoc （楼主）

大佬问下，main启动的话，如果主程序退出那么消费者也就退出了，消费到一半的任务该怎么办呢？

Harvoc （楼主）

@deatil 是不是就是退出的时候会给消费者的协程发信号并且等待其他的消费者退出然后自己 (main) 在退出？还是说在 main 退出时，其余的消费者任务还在进行等任务完了后会自己退出？在这块还是没想明白，大佬可以发个链接或者关键词吗？感激不尽 ( つ・̀ω・́) つ

猿来是你

见习助教 13 声望

可以用go-zero的 NewServiceGroup 管理多个服务，启动执行start，主服务退出会执行stop，例如下图我写的例子

file

mq服务可以随自己想要的结构体

file

6个月前评论

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容，与人为善，比聪明更重要！

帮助

关于在go-zero中如何使用rocketmq的消费者？

1. 问题描述？

社区赞助商

关于 LearnKu

资源推荐

服务提供商

其他信息

关于在go-zero中如何使用rocketmq的消费者？

1. 问题描述？

社区赞助商

关于 LearnKu

资源推荐

服务提供商

其他信息

请登录