<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)  編輯  收藏

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


    網站導航:
     
    主站蜘蛛池模板: 免费国产高清视频| 国产福利在线观看免费第一福利| 黑人粗长大战亚洲女2021国产精品成人免费视频 | 一级片在线免费看| 亚洲精品A在线观看| 人人公开免费超级碰碰碰视频| 免费人成视网站在线观看不卡| 午夜亚洲国产精品福利| 亚洲国产精品日韩专区AV| 人妻仑乱A级毛片免费看| 亚洲综合无码精品一区二区三区 | 91高清免费国产自产拍2021| 亚洲网址在线观看| 成年人免费视频观看| 亚洲AV无码AV日韩AV网站| 亚洲成av人片不卡无码久久| 久久久久久av无码免费看大片 | 亚洲黄网站wwwwww| 毛片a级毛片免费播放100| 亚洲一区二区无码偷拍| 一本色道久久88综合亚洲精品高清| 五月婷婷免费视频| 国产精品亚洲A∨天堂不卡| 亚洲电影免费在线观看| 黄网站色视频免费看无下截 | 精品一区二区三区免费毛片爱| 亚洲熟妇色自偷自拍另类| 日韩伦理片电影在线免费观看| 香蕉国产在线观看免费| 亚洲成AV人片在线观看WWW| 国产成人精品免费视| 女bbbbxxxx另类亚洲| 亚洲成AV人片在线播放无码| 可以免费看黄视频的网站| 白白色免费在线视频| 亚洲乱码精品久久久久..| 84pao国产成视频免费播放| 久久久久久亚洲精品影院| 国产又大又粗又长免费视频 | 亚洲人成77777在线播放网站不卡 亚洲人成77777在线观看网 | 久久久久亚洲AV成人无码网站|