jms

关于jboss的jms文章，网上很多，但基本雷同。而且大部分不太全，所以拷贝出来的代码，多多少少都有点问题，也有可能是和JBOSS的版本有关。

 

要求：JBOSS 6

 

代码：

package sty.main.jms;

import java.util.Hashtable;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import EDU.oswego.cs.dl.util.concurrent.CountDown;

public class SendRecvClient {
    static CountDown done = new CountDown(1);
    QueueConnection conn;
    QueueSession session;
    Queue que;
   
    public static class ExListener implements MessageListener {
        public void onMessage(Message msg) {
            done.release();
            TextMessage tm = (TextMessage)msg;
            try {
                System.out.println("onMessage, recv text=" + tm.getText());
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
       
    }
   
    @SuppressWarnings("unchecked")
    public void setupPTP() throws NamingException, JMSException {
        Hashtable env = new Hashtable();
        env.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
        env.put(Context.PROVIDER_URL, "jnp://135.251.208.116/");
        InitialContext iniCtx = new InitialContext(env);
        Object tmp = iniCtx.lookup("ConnectionFactory");
        QueueConnectionFactory qcf = (QueueConnectionFactory)tmp;
        conn = qcf.createQueueConnection();
        que = (Queue)iniCtx.lookup("/queue/DLQ");
        session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
        conn.start();
    }
   
    public void sendRecvAsync(String text) throws NamingException, JMSException {
        System.out.println("Begin sendRecvAsyc");
        setupPTP();
        QueueReceiver recv = session.createReceiver(que);
        recv.setMessageListener(new ExListener());
        QueueSender send = session.createSender(que);
        TextMessage tm = session.createTextMessage(text);
        send.send(tm);
        System.out.println("sendRecvAsyc sent=" + tm.getText());
        send.close();
        System.out.println("End sendRecvAsyc");
    }
   
    public void stop() throws JMSException {
        conn.stop();
        session.close();
        conn.close();
    }
   
    public static void main(String[] args) {
        SendRecvClient client = new SendRecvClient();
        try {
            client.sendRecvAsync("hello world");
            client.done.acquire();   
            client.stop();
            System.exit(0);
        } catch (NamingException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (JMSException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}

 

 

需要注意的问题：

1.关于JNDI获取queue的问题：que = (Queue)iniCtx.lookup("/queue/DLQ");在jboss 6中，JMS配置是在目录$JBOSS_HOME/server/default/deploy/hornetq下，查看文件hornetq-jms.xml下有条配置：

   <queue name="DLQ">
      <entry name="/queue/DLQ"/>
   </queue>

如果想新增queue，类似拷贝一份即可。

2.如果JBOSS和程序client运行的不是同一台机器上，启动时候请用$JBOSS_HOME/bin/run.sh -b 135.251.208.116 这里135.251.208.116是JBOSS所在机器的IP地址，请不要使用0.0.0.0