使用spring 的jms发送和接收消息
新建工程 
导入spring的jar包,
 spring-aop-4.0.6.RELEASE.jar
 spring-aspects-4.0.6.RELEASE.jar
 spring-beans-4.0.6.RELEASE.jar
 spring-build-src-4.0.6.RELEASE.jar
 spring-context-4.0.6.RELEASE.jar
 spring-context-support-4.0.6.RELEASE.jar
 spring-core-4.0.6.RELEASE.jar
 spring-expression-4.0.6.RELEASE.jar
 spring-framework-bom-4.0.6.RELEASE.jar
 spring-instrument-4.0.6.RELEASE.jar
 spring-instrument-tomcat-4.0.6.RELEASE.jar
 spring-jdbc-4.0.6.RELEASE.jar
 spring-jms-4.0.6.RELEASE.jar
 spring-messaging-4.0.6.RELEASE.jar
 spring-orm-4.0.6.RELEASE.jar
 spring-oxm-4.0.6.RELEASE.jar
 spring-test-4.0.6.RELEASE.jar
 spring-tx-4.0.6.RELEASE.jar
 spring-web-4.0.6.RELEASE.jar
 spring-webmvc-4.0.6.RELEASE.jar
 spring-webmvc-portlet-4.0.6.RELEASE.jar
 spring-websocket-4.0.6.RELEASE.jar

导入activeMq的jar包
activemq-all-5.10-SNAPSHOT.jar

将user library中的jar包发布到应用中
右击工程-->properties-->deployment assermbly-->add-->选择对应jar包

tomcat容器集成activieMq,在conf/context.xml文件的配置内容如下:
<!--set activeMq-->
<Resource name="jms/ConnectionFactory"    
                auth="Container"    
                type="org.apache.activemq.ActiveMQConnectionFactory"  
                description="JMS Connection Factory"  
                factory="org.apache.activemq.jndi.JNDIReferenceFactory"  
                brokerURL="tcp://localhost:61616"  
                brokerName="LocalActiveMQBroker" />  
                  
<Resource name="jms/Queue"    
                auth="Container"    
                type="org.apache.activemq.command.ActiveMQQueue"  
                description="My Queue"  
                factory="org.apache.activemq.jndi.JNDIReferenceFactory"  
                physicalName="TomcatQueue" />

jms的配置文件如下:

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING/DTD BEAN/EN"

"http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<!-- 连接工厂 -->
<bean id="jmsConnectionFactory"

class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName"

value="java:comp/env/jms/ConnectionFactory"></property>
</bean>

<!-- 消息队列 -->
<bean id="tomcatQueue" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="java:comp/env/jms/Queue"></property>
</bean>

<!-- 配置JMS的模板 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<!-- 链接工厂 -->
<property name="connectionFactory">
<ref bean="jmsConnectionFactory" />
</property>
<!-- 消息队列 -->
<property name="defaultDestination">
<ref bean="tomcatQueue" />
</property>
</bean>

<!-- 发送消息队列到目的地 -->
<bean id="sender" class="cn.yue.demo.jms.MessageSender">
<property name="jmsTemplate">
<ref bean="jmsTemplate" />
</property>
</bean>

<!-- 接收消息 -->
<bean id="receiver" class="cn.yue.demo.jms.MessageReceiver">
<property name="jmsTemplate">
<ref bean="jmsTemplate" />
</property>
</bean>

<!-- 默认的消息监听容器 -->
<bean id="listenerContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory">
<ref bean="jmsConnectionFactory" />
</property>
<property name="destination">
<ref bean="tomcatQueue" />
</property>
<property name="messageListener">
<ref bean="receiver" />
</property>
</bean>
</beans>

spring中文件中的配置文件如下:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns:util="http://www.springframework.org/schema/util"
xmlns:context="http://www.springframework.org/schema/context"

xmlns:p="http://www.springframework.org/schema/p"
xmlns:amq="http://activemq.apache.org/schema/core"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/util
http://www.springframework.org/schema/util/spring-util.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd">

<!-- 引入jms配置文件 -->
<import resource="classpath:jmsconfig.xml" />

<!-- 自动扫描 -->
<context:component-scan base-package="cn.yue.demo" />
</beans>

web.xml的配置文件如下:

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://java.sun.com/xml/ns/javaee"

xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee

http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
id="WebApp_ID" version="3.0">
<display-name>SpringJmsDemo</display-name>

