假如有这么一个需求,我希望rabbitMQ的队列每秒被消费1条信息,但是有两个消费者轮流消费,也就是
第0秒:第一个消费者输出A
第1秒:第一个消费者输出B
第2秒:第一个消费者输出A
第3秒:第一个消费者输出B
间隔打印一直到消费完毕
如何设置mq或者交换机的属性呢
还有死信队列是干嘛的,网上好多都在说咋用,不知道是干嘛的
2个消费者,复用一个连接就行
每秒消费几条队列是消费者决定的,不是生产者决定的,也不是队列本身决定的
队列本身只负责存储队列,可不管谁往里存,谁往外取
你可以开两个线程,加个锁,同一时间只允许一个线程执行
答案复制过来了
你这是2个问题,我怀疑
1、MQ每秒提供1条信息,多了限流
2、消费者,必须轮流消费
问题1
你可以再建一个MQ啊,原始的MQ,信息随便来, 你本地再建一个对外服务的,你自己写个消费者,每秒从原始MQ消费1条,然后放到这个对外的MQ里。
问题2,
这个是外部消费者控制,我真的不知道你个服务提供端,怎么限制消费端必须要【循环】?
难道你要给2个消费者,建2个队列,然后每隔【2秒钟】先后发送1条数据给他们?