一个topic订阅一条消息,处理完自己的任务后再订阅该主题的下一条
不行,别这样干
是因为消息不能堆积吗?
因为不能将全部任务下发,需要一个一个处理完才能进行下一个消息的处理,那有什没其他办法吗?
简单点就自己搞一个队列做接收,然后异步处理吧。
要可靠点就存到rabbitmq 或 kafka的队列中,然后一个个的去消费。你那方法不行
好的
一个topic订阅一条消息,处理完自己的任务后再订阅该主题的下一条
不行,别这样干
是因为消息不能堆积吗?
因为不能将全部任务下发,需要一个一个处理完才能进行下一个消息的处理,那有什没其他办法吗?
简单点就自己搞一个队列做接收,然后异步处理吧。
要可靠点就存到rabbitmq 或 kafka的队列中,然后一个个的去消费。你那方法不行
好的