文档章节

EJB3.0 JBoss的JMS实例

我想去看一看大海
 我想去看一看大海
发布于 2014/06/24 14:10
字数 461
阅读 64
收藏 1

1. 引入开发JMS相关Jar包

compile 'org.jboss.javaee:jboss-jms-api-1.1_spec:5.0.2.GA'



2. 在JBoss中配置Destination


我使用的是jboss-4.2.3.GA,如果启动模式是default,可以在default/deploy/jms目录下找到jbossmq-destinations-service.xml,进行相关配置,其它版本参见相应文档

<mbean code="org.jboss.mq.server.jmx.Queue"
	 name="jboss.mq.destination:service=Queue,name=myQueue">
    <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
  </mbean>



3. 编写接收队列消息的代码, 需要实现MessageListener接口


package com.icode.jejb.message;

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

/**
 * Created with IntelliJ IDEA.
 * User: ZhongGang
 * Date: 14-6-20
 * Time: 下午11:22
 */
@MessageDriven(activationConfig = {
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
        @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/myQueue")
})
public class LogMessage implements MessageListener {

    @Override
    public void onMessage(Message message) {
        try {
            TextMessage textMessage = (TextMessage) message;
            System.out.println("Received message: " + textMessage.getText());
        } catch (JMSException e) {
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
        }
    }
}

@MessageDriven注解定义类是一个消息驱动Bean, @ActivationConfigProperty定义相关的属性,基本的必要的属性要指定Destination的类型,是Topic还是Queue,Destination的名称

4. 编写发送消息的代码

package com.icode.jejb.web.servlet;

import javax.jms.*;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;

/**
 * Created with IntelliJ IDEA.
 * User: alexz
 * Date: 14-6-23
 * Time: 下午3:32
 * To change this template use File | Settings | File Templates.
 */
public class SendMessageServlet extends HttpServlet {

    @Override
    protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        try {
            String message = req.getParameter("message");
            InitialContext context = new InitialContext();
            QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory) context.lookup("ConnectionFactory");
            QueueConnection queueConnection = queueConnectionFactory.createQueueConnection();
            QueueSession session = queueConnection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);

            Queue queue = (Queue) context.lookup("queue/myQueue");
            TextMessage textMessage = session.createTextMessage(message);
            QueueSender sender = session.createSender(queue);
            sender.send(textMessage);

            session.close();
            queueConnection.close();
        } catch (NamingException e) {
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
        } catch (JMSException e) {
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
        }
    }
}



 4.1 获取连接工厂

 4.2 获取连接

 4.3 获取队列或订阅主题

 4.4 根据连接创建会话

 4.5 创建消息(可以是TextMessage, ObjectMessage等)

 4.6 使用会话发送消息



© 著作权归作者所有

共有 人打赏支持
我想去看一看大海
粉丝 3
博文 27
码字总数 6202
作品 0
成都
高级程序员
JBoss6【基础】简介(未整理)

JBoss是全世界开发者共同努力的成果,一个基于J2EE的开放源代码的应用服务器 因为JBoss代码遵循LGPL许可,你可以在任何商业应用中免费使用它,而不用支付费用 2006年,Jboss公司(http://jboss...

小99
2014/03/18
0
0
Tomcat,JBoss与JBoss Web

最近接触到应用服务器JBoss,此外JBoss Web与Tomcat也同为web服务器,便查阅资料对三者进行比较,供大家参考。 一、Tomcat Tomcat 服务器是免费开源的Web 应用服务器。支持最新的Servlet 和J...

thinkyoung
2014/11/16
0
0
J2EE进阶(二十四)JBoss Web和 Tomcat的区别

J2EE进阶(二十四)JBoss Web和 Tomcat的区别 在Web2.0的浪潮中,各种页面技术和框架不断涌现,为服务器端的基础架构提出了更高的稳定性和可扩展性的要求。近年来,作为开源中间件的全球领导者...

sunhuaqiang1
05/27
0
0
将J2EE程序从weblogic移植到JBoss上

前几天将一个原来的项目从weblogic上移植到了JBoss上,于是就将移植中出现的问题以及需要完成的工作记录了下来,以供大家参考。 1、上下文(Context)的获得方式不同,下面分别是两者获得上下...

大_于
2014/05/28
0
0
JBoss 系列六十八:JBoss 7/WildFly 集群之有状态会话Bean集群 - II(示例)

概述 本文分两个部分:有状态会话Bean集群和有状态会话Bean集群示例 有状态会话Bean集群 关于有状态会话Bean集群的基本理论参照JBoss 7/WildFly 集群之无状态会话Bean集群 - I(基本理论)。...

无鸯
2014/02/04
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

c语言之内存分配笔记

先看一个数组: short array[5] = {1,2} // 这儿定义的一个int类型的数组,数组第1和第2个元素值是1和2.其余后面默认会给值为0; 或者 short array[] = {1,2};//这儿数组第1和第2个元素,数组...

DannyCoder
35分钟前
0
0
Shell | linux安装包不用选择Y/N的方法

apt-get install -y packageOR echo "y" | sudo apt-get install package

云迹
今天
1
0
Hadoop的大数据生态圈

基于Hadoop的大数据的产品圈 大数据产品的一句话概括 Apache Hadoop: 是Apache开源组织的一个分布式计算开源框架,提供了一个分布式文件系统子项目(HDFS)和支持MapReduce分布式计算的软件架...

zimingforever
今天
4
0
八大包装类型的equals方法

先看其中一个源码 结论:八大包装类型的equals方法都是先判断类型是否相同,不相同则是false,相同则判断值是否相等 注意:包装类型不能直接用==来等值比较,否则编译报错,但是数值的基本类型...

xuklc
今天
2
0
NoSQL , Memcached介绍

什么是NoSQL 非关系型数据库就是NoSQL,关系型数据库代表MySQL 对于关系型数据库来说,是需要把数据存储到库、表、行、字段里,查询的时候根据条件一行一行地去匹配,当量非常大的时候就很耗...

TaoXu
昨天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部