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的源码
31fb000343cdda1fb9a2
31fb0003447d3f2e253e
RabbitTemplate
Spring amqp有AmqpTemplate一个具体实现类，那就是RabbitTemplate
可以使用RetryTemplate为RabbitTemplate配置重试相关的参数
通过XML形式配置重试参数
32170002856fdd1fffe5
-
initialInterval是重试的重试间隔时间
-
maxInterval是重试最大间隔时间
-
multiplier是从初始值到最大的增长倍数，其实我们还可以配置SimpleRetryPolicy来指定重试的次数
320d00020a3a77819325
通过Java配置类形式配置重试参数
320d00020b11caf10048
如果您觉得阅读本文对您有帮助，请点一下“喜欢”按钮，您的“喜欢”将是我最大的写作动力！如果您想持续关注我的文章，请扫描二维码，关注JackieZheng的微信公众号，我会将我的文章推送给您，并和您一起分享我日常阅读过的优质文章。
网友评论