生產(chǎn)者(producer)->消息隊(duì)列(message queue)
成都創(chuàng)新互聯(lián)公司提供做網(wǎng)站、成都網(wǎng)站設(shè)計(jì)、網(wǎng)頁設(shè)計(jì),高端網(wǎng)站設(shè)計(jì),一元廣告等致力于企業(yè)網(wǎng)站建設(shè)與公司網(wǎng)站制作,10年的網(wǎng)站開發(fā)和建站經(jīng)驗(yàn),助力企業(yè)信息化建設(shè),成功案例突破成百上千,是您實(shí)現(xiàn)網(wǎng)站建設(shè)的好選擇.
package com.java1234.activemq; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory; /** * 消息生產(chǎn)者 * @author Administrator * */ public class JMSProducer { private static final String USERNAME=ActiveMQConnection.DEFAULT_USER; // 默認(rèn)的連接用戶名 private static final String PASSWORD=ActiveMQConnection.DEFAULT_PASSWORD; // 默認(rèn)的連接密碼 private static final String BROKEURL=ActiveMQConnection.DEFAULT_BROKER_URL; // 默認(rèn)的連接地址 private static final int SENDNUM=10; // 發(fā)送的消息數(shù)量 public static void main(String[] args) { ConnectionFactory connectionFactory; // 連接工廠 Connection connection = null; // 連接 Session session; // 會(huì)話 接受或者發(fā)送消息的線程 Destination destination; // 消息的目的地 MessageProducer messageProducer; // 消息生產(chǎn)者 // 實(shí)例化連接工廠 connectionFactory=new ActiveMQConnectionFactory(JMSProducer.USERNAME, JMSProducer.PASSWORD, JMSProducer.BROKEURL); try { connection=connectionFactory.createConnection(); // 通過連接工廠獲取連接 connection.start(); // 啟動(dòng)連接 session=connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); // 創(chuàng)建Session destination=session.createQueue("FirstQueue1"); // 創(chuàng)建消息隊(duì)列 messageProducer=session.createProducer(destination); // 創(chuàng)建消息生產(chǎn)者 sendMessage(session, messageProducer); // 發(fā)送消息 session.commit(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } finally{ if(connection!=null){ try { connection.close(); } catch (JMSException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } } /** * 發(fā)送消息 * @param session * @param messageProducer * @throws Exception */ public static void sendMessage(Session session,MessageProducer messageProducer)throws Exception{ for(int i=0;i<JMSProducer.SENDNUM;i++){ TextMessage message=session.createTextMessage("ActiveMQ 發(fā)送的消息"+i); System.out.println("發(fā)送消息:"+"ActiveMQ 發(fā)送的消息"+i); messageProducer.send(message); } } }
消費(fèi)者(Consumer)--(監(jiān)聽)->消息隊(duì)列
package com.java1234.activemq; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageConsumer; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory; /** * 消息消費(fèi)者 * @author Administrator * */ public class JMSConsumer2 { private static final String USERNAME=ActiveMQConnection.DEFAULT_USER; // 默認(rèn)的連接用戶名 private static final String PASSWORD=ActiveMQConnection.DEFAULT_PASSWORD; // 默認(rèn)的連接密碼 private static final String BROKEURL=ActiveMQConnection.DEFAULT_BROKER_URL; // 默認(rèn)的連接地址 public static void main(String[] args) { ConnectionFactory connectionFactory; // 連接工廠 Connection connection = null; // 連接 Session session; // 會(huì)話 接受或者發(fā)送消息的線程 Destination destination; // 消息的目的地 MessageConsumer messageConsumer; // 消息的消費(fèi)者 // 實(shí)例化連接工廠 connectionFactory=new ActiveMQConnectionFactory(JMSConsumer2.USERNAME, JMSConsumer2.PASSWORD, JMSConsumer2.BROKEURL); try { connection=connectionFactory.createConnection(); // 通過連接工廠獲取連接 connection.start(); // 啟動(dòng)連接 session=connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE); // 創(chuàng)建Session destination=session.createQueue("FirstQueue1"); // 創(chuàng)建連接的消息隊(duì)列 messageConsumer=session.createConsumer(destination); // 創(chuàng)建消息消費(fèi)者 messageConsumer.setMessageListener(new Listener()); // 注冊(cè)消息監(jiān)聽 } catch (JMSException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
監(jiān)聽(Listener)消息隊(duì)列
package com.java1234.activemq; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; /** * 消息監(jiān)聽 * @author Administrator * */ public class Listener implements MessageListener{ @Override public void onMessage(Message message) { // TODO Auto-generated method stub try { System.out.println("收到的消息:"+((TextMessage)message).getText()); } catch (JMSException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
網(wǎng)站欄目:JMS消息隊(duì)列ActiveMQ(點(diǎn)對(duì)點(diǎn)模式)
URL網(wǎng)址:http://aaarwkj.com/article10/gdsdgo.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站排名、外貿(mào)網(wǎng)站建設(shè)、網(wǎng)站內(nèi)鏈、微信小程序、搜索引擎優(yōu)化、企業(yè)建站
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)