欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

分布式系统之消息中间件rabbitmq

程序员文章站 2022-03-26 13:16:34
...
既然要做分布式系统,就不得不说分布式消息通信系统。分布式系统的基础是各个分布式单元能够以各种方式互相通信,分布式消息中间件比较有名的开源实现有rabbitMQ,zeroMQ(库),ActiveMQ等,本篇先考察一下著名的消息中间件rabbitmq

rabbitmq在2010年4月被SpringSource收购,后者是vmware的一个部门,就是说,rabbitmq目前已经是vmware的了。

rabbitmq使用erlang语言编写,实现了AMQP协议。AMQP协议在04年中~06年中由摩根大通集团和iMatix公司开发,后来由AMQP工作组维护。最初用于金融领域,后来慢慢成为一个通用的协议。与JMS不同,AMQP定义了详细的消息格式,因此任何语言开发的软件都可以与其他语言开发的软件进行互通,只要他们的消息格式一致即可。

AMQP协议定义了Message Broker作为消息服务器,定义了User作为消息服务器的使用者(producer或consumer),User和Message Broker之间可以建立物理连接Connection,在Connection上,可以创建虚拟连接channel。基于Channel,可以声明(declare)交换机exchange,队列queue,可以在exchange和queue间建立绑定binding,Message由生产者发送到exchange,然后按照规则发送给binding到该exchange的queue。Message分为头部和消息体,其中头部包含了routing-key,而binding也有routing-key的属性,不过这个binding的这个属性可以是一个或多个明确的routing-key,也可以是一个或多个pattern。

exchange和queue之间可以有多个binding,一个exchange可以bind多个queue,一个queue也可以bind到多个exchange。这里exchange相当于硬件的交换机,但queue不是连线,而是一个缓存,binding是queue和exchange之间的关系。虽然exchange和queue之间可以有多个binding,但不会导致一个消息会从exchange重复发送给同一个queue,一个消息从一个exchange最多发送一次给一个queue。

binding实际上是exchange上的一条配置规则。