ActiveMQ整合以及使用
1.activeMq 的连接工厂 整合spring 需要加入缓存 原因
Spring中发送消息的核心是JmsTemplate,然而Jmstemplate的问题是在每次调用时都要打开关闭session和producter,效率很低,所以引申出了PooledConnectionFactory连接池,用于缓存session和producter。然而这还不是最好的。从spring2.5.3版本后,Spring又提供了CachingConnectionFactory,这才是首选的方案。然而CachingConnectionFactory有一个问题必须指出,默认情况下,CachingConnectionFactory只缓存一个session,在它的JavaDoc中,它声明对于低并发情况下这是足够的。与之相反,PooledConnectionFactory的默认值是500。这些设置,在很多情况下,需要亲自去测试并验证。我将其设置为100,对我来说还是很不错
例如 在发布消息的时候就需要使用session来进行send
2.整合配置
1>配置文件里面创建 activemq自带的factorybeen 传入服务端的地址 密码 账号
2>连接工厂里面需要与spring的带有缓存的连接工厂整合 并且设置session的大小
3>设置消息队列的模式和模板 点对点 还是发布订阅模式 一般可以设置两种 看业务情况而定
4>使用模板对象来进行操作 消息的传送
5>消费方怎么配置其他配置和发送方一样 但是接受方还有额外的配置
在监听器里面需要传入几个参数
1.mq的连接工厂
2.定义队列的目的地
3.出入自己定义的监听器 需要实现MessageListener的接口实现里面的方法
6>消费方接受消息的方法需要实现MessageListener