Hello World---------queue

queue

1. 引入Jar 包  activemq-all-5.15.2.jar
2. Produce

3. package com.city.producer;import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;public class JMSProducer {//默认连接用户名private static final String USERNAME ="admin";//默认连接密码private static final String PASSWORD ="admin";//默认连接地址private static final String BROKEURL ="tcp://localhost:61616";//发送的消息数量private static final int SENDNUM = 10;public static void main(String[] args) {Connection connection= null;Session session= null;Queue queue;MessageProducer producer;TextMessage textMessage = null;ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(JMSProducer.USERNAME, JMSProducer.PASSWORD, JMSProducer.BROKEURL);try {connection = connectionFactory.createConnection();connection.start();session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);queue = session.createQueue("HelloWorld");producer = session.createProducer(queue);for (int i= 0;i<JMSProducer.SENDNUM;i++) {textMessage = session.createTextMessage("ActiveMQ 发送消息:" + i);System.out.println("发送消息：ActiveMQ 发送消息:" + i);producer.send(textMessage);}session.commit();} catch (JMSException e) {e.printStackTrace();try {session.close();connection.close();} catch (JMSException e1) {e1.printStackTrace();}}}
   }

4. Consumer

5. package com.city.consumer;import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;public class JMSConsumer {private static final String USERNAME = "admin";//默认连接用户名private static final String PASSWORD = "admin";//默认连接密码private static final String BROKEURL = "tcp://localhost:61616";//默认连接地址public static  void  main(String [] args) {ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(JMSConsumer.USERNAME, JMSConsumer.PASSWORD, JMSConsumer.BROKEURL);Connection connection = null;Session session =null;MessageConsumer consumer;Queue queue;try {connection = connectionFactory.createConnection();connection.start();session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);queue = session.createQueue("HelloWorld");consumer = session.createConsumer(queue);while (true) {TextMessage message  = (TextMessage)consumer.receive(1000);if (message!=null) {System.out.println("接受消息：ActiveMQ 接受消息:"+message.getText());} else {break;}}} catch (JMSException e) {e.printStackTrace();try {session.close();connection.close();} catch (JMSException e1) {e1.printStackTrace();}}System.out.println("AAAAAA");}
   }
   

6. 查看ActiveMQ ---------------http://127.0.0.1:8161/admin/
    

来自为知笔记(Wiz)