Spring集成RabbitMQ-连接和消息模板

2017-08-13 本文已影响160人 Jackie_Zheng

ConnectionFactory

ConnectionFactory是RabbitMQ服务掌握连接Connection生杀大权的重要组件
有了它，就可以创建Connection(org.springframework.amqp.rabbit.connection.Connection)
CachingConnectionFactory是仅有的默认会创建一个能够被应用共享的连接代理，下图是CachingConnectionFactory的继承关系
上篇提过，在CachingConnectionFactory的构造函数中，可以赋值hostname，username和passoword等
Channel这个概念应该熟悉，可以认为是一个连接通道，CachingConnectionFactory中默认最多可以缓存25个Channel，也可以通过方法setChannelCacheSize()设置

32000001faca6fdacc6a

下面是构造CachingConnectionFactory和创建Connection的代码

31fb000333d47022b1f0

当然，我们使用XML配置文件的方式也可以实现同样的效果

321e0001f08e874b3826

这还没完，使用了Spring-rabbitmq，我们还可以这样定义

32170002743eb385cbee

这是使用了RabbitMQ的命名空间定义的，这里除了定义hostname，username等，还定义了channel-cache-size，这就是我们前面说的默认值是25的属性。

消息发送的确认和返回

使用CachingConnectionFactory的方法setPublisherConfirms和setPublisherReturns设置为true，则创建的Channel就会回传这些属性

Connection和Channel监听器

Connection和Channel分别有对应的监听器接口ConnectionListener和ChannelListener，在CachingConnectionFactory上可以注册这两个监听器的实现类。
这两个接口可以监听有关Connection和Channel生命周期已经相关事件，比如创建、关闭等。
下面分别是ConnectionListener和ChannelListener的源码