Maven 配置文件
org.apache.activemq activemq-all 5.9.1
provider 生产者代码
import static commons.Constants.*;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.MessageProducer;import javax.jms.Queue;import javax.jms.Session;import org.apache.activemq.ActiveMQConnectionFactory;public class Provider { public static void main(String[] args) { ConnectionFactory cf = new ActiveMQConnectionFactory(URL); //创建工厂链接对象 Connection connection = null; Session session = null; Queue queue = null; MessageProducer producer = null; try { connection = cf.createConnection(); //使用工厂创建链接 connection.start(); //开启连接 session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); //使用连接对象创建会话 queue = session.createQueue(QUEUE_ONE); //使用会话创建目标对象 producer = session.createProducer(queue); // 使用会话、目标对象创建生产者对象 Message message = session.createTextMessage("hello ,i'm not good"); //使用会话创建消息对象 producer.send(message);//发送消息 System.out.println("send:"+message.toString()); } catch (JMSException e) { e.printStackTrace(); }finally { if(producer != null) { try { producer.close(); } catch (JMSException e) { e.printStackTrace(); } } if(session != null) { try { session.close(); } catch (JMSException e) { e.printStackTrace(); } } if(connection != null) { try { connection.close(); } catch (JMSException e) { e.printStackTrace(); } } } }}
Consumer 消费者
import static commons.Constants.*;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.MessageConsumer;import javax.jms.MessageListener;import javax.jms.Queue;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;public class Consumer { public static void main(String[] args) { ConnectionFactory cf = new ActiveMQConnectionFactory(URL); Connection connection = null; Session session = null; MessageConsumer consumer = null; try { connection = cf.createConnection(); connection.start(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Queue queue = session.createQueue(QUEUE_ONE); consumer = session.createConsumer(queue); //向consumer对象中设置一个messageListener对象，用来接收消息 consumer.setMessageListener(new MessageListener() { public void onMessage(Message message) { if(message instanceof TextMessage) { //当前测试，仅测试Text类型的消息 TextMessage text = (TextMessage)message; try { System.out.println(text.getText()); } catch (JMSException e) { e.printStackTrace(); } } } }); System.out.println("consumer : "+System.currentTimeMillis()); System.in.read(); }catch(Exception e) { e.printStackTrace(); }finally { if(consumer != null) { try { consumer.close(); } catch (JMSException e) { e.printStackTrace(); } } if(session != null) { try { session.close(); } catch (JMSException e) { e.printStackTrace(); } } if(connection != null) { try { connection.close(); } catch (JMSException e) { e.printStackTrace(); } } } }}
Constants 常量类
package commons;public interface Constants { String URL = "tcp://192.168.49.128:61616"; String QUEUE_ONE = "CQC_ONE"; }