<!-- 设置spring配置文件路径 -->
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:applicationContext.xml</param-value>
</context-param>

<!-- 设置spring监听,在应用启动时启动spring容器 -->
<listener>
<listener-

class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>

<!-- 防止延迟加载 -->
<filter>
<filter-name>Spring OpenEntityManagerInView</filter-name>
<filter-

class>org.springframework.orm.jpa.support.OpenEntityManagerInViewFilter</filter-class>
</filter>

<welcome-file-list>
<welcome-file>index.html</welcome-file>
<welcome-file>index.htm</welcome-file>
<welcome-file>index.jsp</welcome-file>
<welcome-file>default.html</welcome-file>
<welcome-file>default.htm</welcome-file>
<welcome-file>default.jsp</welcome-file>
</welcome-file-list>
</web-app>

java代码如下:
/**
 * Copyright (C) 2016
 * 
 * FileName:MessageSender.java
 *
 * Author:<a href="mailto:zhenhuayue@sina.com">Retacn</a>
 *
 * CreateTime: 2016-3-10
 */
// Package Information

package cn.yue.demo.jms;

import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

/**
 * 消息发送
 * 
 * @version
 * @Description:
 * @author <a href="mailto:zhenhuayue@sina.com">Retacn</a>
 * @since 2016-3-10
 */
public class MessageSender {
    // 消息模版
    private JmsTemplate jmsTemplate;

/**
     * 发送消息
     * 
     * @param text 消息内容
     */
    public void send(final String text) {
        jmsTemplate.send(new MessageCreator() {

public Message createMessage(Session session) throws JMSException {
                return session.createTextMessage(text);
            }
        });
    }

public JmsTemplate getJmsTemplate() {
        return jmsTemplate;
    }

public void setJmsTemplate(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }
}

/**
 * Copyright (C) 2016
 * 
 * FileName:MessageReceiver.java
 *
 * Author:<a href="mailto:zhenhuayue@sina.com">Retacn</a>
 *
 * CreateTime: 2016-3-10
 */
// Package Information

package cn.yue.demo.jms;

import org.springframework.jms.core.JmsTemplate;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

/**
 * 消息接收
 * 
 * @version
 * @Description:
 * @author <a href="mailto:zhenhuayue@sina.com">Retacn</a>
 * @since 2016-3-10
 */
public class MessageReceiver implements MessageListener {
    // 消息模版
    private JmsTemplate jmsTemplate;

/**
     * 接收消息
     * 
     * @throws JMSException
     */
    public void receive() throws JMSException {
        TextMessage text = (TextMessage) this.jmsTemplate.receive();
        System.out.println("receive=" + text.getText());
    }

/**
     * 监听回调函数
     */
    public void onMessage(Message message) {
        if (message instanceof TextMessage) {
            TextMessage text = (TextMessage) message;
            try {
                System.out.println(text.getText());
            } catch (Exception e) {
            }
        }
    }

public JmsTemplate getJmsTemplate() {
        return jmsTemplate;
    }

public void setJmsTemplate(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }

}

/**
 * Copyright (C) 2016
 * 
 * FileName:MessageTest.java
 *
 * Author:<a href="mailto:zhenhuayue@sina.com">Retacn</a>
 *
 * CreateTime: 2016-3-10
 */
// Package Information

package cn.yue.demo.jms;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import javax.jms.JMSException;

/**
 * 测试消息接收
 * 
 * @version
 * @Description:
 * @author <a href="mailto:zhenhuayue@sina.com">Retacn</a>
 * @since 2016-3-10
 */
public class MessageTest {
    /**
     * 测试消息的发送与接收
     * 
     * @throws JMSException
     */
    public void test() throws JMSException {
        ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext(
                "applicationContext.xml");
        MessageSender sender = (MessageSender) ctx.getBean("sender");
        MessageReceiver receive = (MessageReceiver) ctx.getBean("receiver");
        sender.send("helloworld");
        receive.receive();
    }
}

启动activeMq

启动tomcat,运行该程序

转载于:https://www.cnblogs.com/retacn-yue/p/6194218.html

