你的问题有两种解决方法。
使用命名队列就是其中之一。
将Exchange设置为扇出模式,并为其订阅命名队列。这样,当发布服务器在您的Exchange中发送消息时,它将被分派到所有侦听的队列。
然后,每个队列可以有一个或多个使用者(允许您进行缩放)。您必须定义一个命名队列/消费者。当一个消费者断开连接时,他的队列仍然接收消息,当他回来时,他可以消费这些消息。
你应该可以那样做你想做的事。
另一种方法是为了你的个人知识,因为你说你想使用rabbitmq。但在这种情况下,您可以使用kafkha,然后,在重新连接之后,您的使用者可以在断开连接时的消息索引处恢复。
如果不起作用,请更新我:)
