<dependencies><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-client</artifactId><version>5.13.4</version></dependency></dependencies><build><plugins><!-- java编译插件 --><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.2</version><configuration><source>1.8</source><target>1.8</target><encoding>UTF-8</encoding></configuration></plugin></plugins></build>

/*** @Auther:qingmu* @Description:脚踏实地,只为出人头地* @Date:Created in 16:16 2019/4/23*/import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;/*** 点对点模式* 生产者*/public class QueueProducer {public static void main(String[] args) throws Exception {//1.创建连接工厂ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.200.128:61616");//2.获取连接Connection connection = connectionFactory.createConnection();//3.启动连接
        connection.start();//4.获取session  (参数1：是否启动事务,参数2：消息确认模式)/***  AUTO_ACKNOWLEDGE = 1    自动确认•    CLIENT_ACKNOWLEDGE = 2    客户端手动确认•    DUPS_OK_ACKNOWLEDGE = 3    自动批量确认•    SESSION_TRANSACTED = 0    事务提交并确认*/Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//5.创建队列对象Queue queue = session.createQueue("test-queue");//6.创建消息生产者MessageProducer producer = session.createProducer(queue);//7.创建消息TextMessage textMessage = session.createTextMessage("欢迎来到神奇的");//8.发送消息
        producer.send(textMessage);//9.关闭资源
        producer.close();session.close();connection.close();}
}

/*** @Auther:qingmu* @Description:脚踏实地,只为出人头地* @Date:Created in 16:23 2019/4/23*/import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;/*** 点对点模式* 消息消费者*/
public class QueueConsumer {public static void main(String[] args) throws Exception{//1.创建连接工厂ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.200.128:61616");//2.获取连接Connection connection = connectionFactory.createConnection();//3.启动连接
        connection.start();//4.获取session  (参数1：是否启动事务,参数2：消息确认模式)Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//5.创建队列对象Queue queue = session.createQueue("test-queue");//6.创建消息消费MessageConsumer consumer = session.createConsumer(queue);//7.监听消息consumer.setMessageListener(new MessageListener() {public void onMessage(Message message) {TextMessage textMessage=(TextMessage)message;try {System.out.println("接收到消息："+textMessage.getText());} catch (JMSException e) {// TODO Auto-generated catch block
                    e.printStackTrace();}}});//8.等待键盘输入
        System.in.read();//9.关闭资源
        consumer.close();session.close();connection.close();}
}

import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;/*** @Auther:qingmu* @Description:脚踏实地,只为出人头地* @Date:Created in 16:32 2019/4/23*/
public class TopicProducer {public static void main(String[] args) throws Exception{//1.创建连接工厂ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.200.128:61616");//2.获取连接Connection connection = connectionFactory.createConnection();//3.启动连接
        connection.start();//4.获取session  (参数1：是否启动事务,参数2：消息确认模式)Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//5.创建主题对象Topic topic = session.createTopic("test-topic");//6.创建消息生产者MessageProducer producer = session.createProducer(topic);//7.创建消息TextMessage textMessage = session.createTextMessage("欢迎来到神奇的世界");//8.发送消息
        producer.send(textMessage);//9.关闭资源
        producer.close();session.close();connection.close();}
}

/*** @Auther:qingmu* @Description:脚踏实地,只为出人头地* @Date:Created in 16:36 2019/4/23*/import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;/*** 订阅* 多对多*/
public class TopicConsumer {public static void main(String[] args) throws Exception{//1.创建连接工厂ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.200.128:61616");//2.获取连接Connection connection = connectionFactory.createConnection();//3.启动连接
        connection.start();//4.获取session  (参数1：是否启动事务,参数2：消息确认模式)Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//5.创建主题对象//Queue queue = session.createQueue("test-queue");Topic topic = session.createTopic("test-topic");//6.创建消息消费MessageConsumer consumer = session.createConsumer(topic);//7.监听消息consumer.setMessageListener(new MessageListener() {public void onMessage(Message message) {TextMessage textMessage=(TextMessage)message;try {System.out.println("接收到消息："+textMessage.getText());} catch (JMSException e) {// TODO Auto-generated catch block
                    e.printStackTrace();}}});//8.等待键盘输入
        System.in.read();//9.关闭资源
        consumer.close();session.close();connection.close();}
}