江苏龙网

  1. 主页 > 生活百科 > >

RabbitMQ的开发应用( 二 )

RabbitMQ


（备注：kafka零拷贝，通过sendfile方式 。（1）普通数据读取：磁盘->内核缓冲区（页缓存 PageCache）->用户缓冲区->内核缓冲区->网卡输出；（2）kafka的数据读取：磁盘->内核缓冲区（页缓存 PageCache）->网卡输出 。
1.2.4.可用性1. rabbitmq：（1）普通集群：在多台机器上启动多个rabbitmq实例，每个机器启动一个 。但是你创建的queue，只会放在一个rabbtimq实例上，但是每个实例都同步queue的元数据 。完了你消费的时候，实际上如果连接到了另外一个实例，那么那个实例会从queue所在实例上拉取数据过来 。（2）镜像集群：跟普通集群模式不一样的是，你创建的queue，无论元数据还是queue里的消息都会存在于多个实例上，然后每次你写消息到queue的时候，都会自动把消息到多个实例的queue里进行消息同步 。这样的话，好处在于，一个机器宕机了，没事儿，别的机器都可以用 。坏处在于，第一，这个性能开销太大了，消息同步所有机器，导致网络带宽压力和消耗很重 。第二，这么玩儿，就没有扩展性可言了，如果某个queue负载很重，你加机器，新增的机器也包含了这个queue的所有数据，并没有办法线性扩展你的queue
2. kafka：kafka是由多个broker组成，每个broker是一个节点；每创建一个topic，这个topic可以划分为多个partition，每个partition可以存在于不同的broker上，每个partition就放一部分数据 。这就是天然的分布式消息队列，就是说一个topic的数据，是分散放在多个机器上的，每个机器就放一部分数据 。每个partition的数据都会同步到其他机器上，形成自己的多个replica副本，然后所有replica会选举一个leader出来，主从结构 。
1.2.5.集群负载均衡1. rabbitmq：rabbitMQ的负载均衡需要单独的loadbalancer进行支持，如HAProxy和Keepalived等 。
2. kafka：kafka采用zookeeper对集群中的broker、consumer进行管理，可以注册topic到zookeeper上；通过zookeeper的协调机制，producer保存对应topic的broker信息，可以随机或者轮询发送到broker上；并且producer可以基于语义指定分片，消息发送到broker的某分片上 。
2.结构2.1.交换机模式RabbitMQ常用的Exchange Type有fanout、direct、topic、headers这四种 。
2.1.1.Direct Exchangedirect类型的Exchange路由规则很简单，它会把消息路由到那些binding key与routing key完全匹配的Queue中 。
2.1.2.Topic Exchange前面讲到direct类型的Exchange路由规则是完全匹配binding key与routing key，但这种严格的匹配方式在很多情况下不能满足实际业务需求 。topic类型的Exchange与direct类型的Exchage相似，也是将消息路由到binding key与routing key相匹配的Queue中，但支持模糊匹配：
· routing key为一个句点号“. ”分隔的字符串（我们将被句点号“. ”分隔开的每一段独立的字符串称为一个单词），如“stock.usd.nyse”、“nyse.vmw”、“quick.orange.rabbit”
· binding key与routing key一样也是句点号“. ”分隔的字符串
· binding key中可以存在两种特殊字符"*"与“#”，用于做模糊匹配，其中" * "用于匹配一个单词，“#”用于匹配多个单词（可以是零个）
2.1.3.Fanout Exchangefanout类型的Exchange路由规则非常简单，它会把所有发送到fanout Exchange的消息都会被转发到与该Exchange 绑定(Binding)的所有Queue上 。
Fanout Exchange 不需要处理RouteKey。只需要简单地将队列绑定到exchange 上 。这样发送到exchange的消息都会被转发到与该交换机绑定的所有队列上 。类似子网广播，每台子网内的主机都获得了一份复制的消息 。所以，Fanout Exchange 转发消息是最快的 。
2.1.4.Headers Exchangeheaders类型的Exchange也不依赖于routing key与binding key的匹配规则来路由消息，而是根据发送的消息内容中的headers属性进行匹配 。
在绑定Queue与Exchange时指定一组键值对；当消息发送到Exchange时，RabbitMQ会取到该消息的headers（也是一个键值对的形式），对比其中的键值对是否完全匹配Queue与Exchange绑定时指定的键值对；如果完全匹配则消息会路由到该Queue，否则不会路由到该Queue 。
2.1.5.Default Exchange 默认严格来说，Default Exchange 并不应该和上面四个交换机在一起，因为它不属于独立的一种交换机类型，而是属于Direct Exchange 直连交换机 。
默认交换机（default exchange）实际上是一个由消息代理预先声明好的没有名字（名字为空字符串）的直连交换机（direct exchange） 。
它有一个特殊的属性使得它对于简单应用特别有用处：那就是每个新建队列（queue）都会自动绑定到默认交换机上，绑定的路由键（routing key）名称与队列名称相同 。


推荐阅读


上一篇：没有了

下一篇：使用这11个代码，可以大大地简化我们的代码