RabbitMQ的一些理解和笔记_其他编程教程_网络编程_码蚁之家_www.codes91.com
返回首页
专题
网络编程
ASP教程 .NET教程 PHP教程 JSP教程 C#教程 Java教程 Delphi教程 VB教程 C/C++教程 Android开发 IOS开发 Windows Phone开发 Python教程 Ruby教程 移动开发 其他编程教程
网页制作
HTML教程 CSS教程 Dreamweaver教程 FrontPages教程 Javascript教程 web前端
数据库
SqlServer MySql Oracle Access DB2 SQLite 其他数据库
图形设计
photoshop教程 Fireworks教程 CorelDraw教程 Illustrator教程 AutoCad教程 FLASH教程
操作系统
Windows xp教程 Windows 7教程 Windows 8教程 Windows 2003教程 Windows Server 2008教程 Linux教程 Windows 10
网站运营
建站经验 SEO优化 站长心得 网赚技巧 网站推广 站长故事
手机学院
手机速递 安卓教程 iphone教程 手机评测 手机技巧 手机知识 手机应用 手机游戏 手机导购
网店宝典
开店指导 开店经验 网店装修 网店推广 网店seo 网购技巧
软件教程
办公软件 系统工具 媒体工具 压缩工具 图文处理 文件管理
范文之家
自我介绍 自我鉴定 写作模板 合同范本 工作总结 贺词祝福语 演讲致辞 思想汇报 入党申请书 实习报告 心得体会 工作计划 简历模板 工作报告 导游词 评语寄语 口号大全 策划书范文
信息工程
软件工程 企业开发 系统运维 软件测试
移民之家
移民动态 移民政策 移民百科 移民生活 技术移民 投资移民
知识大全
母婴 数码 摄影 装修 美文 常识 时尚 婚嫁 美食 养生 旅游 兴趣 职场 教育 文学 健康
问答大全
电脑网络 手机数码 QQ专区 生活 游戏 体育运动 娱乐明星 休闲爱好 文化艺术 社会民生 教育科学 健康医疗 商业理财 情感家庭 地区问题 其他
编程问答
IOS Android .NET Java C/C++ Delphi VC/MFC 其他语言 PHP MSSQL MYSQL Oracle 其他数据库 Web开发 Windows Linux 硬件/嵌入开发 网络通信 移动开发 云计算 企业IT 游戏开发
笑话大全
幽默笑话 爱情笑话 成人笑话 校园笑话 爆笑笑话 综合笑话 古代笑话 现代笑话 国外笑话

RabbitMQ的一些理解和笔记(1/2)

来源:互联网  时间:2018/11/1 13:17:52

在这篇博客中,简单记录一下 rabbitmq 服务器中一些基本的概念。

Connection:connection 为 TCP连接,是我们的应用程序和RabbitMQ服务器真正发送和接收数据的地方。

Channel: channel为connection创建的“信道”,具体的AMQP命令都是通过信道发送出去的。每一条信道都有一个唯一的id,channel是线程不安全的。

bindingKey和routingKey的区分:

bindingkey: 在使用绑定的时候,需要用到的路由键是 bindingkey。涉及到的客户端方法: channel.exchangeBind channel.queueBind等

    routingkey: 在发送消息的时候,需要用到的路由键是 routingkey。涉及到的客户端方法: channel.basicPublish

exchange:交换器,存在四种类型

  1. fanout:fanout类型的Exchange路由规则非常简单,它会把所有发送到该Exchage的消息路由到所有与它绑定的Queue中。

  2. direct:direct类型的Exchange路由规则也是非常简单,它会把消息路由到哪些 binding key routing key 完全匹配的Queue中。

    每个队列在新建时,默认会绑定到  默认交换器(名字为空字符串),绑定的路由键名称和路由键名称一致。
  3. topic:根据 routingKey 和 bindingKey 进行匹配。bindingKey
  4. headers:此种交换器不常用,它是使用headers来匹配的,不依赖routingKey和bindingKey可以存在两种特殊字符*#用于做模糊匹配,其中 “*” 用于匹配一个单词,“#”用于匹配多个参数(可以是零个)。注意:“*” 以 . 作为分隔符 、  “#” 以任何字符作为匹配关键字的部分。

vhost:虚拟主机

每一个 vhost 本质上就是一个 mini 版的 RabbitMQ 服务器,它拥有自己的队列、交换器、绑定等,同时它也有自己的权限控制。它提供了逻辑上的隔离,保证了数据的安全性。

Connection和Channel有什么关系?

   我们知道操作系统创建和销毁一条tcp连接是非常消耗性能的,如果系统高峰期时,大量的创建和销毁TCP连接,这会造成大量的性能损耗,并且系统很有可能达到瓶颈,如果我们所有的线程都使用一条TCP连接,并且保证每个线程的私密性,那么就可以大大提高系统的性能,因此 Channel 就应运而生了。

即:我们可以简单的理解,channel 就是一个虚拟的 connection,channel是通过connection创建得来的,channel是线程不安全的。

设置消息的过期时间:

   1、设置队列中消息的过期时间

          通过队列设置的过期时间,那么队列中的每条消息的过期时间都是一致的。

         在channel.queueDeclare 时,设置x-message-ttl 参数,这个参数的单位是毫秒

         ** 不进行设置,表示此消息永不过期

         ** 设置为0表示,除非此时可以将消息投递给消费者,否则该消息会被立即丢弃

    2、为单条消息设置过期时间

         在channel.basicPublish 方法中加入expiretion 的属性参数,单位是毫秒

注意:

   1、如果同时设置了队列的过期时间和消息的过期时间,那么以过期时间小的为准

          2、对于第一种方法设置的过期时间,在消息过期时就会从队列中进行移除,对于第二种方法,即使消息过期也不会马上从队列中移除,因为每条消息的过期时间是在即将投递给消费者之前进行判断的。

消费者消费消息时与rabbitmq断开连接:

    如果消费者就收到一条消息,然后确认之前与RabbitMQ断开连接或从队列上取消订阅,RabbitMQ会认为这条消息没有进行分发,会重新分发给下一个消费者进行处理。


上一篇CC65 开发FC/NES 游戏(三)使用摇杆
下一篇从socket到TCP协议,透彻理解网络编程
明星图片
相关文章
《 RabbitMQ的一些理解和笔记》由码蚁之家搜集整理于网络,
联系邮箱:mxgf168#qq.com(#改为@)