ASP源码.NET源码PHP源码JSP源码JAVA源码DELPHI源码PB源码VC源码VB源码Android源码
当前位置:首页 >> 网络编程 >> 其他编程教程 >> RabbitMQ的一些理解和笔记

齐发国际登录

来源:网络整理     时间:2018-11-01     关键词:

本篇文章主要介绍了" RabbitMQ的一些理解和笔记",主要涉及到方面的内容,对于其他编程教程感齐发国际游戏的同学可以参考一下: 在这篇博客中,简单记录一下 rabbitmq 服务器中一些基本的概念。Connection:connection 为 TCP连接,是我们的应用程序和Rabbi...

在这篇博客中,简单记录一下 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 游戏(三)使用摇杆 下一篇:没有了

相关图片

相关文章