内容简介:在一些项目中,单独开启一个ActiveMQ,对于项目实施来说有时略显繁琐。所以我们将ActiveMQ内嵌到Tomcat,Tomcat启动同时就顺带启动了ActiveMQ。由此我们需要掌握三个个重要的知识点ActiveMQ中的BrokerService自启动Servlet配置
在一些项目中,单独开启一个ActiveMQ,对于项目实施来说有时略显繁琐。所以我们将ActiveMQ内嵌到Tomcat,Tomcat启动同时就顺带启动了ActiveMQ。由此我们需要掌握三个个重要的知识点
ActiveMQ中的BrokerService
自启动Servlet配置
使用jconsole了解嵌入ActiveMQ运行状态
一、开启BrokerService
在pom.xml添加ActiveMQ依赖,本次代码实例采用5.7版本,记住只需要activemq-core就行。
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-core</artifactId>
<version>5.7.0</version>
</dependency>
在编写BrokerService代码部分,主要注意三个点
是否需要在jconsole中显示监控信息 broker.setUseJmx(true)
设置连接用户名和密码,如何使用验证插件
是否持久化,存储位置设置,持久化配置
所以需要启动一个连接地址 tcp://localhost:61616,用户名为admin,密码为admin,需要持久化,持久化数据文件存储地址为 /activemq ,需要启动jconsole监控的BrokerService的代码如下:
1 // author:herbert qq:464884492
2 BrokerService broker = new BrokerService();
3 broker.setUseJmx(true); // 开启监控
4 broker.setPersistent(true); // 持久化
5 broker.setBrokerName("Test");
6 SimpleAuthenticationPlugin sap = new SimpleAuthenticationPlugin();
7 AuthenticationUser au = new AuthenticationUser("admin", "admin","users");
8 ArrayList<AuthenticationUser> d = new ArrayList<AuthenticationUser>();
9 d.add(au);
10 sap.setUsers(d); // 用户验证
11 broker.setPlugins(new BrokerPlugin[] { sap });
12 String mqDataPath = "/activemq"; // 存储位置
13 broker.getPersistenceAdapter().setDirectory(new File(mqDataPath));
14 broker.addConnector("tcp://localhost:61616"); // 连接地址
15 broker.start();
二、生产者和消费者
ActiveMQ中,通用的消息传递方式有两种
队列,支持消息持久化,未消费的消息,在重启后依然存在。若有多个消费者,在每次提取一条消息的前提下,所有消费均分队列中的消息
主题,不支持消息持久化,未消费的消息,在重启后消息丢失。若有多个消费,每个消费者依次消费主题中所有消息
不管是生产者还是消费者代码编写,主要是4个步骤
建立连接,采用failover:()方式,自动断线重连
建立Session,获取发送或接收目标Destination ,指定是队列(session.createQueue(queueName)),还是主题(session.createTopic(topicName))
通过Session获取生产者或消费者
生产或消费消息
我们现在编写一个生产者的代码,并循环产生10条消息
1 // author:herbert qq:464884492
2 String mqConnUrl = "tcp://localhost:61616";
3 String connUrl = "failover:(" + mqConnUrl.trim()+ ")?initialReconnectDelay=1000&maxReconnectDelay=30000";
4 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin","admin", connUrl);
5 javax.jms.Connection connection = connectionFactory.createConnection();
6 connection.start();
7 Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
8 Destination destination = session.createQueue("system");
9 MessageProducer messageProducer = session.createProducer(destination);
10
11 for (int i = 0; i < 10; i++) {
12 javax.jms.TextMessage message = session.createTextMessage("ActiveMQ 发送的消息" + i);
13 System.out.println("发送消息:" + "ActiveMQ 发送的消息" + i);
14 messageProducer.send(message);
15 }
编写一个消费,消费上边的10条消息
// author:herbert qq:464884492
String mqConnUrl = "tcp://localhost:61616";
String connUrl = "failover:(" + mqConnUrl.trim()+ ")?initialReconnectDelay=1000&maxReconnectDelay=30000";
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "admin", connUrl);
javax.jms.Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("system");
MessageConsumer messageConsumer = session.createConsumer(destination);
br/>@Override
public void onMessage(javax.jms.Message message) {ActiveMQTextMessage m = (ActiveMQTextMessage) message;
try {
System.out.println("接收到:" + m.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
});
运行效果
可见,我们生产者,产生的10条消息,已成功被消费者处理了。
三、监控嵌入的ActiveMQ
对于嵌入的ActiveMQ,在BrokerService启动前需要设置 broker.setUseJmx(true);然后找到你的JAVA_HOME,切换到bin,输入jconsole命令。
待jconsole启动后,选择ActiveMQ所在的进程。连接后选择Mbean页签
红框的地方分别为已消费和已进入MQ中的消息的条数。选择操作,找到那个SendTextMessage还可以想此队列发送消息。
四、Selvelt跟随Tomcat启动
对于Tomcat7.x版本之后Tomcat,Selvelt都可以通过直接在代码中通过注解的方式配置URl连接,一起是否自启动loadOnStartup这个值>=0表示需要自启动,值越小优先级越高
1 // author:herbert qq:464884492
2 @WebServlet(urlPatterns = "/initmq", loadOnStartup = 1)
3 public class InitMqServlet extends HttpServlet {
4 @Override
5 public void init(ServletConfig config) throws ServletException {
6 super.init(config);
7 // 这里编写启动ActiveMQ代码
8 }
9 }
五、总结
这次以ActiveMQ作为消息队列使用切入点,总体上说还比较顺利。其中唯一出现问题的地方就是对于activeMQ依赖过多,多依赖了jaractivemq-broker,导致消息能连接,但不能发送消息。后边直接换成 activemq-all,有出现slf4j日志冲突,使用exclusions依然不能解决问题。最终只依赖 activemq-core,完美解决所有问题。
以上所述就是小编给大家介绍的《ActiveMQ嵌入Tomcat》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!
猜你喜欢:本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
数据结构与算法分析
张琨、张宏、朱保平 / 人民邮电出版社 / 2016-2-1 / 45
本书共分10章,主要包括第1章绪论,第2章线性表,第3章栈和队列,第4章串,第5章数组和广义表,第6章 树和二叉树,第7章图,第8章查找,第9章内部排序,第10章算法分析。其内容模块涵盖了课堂教学、习题课教学、实验教学、自学辅导、综合训练等。立体化教材的使用在提高教学效率、增强教学效果、加大教学信息量、培养学生的应用与实践能力。 作者简介一起来看看 《数据结构与算法分析》 这本书的介绍吧!