小白笔记-RabbitMQ消息队列
发布日期:2022-03-02 13:23:43 浏览次数:9 分类:技术文章

本文共 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 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!

上一篇:Django对于数据库的基础知识
下一篇:关于myspl数据库安装及基本用法

发表评论

最新留言

路过按个爪印,很不错,赞一个!
[***.219.124.196]2023年01月30日 20时54分37秒

关于作者

    喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!

最新文章

常用数据生成算法accumulate 2019-12-30 12:48:06
常用拷贝和复制算法swap 2019-12-30 12:48:07
常用算术生成算法fill 2019-12-30 12:48:07
常用集合算法set_intersection 2019-12-30 12:48:07
常用集合算法set_union 2019-12-30 12:48:07
查找算法 binary_serach 2019-12-30 12:48:05
2021-09-29 2019-12-30 12:48:05
查找算法count 2019-12-30 12:48:06
查找算法count_if 2019-12-30 12:48:06
常用排序算法sort 2019-12-30 12:48:06
排序算法-洗牌算法 2019-12-30 12:48:06
逻辑仿函数 逻辑非 2019-12-30 12:48:04
常用遍历算法for_each 2019-12-30 12:48:04
常用遍历算法 transform 2019-12-30 12:48:04
查找算法find 2019-12-30 12:48:05
查找算法find_if 2019-12-30 12:48:05
查找相邻元素算法 2019-12-30 12:48:05
STL案例2-成员分组 2019-12-30 12:48:03
STL函数对象基本使用 2019-12-30 12:48:03
谓词 一元谓词 2019-12-30 12:48:03