1. 程式人生 > >activeMQ的建立生產者和消費者的demo(佇列模式)

activeMQ的建立生產者和消費者的demo(佇列模式)

佇列模式流程圖(有點醜,網上查的)


程式碼實現生產者

 String url="tcp://47.93.188.85:61616";
     //目標名稱
   String name="test";
 //建立連線工廠
 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
//建立連線
 Connection connection = connectionFactory.createConnection();
 //啟動連線
  connection.start();
 //建立會話
 Session session
= connection.createSession(false, Session.AUTO_ACKNOWLEDGE); //建立目標 Destination destination = session.createQueue(name); //建立一個生產者 MessageProducer messageProducer = session.createProducer(destination); //建立訊息 TextMessage textMessage= session.createTextMessage("beijin,beijin"); //傳送訊息 messageProducer
.send(textMessage);

2.x消費者的程式碼實現

   String url="tcp://47.93.188.85:61616";
  String name="test";
 //建立連線工廠
 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
//建立連線
 Connection connection = connectionFactory.createConnection();
 //啟動連線
  connection.start();
 //建立會話
 Session session
= connection.createSession(false, Session.AUTO_ACKNOWLEDGE); //建立目標 Destination destination = session.createQueue(name); //建立一個消費著 MessageConsumer messageConsumer = session.createConsumer(destination); //穿件一個監聽器 messageConsumer.setMessageListener(new MessageListener() { public void onMessage(Message message) { System.out.println("message = " + message); } });