package com.cool.jms;import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;/***  消息生产者* Created by hejin on 2017/4/12 0012.*/
public class JMSProducer {//默认连接用户名private static final String USER= ActiveMQConnection.DEFAULT_USER;//默认连接密码private static final String PASSWORD=ActiveMQConnection.DEFAULT_PASSWORD;//默认连接地址private static final String URL=ActiveMQConnection.DEFAULT_BROKER_URL;//发送的消息数量private static final int SENDNUM=10;public static void main(String[] args) throws JMSException {//连接工厂ConnectionFactory connectionFactory;//连接Connection connection;//会话(接收或发送消息的线程)Session session;//消息目的地Destination destination;//消息生产者MessageProducer messageProducer;//实例化连接工厂connectionFactory=new ActiveMQConnectionFactory(JMSProducer.USER,JMSProducer.PASSWORD,JMSProducer.URL);try {//通过连接工厂获取连接connection = connectionFactory.createConnection();//启动连接connection.start();//创建sessionsession=connection.createSession(true,Session.AUTO_ACKNOWLEDGE);//创建一个名称为HelloWorld的消息队列destination= session.createQueue("HelloWorld");//创建消息生产者messageProducer = session.createProducer(destination);//发送消息sendMessage(session,messageProducer);//提交session.commit();} catch (Exception e) {e.printStackTrace();}}public static void sendMessage(Session session,MessageProducer messageProducer) throws Exception{for (int i=0;i<JMSProducer.SENDNUM;i++){//创建需要发送的消息TextMessage message = session.createTextMessage("ActiveMQ发送消息:" + i);System.out.println("ActiveMQ发送消息:"+i);messageProducer.send(message);}}
}

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;/*** Created by hejin on 2017/4/12 0012.*/
public class JMSConsumer {//默认连接名称private static  String USER= ActiveMQConnection.DEFAULT_USER;//默认密码private static  String PASSWORD=ActiveMQConnection.DEFAULT_PASSWORD;//默认连接地址private static String URL=ActiveMQConnection.DEFAULT_BROKER_URL;public static void main(String[] args) {//连接工厂ConnectionFactory connectionFactory;//连接Connection connection;//会话 接收或发送消息的进程Session session;//消息的目的地Destination destination;//消息的消费者MessageConsumer messageConsumer;//实例化连接工厂connectionFactory=new ActiveMQConnectionFactory(JMSConsumer.USER,JMSConsumer.PASSWORD,JMSConsumer.URL);//IDEA快速捕获异常快捷键:Ctrl+Alt+Ttry {//通过连接工厂获取连接connection=connectionFactory.createConnection();//启动连接connection.start();//创建sessionsession=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);//创建一个HelloWorld的消息队列destination=session.createQueue("HelloWorld");//创建消息消费者messageConsumer = session.createConsumer(destination);while(true){TextMessage message = (TextMessage) messageConsumer.receive(100000);if(message!=null){System.out.println("收到的消息:"+message.getText());}else{break;}}} catch (JMSException e) {e.printStackTrace();}}
}

控制台输出: