<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。

    主站蜘蛛池模板: 国产成人在线观看免费网站| 91精品免费在线观看| 在线观看永久免费视频网站 | 亚洲女同成av人片在线观看 | 美女啪啪网站又黄又免费| 成年女性特黄午夜视频免费看| 亚洲制服丝袜在线播放| 亚洲精品国产免费| 亚洲另类春色国产精品| 国产精品美女午夜爽爽爽免费| 狠狠色伊人亚洲综合网站色| 西西大胆无码视频免费| 亚洲AV无码AV吞精久久| 一本色道久久88综合亚洲精品高清| 无遮挡国产高潮视频免费观看| 亚洲片国产一区一级在线观看 | 色在线亚洲视频www| 日韩视频免费在线| 老妇激情毛片免费| 亚洲精品无码久久久久去q| 污污网站免费观看| 亚洲欧美国产日韩av野草社区| 免费a级毛片永久免费| 91视频精品全国免费观看| 亚洲酒色1314狠狠做| 久久久高清免费视频| 精品一区二区三区免费毛片| 国产亚洲美日韩AV中文字幕无码成人 | 夭天干天天做天天免费看| 黄色毛片免费观看| 亚洲综合国产精品| 日韩电影免费在线| 99久久99这里只有免费的精品| 亚洲国产成人精品久久| 亚洲av无码天堂一区二区三区| 久久免费公开视频| 老子影院午夜伦不卡亚洲| 久久亚洲精品无码| 日本特黄特色aa大片免费| 永久免费不卡在线观看黄网站| 亚洲av无码电影网|