随笔-159  评论-114  文章-7  trackbacks-0
JMS 使用
启动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 阅读(411) 评论(0)  编辑  收藏 所属分类: 达内学习总结

只有注册用户登录后才能发表评论。
网站导航:
 
Powered by: 博客园 模板提供：沪江博客 Copyright ©2024 北国狼人的BloG