rabbitmq 为 amqp协议的实现。

实际使用过程中又要使用到pika这个库。

明确几个概念:

queue 官网说这个概念是信箱。 queue确实是消息的缓存区

exchange 这个概念负责消息的传递,官网说  rabbitmq 从来不直接把消息发送到queue中,也就是说只把消息发送到exchage这个服务中。

routing_key 安装官网给的教程,这个东西只有在exchange的type是direct 或者topic的时候才有作用

说一下联系:

官网说要把消息发给queue 你首先要让exchagne知道queue 怎么让exchage知道queue呢?

需要 channel的queue_bind这个方法让exchagne知道queue 让exchagne知道与routing_key绑定的queue

direct topic都可以支持routing_key 却别我以为就是topic支持* #通配符。

消息流:

fanout情况下,exchange会把消息发给所有知道的queue的

direct情况下,exchagne会把消息发给所有知道的queue中,但是会是使用routing_key作为分流器,routing_key与那个queue绑定就发给那个queue

持久化:

如果想让mqserver重启以后还能保持消息,就在生命queue的时候 置 durable=True  basic_public  property method=2

大概就写这么多 ,花了三分钟。

转载于:https://www.cnblogs.com/S-volcano/p/4992214.html

rabbitmq 笔记相关推荐

  1. 狂神说RabbitMQ笔记下载

    狂神说RabbitMQ笔记下载.md后缀 https://wws.lanzoui.com/iJIaroylmqh

  2. 学相伴飞哥RabbitMQ笔记

    什么是中间件 我国企业从20世纪80年代开始就逐渐进行信息化建设,由于方法和体系的不成熟,以及企业业务和市场需求的不断变化,一个企业可能同时运行着多个不同的业务系统,这些系统可能基于不同的操作系统.不 ...

  3. 所有人 把膝盖准备好,这份“保姆级”的RabbitMQ笔记,你不服不行

    什么是消息中间件 MQ全称为Message Queue,消息队列是应用程序和应用程序之间的通信方法. 为什么使用MQ? 在项目中,可将一些无需即时返回且耗时的操作提取出来,进行异步处理,而这种异步处理 ...

  4. Redis和RabbitMQ笔记

    狂神说Redis笔记 链接:https://pan.baidu.com/s/1yNoJiIIUNj2zA7vY3lKHOw 提取码:yyds 尚硅谷消息中间件,RabbitMQ 链接:https:// ...

  5. RabbitMQ笔记-使用rabbitmq-c实现Fair dispatch(公平分发)

    目录 概念及注意 代码与实例 概念及注意 这里C接口中有2个函数一个是: amqp_basic_get() 另外一个是: amqp_basic_consume() 前者可以一条一条的读取,后者是一次读 ...

  6. RabbitMQ笔记-使用rabbitmq-c让生产者发送数据

    目录 环境 下载地址 过程 环境 RabbitMQ和Erlang的版本如下: rabbitmq-c的版本 下载地址 RabbitMQ下载地址: https://www.rabbitmq.com/dow ...

  7. RabbitMQ笔记

    一.安装及配置 摘要:为了简单起见,在安装过程中已默认关闭了firewalld防火墙 和 SELinux.实际生产中,则不这样子做,而是开放相应的端口,以增强安全性. 关闭firewalld防火墙 和 ...

  8. 【学相伴】狂神说 RabbitMQ笔记(简单使用RabbitMQ)

    目录 什么是rabbitMQ 使用docker安装RabbitMQ,如果没有使用过docker的可以看这篇文章https://blog.csdn.net/qq_44716544/article/det ...

  9. rabbitmq 笔记

    basic.comsume会订阅消息并不断收取消息.直到取消订阅为止. basic.get会获取单条消息,不能把basic.get放在一个循环里来替代basic.comsume,这样会影响性能. 当队 ...

  10. 学相伴飞哥RabbitMQ笔记以及个人总结

    一.什么是中间件? 1.简介 我国企业从20世纪80年代开始就逐渐进行信息化建设,由于方法和体系的不成熟,以及企业业务和市场需求的不断变化,一个企业可能同时运行着多个不同的业务系统,这些系统可能基于不 ...

最新文章

  1. UCOSIIIAPI函数接口OSTaskCreate();函数
  2. boost::rethrow_exception相关的测试程序
  3. grenndao 插入表数据报错
  4. python怎么使用time模块_PYTHON的TIME模块使用
  5. 1051 复数乘法 (15 分)
  6. layui下拉框往上显示跟往下显示_牛肉价格持续攀升,潮汕牛肉火锅下月或将调涨了...
  7. Datawhale-零基础入门NLP-新闻文本分类Task02
  8. [Robot Framework] User Guide : 如何自己创建library
  9. Criteria和DetachedCriteria区别应用
  10. BJOI2018 简要题解
  11. python场景识别_python 场景
  12. 鸿蒙os运行内存,体验亮点满满!鸿蒙OS系统6月份开启适配,不只有华为手机
  13. node.js的安装教程
  14. HTML5 WebGame开源工具之impactjs
  15. 基于Android的家校联系平台开发(论文)
  16. 【题目】一个信道的比特速率为4Mbps,信号的传播延迟为20ms,数据帧的大小为10^4比特,采用滑动串口协议,不考虑帧的生成时间,支持捎带应答,那么帧序号应为多少bit?
  17. 记录一次利用python调用chrome爬取天眼查网址工商信息的过程
  18. 邮件中html内嵌图片,邮件内嵌html
  19. 计算机系统结构 之 指令系统
  20. 毕业论文-马尔可夫随机场

热门文章

  1. MAC硬盘空间减少的隐藏杀手,VM到底是什么?
  2. 如何在Mac上自定义控制中心
  3. Mac打不开TXT文件怎么解决?
  4. nginx安装lua/replace-filter-nginx-module
  5. AMD将统治2017年的PC及服务器市场?
  6. VINS(二)Feature Detection and Tracking
  7. 没有Angular 3,下一个Angular主版本将是Angular 4
  8. saltstack 自动化运维神器(四)salt-ssh
  9. sybase相关的知识
  10. dropdownlist返回值设置方法