隨筆-159 
評論-114 
文章-7 
trackbacks-0

          
	

          

          
	
					


          
	
	啟動Weblogic服務器，由于JMS，需要一個消息中間件，Tuxedo。本文使用的是WebLogic 9.1，與8.1的有所不同。

          登錄

          logon.jpg

          創建JMS servers

          server.jpg


          設置完JMS服務器以后，要設置JMS的Modules，以便JMS客戶端和接受端能查找相應的JMSFactory和JMSdestination。

          module.jpg


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

          會出現配置相關的配置文件

          建立兩個資源

          一個是ConnectionFactory，配置一個JNDI。

          另外一個是Queue-0，配置一個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();
          ????????
          ????????
          ????????          //消息的接受者，是否給消息中間件回復，否則重復發送。第二參數使用自動確認
          ????????QueueSession?session?=?conn.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
          ????????
          ????????          //根據目的地,確定發送者
          ????????QueueSender?sender?=?session.createSender(queue);
          ????????
          ????????
          ????????          //Message的創建要使用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資源，就能看到自己發送的TextMessage。

          下回分解MDB。

          



          
                                
                                
                                
          
	
          posted on 2006-03-25 21:34 北國狼人的BloG 閱讀(417) 評論(0)  編輯  收藏  所屬分類: 達內學習總結 
          

          







          
	    
    




          








          

				

          







    







          
        
	




主站蜘蛛池模板：
明光市|
彭山县|
陵川县|
根河市|
永新县|
日土县|
前郭尔|
常熟市|
克什克腾旗|
黄山市|
辽宁省|
通辽市|
蓝山县|
南宫市|
南安市|
三明市|
凉城县|
武宣县|
吉水县|
凌源市|
平南县|
西乡县|
谷城县|
临潭县|
苍山县|
沙坪坝区|
昔阳县|
仁寿县|
德昌县|
翼城县|
肇州县|
宁南县|
凤山县|
修文县|
衡南县|
嘉祥县|
弥渡县|
北海市|
桦甸市|
锡林浩特市|
佳木斯市|