博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
RabbitMQ学习以及与Spring的集成(二)
阅读量:4878 次
发布时间:2019-06-11

本文共 1741 字,大约阅读时间需要 5 分钟。

本文介绍RabbitMQ的一些基本概念。

RabbitMQ服务可以安装在独立服务器上,通过配置的账户和ip访问使用。也就是说,RabbitMQ和使用它的应用可以部署在不同的服务器上。RabbitMQ的账户配置可以在其web后台的admin板块配置。

Virtual Host

virtual host直译就是虚拟主机,RabbitMQ作为一个比较成熟的消息中间件,当然可以为不同的应用提供不同的服务空间。这就是virtual host的作用,用以区分不同应用的资源。不同的virtual host管理各自的exchanges、queue和bindings。我们在新建账户时需要指定对应的virtual host,这就意味着使用这个账户进行连接的应用只能使用该virtual host下的资源。当然了,一个virtual host是可以有多个账户的。

Exchanges

交换机们。在RabbitMQ中,发送的消息最终会发送到queue(消息队列)。但是我们不是通过直接指定某个queue进行消息发送,而是需要通过Exchange,根据其指定的规则进行转发,这是为了增加程序的可开发性。既然是通过Exchange转发,那么Exchange和queue之间就存在一个绑定关系,这个绑定关系需要通过xml等预先配置好。根据Exchange转发的规则不同产生了四种Exchange类型。分别是Direct exchange,Fanout exchange,Topic exchange,Headers exchange。

Direct exchange通过一个key值进行消息转发。绑定queue到Direct exchange的时,需要指定该queue的一个key值。我们发送消息时,除了消息本身,还需发送一个key。Direct exchange就会根据该key查询有无对应的queue。有,则转发到对应的queue,完成发送过程。两个不同的queue使用同一个key进行绑定也是可以的,符合条件的消息会一起发送给两个queue。

Fanout exchange是直接将消息转发到所有绑定到它的queue上。发送消息时只需要发送消息体。

Topic exchange规则稍稍有点复杂。一个queue是通过一个pattern绑定到Topic exchange的。一个pattern其实也是一串字符,但是它可以包含两个特殊符号。*和#。举例来说,绑定一个了queue A到Topic exchange并指定pattern是"animal.bird.*",那么在发送消息时,如果发送的key是"animal.bird.somebird",则这个消息就可以转发到queue A。而"animal.fish.somefish"或者"animal.bird"这样就不行,相当于*表示了一个占位符。至于"#",它表示省略。举例来说,queue B绑定到Topic exchange指定pattern是"animal.#",那么key是"animal.bird.somebird"、"animal.bird"、"animal.fish"的消息可以发送的queue B。

Headers exchange还没研究。

Queues

消息队列。消息队列是消息的载体,我们可以在应用中定义多个消息队列。消息在被消耗之前,是存储在queue中的,而queue的创建和维护是在RabbitMQ服务器上的。所以没被消耗的消息占用的是消息服务器的内存而不是应用的内存。一个queue可以绑定到任意个exchange中。

Consumers

消息消费者。消息的消费可以有两种方式进行。一种是定义queue的listener,只要消息发送到queue就会触发对应listener的onMessage()方法,相当于消息的push。值得注意的是,一个queue可以定义多个对应的consumer,一个consumer也可以监听多个queue。另一种是消息的pull,我们通过可以指定queue的name对消息进行拉取。

转载于:https://www.cnblogs.com/derry9005/p/6474945.html

你可能感兴趣的文章
又混了一天班
查看>>
九度oj 1006
查看>>
HDU6400-2018ACM暑假多校联合训练1004-Parentheses Matrix-构造
查看>>
最短路问题专题
查看>>
《Redis复制与可扩展集群搭建》看后感
查看>>
Jquery Mobile总结
查看>>
223. Rectangle Area
查看>>
spring boot + velocity中文乱码解决方式
查看>>
读罢泪两行,人生成长必须面对的10个残酷事实
查看>>
ASP 32位程序运行与64位问题:ADODB.Connection 错误 '800a0ea9' 未指定提供程序,也没有指派的默认提供程序。...
查看>>
xcode-git笔记
查看>>
TCP和UDP的优缺点及区别
查看>>
MATLAB消除曲线毛刺Outlier Detection and Removal [hampel]
查看>>
MySQL DATE_SUB() 函数
查看>>
在SSH框架下按条件分页查询
查看>>
jquery选择器
查看>>
【javascript学习——《javascript高级程序设计》笔记】DOM操作
查看>>
高效的SQL语句翻页代码
查看>>
NPAPI插件开发详细记录:用VS2010开发NPAPI插件步骤
查看>>
linux下Makefile全解(二)
查看>>