社区所有版块导航
Python
python开源   Django   Python   DjangoApp   pycharm  
DATA
docker   Elasticsearch  
aigc
aigc   chatgpt  
WEB开发
linux   MongoDB   Redis   DATABASE   NGINX   其他Web框架   web工具   zookeeper   tornado   NoSql   Bootstrap   js   peewee   Git   bottle   IE   MQ   Jquery  
机器学习
机器学习算法  
Python88.com
反馈   公告   社区推广  
产品
短视频  
印度
印度  
Py学习  »  Artandor  »  全部回复
回复总数  1

你的问题有两种解决方法。

使用命名队列就是其中之一。 将Exchange设置为扇出模式,并为其订阅命名队列。这样,当发布服务器在您的Exchange中发送消息时,它将被分派到所有侦听的队列。

然后,每个队列可以有一个或多个使用者(允许您进行缩放)。您必须定义一个命名队列/消费者。当一个消费者断开连接时,他的队列仍然接收消息,当他回来时,他可以消费这些消息。

你应该可以那样做你想做的事。

另一种方法是为了你的个人知识,因为你说你想使用rabbitmq。但在这种情况下,您可以使用kafkha,然后,在重新连接之后,您的使用者可以在断开连接时的消息索引处恢复。

如果不起作用,请更新我:)