activeMQ的建立生產者和消費者的demo(佇列模式)
阿新 • • 發佈:2018-11-21
佇列模式流程圖(有點醜,網上查的)
程式碼實現生產者
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); } });