文档章节

EJB3.0 JBoss的JMS实例

我想去看一看大海
 我想去看一看大海
发布于 2014/06/24 14:10
字数 461
阅读 66
收藏 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
tomcat,Jboss,weblogic区别与比较

tomcat,Jboss,weblogic区别与比较 一、tomcat Tomcat 服务器是一个免费的开放源代码的Web 应用服务器,它是Apache 软件基金会(Apache Software Foundation)的Jakarta 项目中的一个核心项...

DemonsI
08/29
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

没有更多内容

加载失败,请刷新页面

加载更多

一切都靠大数据:滴滴已封禁4.3万人员、车辆

这段时间以来,滴滴出行相继出炉了各种整改措施,包括自身安全建设和外部社会共建,昨日就刚刚宣布正在筹备建立安全监督顾问委员会。 据媒体最新报道,9月30日,上海市交通委员会执法总队、上...

linuxCool
42分钟前
4
0
awk命令用法介绍

10月18日任务 9.6/9.7 awk 1.awk(上)(下) 1.awk 分段操作功能 指定分隔符,并把第一段打印出来,不会改动文件内容 将所有内容打印出来 awk 没有指定分隔符号,则会默认用空格或者空白字符...

hhpuppy
今天
4
0
Spring Cloud Eureka Server高可用之:在线扩容

本文共 1591字,阅读大约需要 6分钟 ! 概述 业务微服务化以后,我们要求服务高可用,于是我们可以部署多个相同的服务实例,并引入负载均衡机制。而微服务注册中心作为微服务化系统的重要单元...

CodeSheep
今天
2
0
内网esxi主机上安装CoreOS虚拟机

CoreOS是一个为专门运行容器而设计的轻量级linux发行版,旨在通过轻量的系统架构和灵活的应用程序部署能力简化数据中心的维护成本和复杂度。它没有包管理工具,运行容器化应用以提供服务;默...

hiwill
今天
2
0
20181018 上课截图

![](https://oscimg.oschina.net/oscnet/49f66c08ab8c59a21a3b98889d961672f30.jpg) ![](https://oscimg.oschina.net/oscnet/a61bc2d618b403650dbd4bf68a671fabecb.jpg)......

小丑鱼00
今天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部