tomcat集成activeMq 简单例子相关推荐

  1. springboot 1.5.2 集成kafka 简单例子

    添加依赖 compile("org.springframework.kafka:spring-kafka:1.1.2.RELEASE") 添加application.propert ...

  2. Jenkins + Git + Maven + tomcat集成环境搭建

    折腾了好几天,终于把Jenkins + Git + Maven + tomcat集成环境搭建起来了,最终主要实现"自动构建.部署"web应用. 1.安装环境 操作系统:Centos ...

  3. 基于 abapGit 和 abaplint 的 ABAP 持续集成的一个例子

    这是 Jerry 2021 年的第 61 篇文章,也是汪子熙公众号总共第 338 篇原创文章. 短歌行 曹操 对酒当歌,人生几何! 譬如朝露,去日苦多. 慨当以慷,忧思难忘. 何以解忧?唯有杜康. 青 ...

  4. ActiveMQ简单介绍以及安装

    ActiveMQ简单介绍以及安装   现实的企业中,对于消息通信的应用一直都非常的火热,而且在J2EE的企业应用中扮演着特殊的角色,所以对于它研究是非常有必要的. 上篇博文深入浅出JMS(一)–JMS ...

  5. Quartz2-Quartz与tomcat集成

    Quartz2-Quartz与tomcat集成 Quartz只与tomcat简单集成,不用其他框架. 写一个要需要执行任务的类DumbJob,实现Job接口 Java代码   package com. ...

  6. Spring集成Activemq使用

    现在任何一个框架的使用都会结合spring框架,quartz.cxf与平时常见的Hibernate.mybatis.Struts等都可以与spring集成起来使用,在这里研究了activemq结合sp ...

  7. Javaweb之简单例子(一)

    Javaweb 之简单例子(一) 目录:                                                                         一.简述    ...

  8. Java单元测试工具:JUnit4(一)——概述及简单例子

    (一)JUnit概述及一个简单例子 看了慕课网的JUnit视频教程:http://www.imooc.com/learn/356,总结笔记.         这篇笔记记录JUnit的概述,以及一个快速 ...

  9. SpringBoot集成ActiveMQ

    一.消息队列概述 1.什么是消息队列? 消息队列是消息中间件的一种实现方式.消息队列中间件是分布式系统中重要的组件,主要解决应用耦合,异步消息,流量削锋等问题.实现高性能,高可用,可伸缩和最终一致性架 ...

  10. php recordset,adodb.recordset PHP通过COM使用ADODB的简单例子 - ADOdb

    要实现下列功能,请确保 php.ini 中的 com.allow_dcom 选项已设为 true. 一.准备工作 新建一个ACCESS数据库,并命名为db.mdb,然后在这个数据库中新建一个表 com ...

最新文章

  1. Linux进程描述符task_struct结构体详解--Linux进程的管理与调度(一)
  2. 使用 Node.js、Express、AngularJS 和 MongoDB 构建一个Web程序
  3. canal解析mysql日志异常_利用Canal解析mysql binlog日志
  4. AJAX-服务器响应
  5. Hadoop 命令操作
  6. linux确定刻录机目录,在Linux操作系统下使用DVD刻录机(转)
  7. 默认表空间位置oracle,oracle 默认表空间
  8. 关于语言选择、输入和产出的关系
  9. html5圆圈刷新 博客,html5话出带圆的波浪线
  10. 维基百科 双线性插值
  11. 【控制】PID和LQR
  12. 电脑键盘灯光的调节方法
  13. 自然语言处理实战:新闻文本分类(附代码)
  14. dkp管理系统 php,RB!DKP v3.1.8 Build
  15. EUV光刻机内部揭秘!
  16. 如何使用DMA,包含源码以及详细注释
  17. Java项目:精美物流管理系统(java+SpringBoot+Vue+maven+Mysql)
  18. 【漏洞通告】Gitlab存在多个高危漏洞
  19. centos6如何添加阿里云centos和epel源
  20. Ymir初级使用教程

热门文章

  1. python程序员到哪里_Python程序员都知道的入门知识の五
  2. 【论文翻译】CenterNet: Objects as Points
  3. MatConvNet中关于vl_simplenn_display的一些分析
  4. 利用matlab求图像均值和方差的几种方法
  5. leetcode——给你两个非空链接表,代表两个非负整数。 数字以相反的顺序存储,并且它们的每个节点包含单个数字。 将两个数字相加,并将其作为链表返回。
  6. windows7下redis的安装实践
  7. pyspark分类算法之多层感知机神经网络分类器模型实践【MLPClassifier】
  8. java html 转word_java后端实现word上传并转html格式
  9. java星号心形代码_肿么用JAVA打印出心形的图案
  10. 关键词词云怎么做_网友问:做独立站,怎么做关键词排名,怎么做客户流量?...