over 1.3 pre creat mouse ner creates apach
所需引入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 示例
来源: http://www.bubuko.com/infodetail-2308798.html