下面小编就为大家带来一篇基于java activemq的实例讲解。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
所需引入jar包：
jms-1.1.jar
activemq-all-5.15.0.jar
生产者
package com.mousewheel.demo; import javax.jms.connection; import javax.jms.connectionfactory; import javax.jms.destination; import javax.jms.jmsexception; import javax.jms.message; import javax.jms.messageconsumer; import javax.jms.messagelistener; import javax.jms.objectmessage; import javax.jms.session; import org.apache.activemq.activemqconnectionfactory; public class mqconsumerdemo { public static void main(string[] args) throws jmsexception { connectionfactory connectionfactory = new activemqconnectionfactory("admin", "admin", "tcp://192.168.31.33:61616"); connection connection = null; try { connection = connectionfactory.createconnection(); connection.start(); session session = connection.createsession(false, session.auto_acknowledge); destination destination = session.createqueue("test-queue"); messageconsumer consumer = session.createconsumer(destination); consumer.setmessagelistener(new messagelistener() { @override public void onmessage(message message) { try { mqbean bean = (mqbean) ((objectmessage) message).getobject(); system.out.println(bean); if (null != message) { system.out.println("收到消息" + bean.getname()); } } catch (exception e) { // todo: handle exception } } }); system.out.println("begin listen"); } catch (exception e) { // todo: handle exception } } }

消费者
package com.mousewheel.demo; import javax.jms.connection; import javax.jms.connectionfactory; import javax.jms.destination; import javax.jms.jmsexception; import javax.jms.message; import javax.jms.messageconsumer; import javax.jms.messagelistener; import javax.jms.objectmessage; import javax.jms.session; import org.apache.activemq.activemqconnectionfactory; public class mqconsumerdemo { public static void main(string[] args) throws jmsexception { connectionfactory connectionfactory = new activemqconnectionfactory("admin", "admin", "tcp://192.168.31.33:61616"); connection connection = null; try { connection = connectionfactory.createconnection(); connection.start(); session session = connection.createsession(false, session.auto_acknowledge); destination destination = session.createqueue("test-queue"); messageconsumer consumer = session.createconsumer(destination); consumer.setmessagelistener(new messagelistener() { @override public void onmessage(message message) { try { mqbean bean = (mqbean) ((objectmessage) message).getobject(); system.out.println(bean); if (null != message) { system.out.println("收到消息" + bean.getname()); } } catch (exception e) { // todo: handle exception } } }); system.out.println("begin listen"); } catch (exception e) { // todo: handle exception } } }

以上就是java activemq的代码实例分享的详细内容。