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

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

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

    隨筆-159  評(píng)論-114  文章-7  trackbacks-0
    啟動(dòng)Weblogic服務(wù)器,由于JMS,需要一個(gè)消息中間件,Tuxedo。本文使用的是WebLogic 9.1,與8.1的有所不同。

    登錄

    logon.jpg

    創(chuàng)建JMS servers

    server.jpg


    設(shè)置完JMS服務(wù)器以后,要設(shè)置JMS的Modules,以便JMS客戶端和接受端能查找相應(yīng)的JMSFactory和JMSdestination。

    module.jpg


    C:\bea\user_projects\domains\base_domain\config\jms

    會(huì)出現(xiàn)配置相關(guān)的配置文件

    建立兩個(gè)資源

    一個(gè)是ConnectionFactory,配置一個(gè)JNDI。

    另外一個(gè)是Queue-0,配置一個(gè)JNDI。

    resource.jpg

    import?javax.jms.*;
    import?java.util.Hashtable;
    import?javax.naming.*;
    import?java.io.*;

    public?class?QueueSend
    {
    ????
    ????
    public?static?void?main(String[]?args)?throws?Exception
    ????
    {
    ????????Hashtable?hash?
    =?new?Hashtable();
    ????????hash.put(Context.INITIAL_CONTEXT_FACTORY,
    "weblogic.jndi.WLInitialContextFactory");
    ????????hash.put(Context.PROVIDER_URL,
    "t3://localhost:7001");
    ????????
    ????????InitialContext?ic?
    =?new?InitialContext(hash);
    ????????
    ????????
    //找工廠
    ????????QueueConnectionFactory?factory?=?(QueueConnectionFactory)ic.lookup("jms/factory");
    ????????
    ????????System.out.println(factory.getClass());
    ????????
    ????????
    ????????
    //找文件夾,也就是目的地
    ????????Queue?queue?=?(Queue)ic.lookup("queue");
    ????????
    ????????System.out.println(queue.getClass());
    ????????
    ????????
    ????????
    //查API,接口有什么方法阿????????
    ????????QueueConnection?conn?=?(QueueConnection)factory.createQueueConnection();
    ????????
    ????????
    ????????
    //消息的接受者,是否給消息中間件回復(fù),否則重復(fù)發(fā)送。第二參數(shù)使用自動(dòng)確認(rèn)
    ????????QueueSession?session?=?conn.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
    ????????
    ????????
    //根據(jù)目的地,確定發(fā)送者
    ????????QueueSender?sender?=?session.createSender(queue);
    ????????
    ????????
    ????????
    //Message的創(chuàng)建要使用Session
    ????????
    ????????BufferedReader?buffer?
    =?new?BufferedReader(new?InputStreamReader(System.in));
    ????????
    ????????
    while(true)
    ????????
    {
    ????????????String?line?
    =?buffer.readLine();
    ????????????
    if(line.equals("quit"))
    ????????????
    {
    ????????????????TextMessage?message?
    =?session.createTextMessage("over");
    ????????????????sender.send(message);?????????
    ????????????????
    break;????????????????
    ????????????}

    ????????????TextMessage?message?
    =?session.createTextMessage(line);
    ????????????sender.send(message);?????????
    ????????}

    ????????
    ??????????????
    ????????
    ????}



    }


    察看一下Queue資源,就能看到自己發(fā)送的TextMessage。

    下回分解MDB。

    主站蜘蛛池模板: 亚洲精品自在线拍| 免费在线观看亚洲| 国产成人综合久久精品免费| aa午夜免费剧场| 亚洲视频一区在线观看| 国产乱子伦精品免费女| 亚洲免费在线播放| 精品国产_亚洲人成在线| 亚洲AV无码一区东京热久久| 巨胸喷奶水视频www网免费| 久久精品免费大片国产大片| 久久亚洲国产最新网站| 国产亚洲精品久久久久秋霞 | 国产色爽免费无码视频| 伊人久久五月丁香综合中文亚洲 | jiz zz在亚洲| 亚洲人成无码网站| 国产小视频在线免费| 日韩精品久久久久久免费| 亚洲AV成人精品一区二区三区| 久久精品九九亚洲精品| 亚洲欧洲久久av| 日本一区二区三区免费高清| 久久黄色免费网站| 一个人看的www免费在线视频| 亚洲情A成黄在线观看动漫软件| 亚洲成AV人片在| 亚洲毛片av日韩av无码| 日韩免费毛片视频| 免费a级毛片无码a∨蜜芽试看| 午夜免费福利片观看| 中国人免费观看高清在线观看二区| 久久久久亚洲精品无码网址色欲 | gogo免费在线观看| 亚洲av中文无码字幕色不卡| 91久久亚洲国产成人精品性色 | 国产又粗又猛又爽又黄的免费视频| 18成禁人视频免费网站| 国产成年无码久久久免费| 精品免费久久久久国产一区| 羞羞视频在线免费观看|