<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    細心!用心!耐心!

    吾非文人,乃市井一俗人也,讀百卷書,跨江河千里,故申城一游; 一兩滴辛酸,三四年學業,五六點粗墨,七八筆買賣,九十道人情。

    BlogJava 聯系 聚合 管理
      1 Posts :: 196 Stories :: 10 Comments :: 0 Trackbacks

    JMS編程模式

    消息形式:

    點對點為兩個客戶之間建立消息隊列,使兩個客戶端之間通過隊列實現點對點的消息傳遞

    注:類似數據結構里的隊列,先進先出

    主題消息,在消息中間件上建立一個主題,沒個客戶端都可已向這個主題發送消息,接受消息

    注:類似廣播的方式

    開發流程:

     


    使用JMS步驟

    1.創建一個JNDI上下文

    Context  init initCtx =new InitialContext(env);

    2.查找創建JMS連接使用的工廠類(Connnect Factory)

    對于主題消息:

    Object tmp=initCtx.lookup(“Connnect Factory”);

    TopicConnectionFactory tcf=( TopicConnectionFactory) tmp;

    對于點對點消息:

    Object tmp=initCtx.lookup(“Connnect Factory”);

    QueueConnectionFactory tcf=( QueueConnectionFactory) tmp;

    3.查找JMS的目標對象(Destination)

    對于主題消息:

    Topic topic=(Topic)iniCtx.lookup(“topic/testTopic”);

    對于點對點消息:

    Queue queue (Queue)iniCtx.lookup(“queue /A”);

    4.創建JMS連接(Connection)

    對于主題消息:

    TopicConnection conn=tcp.createTopicConnection();

    對于點對點消息:

    QueueConnection conn=tcp.createQueueConnection ();

    5.創建JMS會話(session)

    對于主題消息:

    TopicSession session=conn.createTopicSession(fasle,Session.AUTO_ACKNOWLEDGE);

    對于點對點消息:

    QueueSession session= conn.createQueueSession(true,0);

    6.創建消息的生產和消費者

    生產者:

    對于主題消息:

    TopicPublisher publisher=session.createPublisher(topic);

    對于點對點消息:

    QueueSender sender = session.createSender (queue);

    消費者:

    對于主題消息:

    TopicSubscriber subscriber=session.createSubscriber (topic);

    對于點對點消息:

    QueueReceiver receiver= session.createReceiver (queue);

    7.注冊消息的監聽者

    對于主題消息:

    TextListener listener=new TextListener();

    subscriber.setMessageListener(listener);

    對于點對點消息:

    TextListener listener=new TextListener();

    receiver.setMessageListener(listener);

    8.開始JMS的連接

       conn.start();

    9.發送和接受消息

    發送消息:

    對于主題消息:

    publisher.publish(message);

    對于點對點消息:

    sender.send(message);

    接受消息:

    對于主題消息:

    Message msg= subscriber.receive();

    對于點對點消息:

    Message msg= receiver.receive(1000);

    10.停止和關閉JMS連接

    conn.stop();

    session.close();

    conn.close();

    posted on 2007-05-06 11:43 張金鵬 閱讀(97) 評論(0)  編輯  收藏

    只有注冊用戶登錄后才能發表評論。


    網站導航:
     
    主站蜘蛛池模板: 国产精品亚洲美女久久久| 亚洲∧v久久久无码精品| 黄色网页在线免费观看| 亚洲黄色在线观看网站| 国产免费人视频在线观看免费| 国产日韩在线视频免费播放| 亚洲明星合成图综合区在线| 免费观看日本污污ww网站一区| 午夜视频免费在线观看| 亚洲国产成人精品无码区二本| 亚洲日本va在线视频观看| 人妻视频一区二区三区免费| 9久久免费国产精品特黄| 亚洲中文字幕久久久一区| 亚洲人成色77777| 日本免费观看网站| 57pao国产成视频免费播放 | caoporn国产精品免费| 亚洲色偷偷av男人的天堂| 亚洲国产精品一区二区九九 | 无码人妻一区二区三区免费看 | 亚洲AV综合永久无码精品天堂| 国产AV无码专区亚洲AV毛网站| 午夜dj免费在线观看| 95老司机免费福利| 亚洲视频在线免费| 亚洲AV成人一区二区三区观看 | 亚洲综合久久综合激情久久| 亚洲国产精品成人| 大陆一级毛片免费视频观看i| 日韩精品无码专区免费播放| 一级A毛片免费观看久久精品| 亚洲中文字幕久久精品无码A| 亚洲美女视频一区二区三区| 精品亚洲综合久久中文字幕| 亚洲国产精品成人AV无码久久综合影院 | 91亚洲自偷手机在线观看| 在线播放亚洲第一字幕| 国产免费观看a大片的网站| 最近中文字幕无吗高清免费视频| 四虎影视成人永久免费观看视频|