本文共 923 字，大约阅读时间需要 3 分钟。

https://blog.csdn.net/qq_47588845/article/details/107986373

RabbitMQ消息队列的安装可以看上面链接这位大佬的 RabbitMQ消息队列 首先简单说一下进程queue，可以父进程也子进程进行交互或者同一父进程下多个子进程进行交互，那我要是想跨平台跨语言交互呢? 就可以用到本文RabbitMQ消息队列进行交互 就像经典的 生产者生产给rabbitMQ 消费者再消费 消息队列（Message Queue） 是一种应用间的通信方式，消息发送后可以立即返回，由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到 MQ 中而不用管谁来取，消息使用者只管从 MQ 中取消息而不管是谁发布的。这样发布者和使用者都不用知道对方的存在。 RabbitMQ基本实例

这是producer生产者端，也就是发消息给rabbit的那一端，代码的后面我都添加了个人理解的注释，仅供参考，希望大佬多多指教

这个是consumer消费者端，代码后面都有注释，如果有错的可以指正一下我，本文主要记录笔记，小白可以一起交流学习 有了生产者消费者就可以实现交互了 生产者端发了 hello world过去rabbitmq 消费者那端从rabbitmq中取出来 下面是结果的展示 消费在后面callback不加True就可以实现轮询后突然挂断 就会传给下一个消费者，常规的轮询是断了就没有了，示例中就没有加

durable如果rabbit突然断了，可以把队列持久化在消费者及生产者端定义队列queue名后加durable=True 即可保存队列 但队列消息还是没有

保存消息可以在生产者 basic_publishd下定义加properties=pika.BaseConnetion（delivery_mode=2）即可在rabbitmq重启的时候 数据不会丢失 每个服务器处理的速度分配不一样，要想合适的分配，可在消费者中配置 basic_qos(prefetch_count=1)#意思是每次只处理一条 处理完再给我发 感谢，纯属记录笔记，大佬轻喷，学习还得看大佬发的文章，本文看也就图一乐别当真 感谢观看！

转载地址：https://blog.csdn.net/WOSHIBEIZHE/article/details/117780165 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！