有没有轻量级分布式消息队列

[1800x]

用于小型分布式微服务系统
要求：
1 几乎没有资源消耗
2 上手、维护简单
3 没有单点故障
4 支持发布/订阅
5 支持失败重试
6 支持定时/延时消息
7 支持 go python

目前主流消息队列，资源消耗大、维护困难。
数据储存可以用 mysql redis 。这两样一般的系统都有。
当然，这个消息队列上传输的数据量不大。

[ipwx]

redis 都支持。。。

[ipwx]

https://redis.io/docs/latest/develop/interact/pubsub/

[iqingqian]

https://github.com/hibiken/asynq

[1800x]

@iqingqian 这货不支持“订阅”。客户端会收到全部任务，没得选

[qingshanyuluo]

那两个流行的消息队列本来也不重啊

[ChoateYao]

用 redis 自己搞一个
就用 set 维持一个订阅列表，每个名称都是一个 redis 队列。

[hui314]

beanstalkd

[gesse]

mqtt ？

[mightybruce]

1.云原生 nats.io
2.redis stream
3. 自己用消息中间件 zeromq 或 nanomsg 自己封装一下想有什么功能就有什么功能。
zeromq 几乎有所有流行语言的库

[mightybruce]

nanomsg 有好几种语言的实现，原来是为了进入 linux 内核，把 zeromq 用 C 改写了，现在也有纯 go 语言实现。
https://github.com/nanomsg/mangos

[yjhatfdu2]

nats jetstream 只有 6 大概没有其他全符合

[dododada]

nsq ， 但是 5 不确定是否支持，可能要自己写

[rekulas]

rabbitmq docker 一键运行内存占用几十 用了很多年了

[8355]

推荐 redis stream
有消费者组 目前我们深度应用，阿里云 2g 的 redis 跑的飞起
有消费和重试机制

[evam]

总感觉你在说 redis 啊

[LieEar]

我推荐一个，celery
https://github.com/celery/celery

[xubeiyou]

Redis 或者是 mqtt

[dwu8555]

@1800x 支持订阅啊，你设置需要处理的 queue 就行了

[allenby]

https://github.com/eclipse-zenoh/zenoh

[codersdp1]

@iqingqian 这个还可以

[BeijingBaby]

既然分布式了，不太可能还很轻量吧。毕竟各种情况都要考虑到。

[904653238]

@8355 用 redis stream, 你们的流重分配是自己做的吗？

[8355]

@904653238 这个没啥难度是自己做的，重新投递即可，stream 内部机制可以记录重试次数和超时时间。

[904653238]

@8355 能交流下吗？ OTA0NjUzMjM4

[Scarb]

rabbitmq

[xsen]

nsq
nats

[su14772]

redis stream 不就可以么

[update]

redis stream

[yougg]

https://github.com/yougg/awesome-message-queue

[zzhaolei]

@yjhatfdu2 nats 好像支持延时消息

https://pkg.go.dev/github.com/nats-io/nats.go#Msg.NakWithDelay

[IDAEngine]

rabbitmq

[xierqii]

pulsar https://pulsar.apache.org/

要是测试用，用镜像一键拉起服务，方便快捷。

[dyllen]

redis 吧，不用额外引入外部组件，引入一个 redis 队列的库就能用了。