首页 > 安全资讯 >

java开发JMS for Jboss4

13-07-20

针对好多朋友,想熟悉JMS相关开发知识,网上例子写的也比较乱,特手动编写了一个例子和服务器配置,希望大家喜欢,支持我1) jboss配置Queue消息队列 打开jboss安装目录,找到server/default/deploy/jms下找到...

针对好多朋友,想熟悉JMS相关开发知识,网上例子写的也比较乱,特手动编写了一个例子和服务器配置,希望大家喜欢,支持我
 
 
 
 
1)  jboss配置Queue消息队列
 
     打开jboss安装目录,找到server/default/deploy/jms下找到文件jbossmq-destinations-service.xml文件
 
     增加配置代码如下:
 
       <mbean code="org.jboss.mq.server.jmx.Queue" 
                name="jboss.mq.destination:service=Queue,name=testQueue">
<depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
</mbean>
 
   启动jboss在jmx-console下,即可查询发布testQueue队列成功的消息,很简单
 
2)开发发送客户端,拷贝jboss目录下client文件夹下的jbossall-client.jar到项目lib下,编写代码如下
 
 import java.util.Properties;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
 
 
public class JmsSender {
public static void main(String[] args) throws JMSException, NamingException {
 
 Properties env = new Properties();
         env.put(Context.PROVIDER_URL, "127.0.0.1:1099");
         env.put(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContextFactory");
         env.put(Context.URL_PKG_PREFIXES,"org.jboss.naming:org.jnp.interfaces");
         Context context = new InitialContext(env);
         
         QueueConnectionFactory factory = (QueueConnectionFactory)context.lookup("ConnectionFactory");
         QueueConnection queueConnection = factory.createQueueConnection();  
         QueueSession queueSession = queueConnection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);   
         Queue queue = (Queue) context.lookup("queue/testQueue"); 
         TextMessage message = queueSession.createTextMessage();  
         message.setText("ddddd"); 
         QueueSender queueSender = queueSession.createSender(queue);
         queueSender.send(queue, message);
         System.out.println("-------------");
  }
}
 
开发完毕,很简单
 
3)接收消息端打开如下
 
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
 
public class JmsReader {
public static void main(String[] args) throws JMSException, NamingException {
Properties env = new Properties();
         env.put(Context.PROVIDER_URL, "localhost:1099");
         env.put(Context.INITIAL_CONTEXT_FACTORY,
                 "org.jnp.interfaces.NamingContextFactory");
         env.put(Context.URL_PKG_PREFIXES,
                 "org.jboss.naming:org.jnp.interfaces");
         /*
          * 利用参数连接好服务器
          */
         InitialContext ic = new InitialContext(env);
         QueueConnection cs = ((QueueConnectionFactory) ic
                 .lookup("ConnectionFactory")).createQueueConnection();
         /*
          * 配置并连接相应的queue
          */
         Queue q = (Queue) ic.lookup("queue/testQueue");
         QueueSession qss = cs.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
         QueueReceiver qr = qss.createReceiver(q);
          /*
          * 启动链接
          */
          cs.start();
      
         /*
          * 开始接受,然后处理接收到的 message
          */
         TextMessage message=(TextMessage)qr.receive();
        System.out.println(message.getText());
             
        cs.close();  
}
 
}
 
 
相关文章
最新文章
热点推荐