`
y806839048
  • 浏览: 1127697 次
  • 性别: Icon_minigender_1
  • 来自: 上海
文章分类
社区版块
存档分类
最新评论

jms

    博客分类：
  • jms
jms 
阅读更多

http://www.pudn.com/downloads213/sourcecode/java/javascript/detail1004476.html
？？？？用tar
附加本例子所需要的jar包
activemq-all-5.2.0.jar
commons-logging-1.1.jar
log4j-1.2.14.jar
spring2.5.5.jar
xbean-spring-2.8.jar(2.8以上)
jdk
jee

这些jar包都可以在activemq的解压包中找到，即一个框架的所有jar包在他的源码里面可以找到

//接收方
///附件中的例子卡住的原因是进行了持久化，一旦有一次测试失败后面就积累了好多消息，此时肯定会一直卡住，需要把文件删除。

//链接
<bean id="syslogEventjmsFactorynew" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL">
<value>tcp://218.242.122.196:61616</value>
</property>
</bean>
</property>
<property name="maxConnections" value="100"></property>
</bean>


<!-- 监听MQ队列，获取syslog事件(综合管理平台需要修改成自己的类包路径,其他地方保持不变) -->
<bean id="syslogEventReceiver" class="com.ces.monitor.service.SyslogEventService"></bean>


//通道
<!-- 接收server消息 -->
   <bean id="syslogEventTopicDestination" class="org.apache.activemq.command.ActiveMQTopic">
<constructor-arg index="0" value="com.topsec.send.syslog">
</constructor-arg>
  </bean>

//监听容器
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="concurrentConsumers" value="6" />
<property name="connectionFactory" ref="syslogEventjmsFactorynew" />
<property name="destination" ref="syslogEventTopicDestination" />
<property name="messageListener" ref="syslogEventReceiver" />
<property name="pubSubNoLocal" value="false"></property>
</bean> 





@Component
public class SyslogEventService implements MessageListener {
/**
*
* @see javax.jms.MessageListener#onMessage(javax.jms.Message)
* @author admin(冯有双)
* @date 2014-9-24 下午5:06:41
*/

@SuppressWarnings("unchecked")
@Override
public void onMessage(Message message) {
Connection conn = null;
PreparedStatement pstm = null;
try {
Serializable obj = ((ObjectMessage) message).getObject();
List<Map<String, Object>> messageList = (List<Map<String, Object>>) obj;


A
工厂（共有）
消息转化（共有）
服务方设置自己的服务地址
通道（共有）


模板含有：
链接工厂
消息转化

生产者：
模板
通道

=====================================================
B
消费者

一个消费者一个监听：（这个其实可以使一个实现了监听的类）
消费者
转化


一个监听一个监听容器：

链接工厂
通道
监听




A应用：applicationContext-activemq.xml

<amq:broker useJmx="false" persistent="true">
<amq:persistenceAdapter>
<amq:amqPersistenceAdapter directory="c:/amq"/>
</amq:persistenceAdapter>
<amq:transportConnectors>
//<amq:transportConnector uri="tcp://localhost:0" />
<amq:transportConnector uri="tcp://localhost:61616" /> 
</amq:transportConnectors>
</amq:broker>

<!-- 连接外部的activeMQ -->
<amq:connectionFactory id="jmsConnectionFactory" brokerURL="tcp://localhost:61616" />

<!--  ActiveMQ destinations  -->
<!--  使用topic方式-->
<amq:topic name="TOPIC" physicalName="JMS-TEST-TOPIC" />

<!--  Spring JmsTemplate config -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory">
<!--  lets wrap in a pool to avoid creating a connection per send -->
<bean class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="jmsConnectionFactory" />
</bean>
</property>
<!-- custom MessageConverter -->
<property name="messageConverter" ref="defaultMessageConverter" />
</bean>

<!-- converter  -->
<bean id="defaultMessageConverter" class="com.me.jms.DefaultMessageConverter" />

<!-- POJO which send Message uses  Spring JmsTemplate -->
<bean id="topicMessageProducer" class="com.me.jms.TopicMessageProducer">
<property name="template" ref="jmsTemplate" />
<property name="destination" ref="TOPIC" />
</bean>
A应用producer
public class TopicMessageProducer {
   
    private JmsTemplate template;

private Topic destination;

public void setTemplate(JmsTemplate template) {
this.template = template;
}

public void setDestination(Topic destination) {
this.destination = destination;
}

public void send(TestBean message) {
System.out.println("=====> message send! ");
template.convertAndSend(this.destination, message);
}
}
A应用中的Action
public class TestAction extends ActionSupport{

private TestBean tb;
private TopicMessageProducer topicMessageProducer;

public String test(){
System.out.println("===> username:" + tb.getUserName());
System.out.println("===> username:" + tb.getPassWord());
topicMessageProducer.send(tb);

return "success";
}
...geter(),seter();
}










B应用applicationContext-activemq.xml
//<amq:connectionFactory id="jmsConnectionFactory"  brokerURL="tcp://localhost:61616" />
<amq:connectionFactory id="jmsConnectionFactory" brokerURL="tcp://localhost:61616" />
<amq:topic name="TOPIC" physicalName="JMS-TEST-TOPIC" />

<!-- converter  -->
<bean id="defaultMessageConverter"
class="com.me.jms.DefaultMessageConverter" />

<!--  Message Driven POJO (MDP) -->
    <!-- consumer1 for topic a -->
    <bean id="topicConsumerA" class="com.me.jms.TopicConsumerA" />

    <!-- consumer2 for topic a -->
    <bean id="topicConsumerB" class="com.me.jms.TopicConsumerB" />
   
    <!-- Message Listener for  -->
<bean id="topicListenerA" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<constructor-arg ref="topicConsumerA" />
<!--  may be other method -->
<property name="defaultListenerMethod" value="receive" />
<!-- custom MessageConverter define -->
<property name="messageConverter" ref="defaultMessageConverter" />
</bean>

<bean id="topicListenerB" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<constructor-arg ref="topicConsumerB" />
<!--  may be other method -->
<property name="defaultListenerMethod" value="receive" />
<!-- custom MessageConverter define -->
<property name="messageConverter" ref="defaultMessageConverter" />
</bean>

<!--  listener container，MDP无需实现接口 -->
<bean id="topicListenerContainerA" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="destination" ref="TOPIC" />
<property name="messageListener" ref="topicListenerA" />
</bean>

    <bean id="topicListenerContainerB" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="destination" ref="TOPIC" />
<property name="messageListener" ref="topicListenerB" />
</bean>
B应用的consumerA和consumerB都一样
public class TopicConsumerA {
public void receive(TestBean message) {
System.out.println("************************************** Topic A userName: " + message.getUserName());
System.out.println("************************************** Topic A passWord: " + message.getPassWord());
}
}




A应用
<amq:broker useJmx="false" persistent="true">

<amq:persistenceAdapter>
<amq:amqPersistenceAdapter directory="d:/amq"/>
</amq:persistenceAdapter>

<amq:transportConnectors>
<amq:transportConnector uri="tcp://localhost:0" />
</amq:transportConnectors>
</amq:broker>

  
<amq:connectionFactory id="jmsConnectionFactory" brokerURL="tcp://localhost:61616" />

    <!--  使用Queue方式-->
    <amq:queue name="QUEUE" physicalName="JMS-TEST-QUEUE" />

<!--  Spring JmsTemplate config -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory">
<!--  lets wrap in a pool to avoid creating a connection per send -->
<bean class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="jmsConnectionFactory" />
</bean>
</property>
<!-- custom MessageConverter -->
<property name="messageConverter" ref="defaultMessageConverter" />
</bean>

<!-- converter  -->
<bean id="defaultMessageConverter" class="com.andyao.activemq.DefaultMessageConverter" />

<bean id="queueMessageProducer" class="com.andyao.activemq.QueueMessageProducer">
<property name="template" ref="jmsTemplate" />
<property name="destination" ref="QUEUE" />
</bean>
B应用
<amq:connectionFactory id="jmsConnectionFactory" brokerURL="tcp://localhost:61616" />

<amq:queue name="QUEUE" physicalName="JMS-TEST-QUEUE" />
 
 
<bean id="queueConsumer" class="com.andyao.activemq.QueueConsumer" />
    <bean id="queueListener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<constructor-arg ref="queueConsumer" />
<!--  may be other method -->
<property name="defaultListenerMethod" value="receive" />
<!-- custom MessageConverter define -->
<property name="messageConverter" ref="defaultMessageConverter" />
</bean>

   <!-- converter -->
<bean id="defaultMessageConverter" class="com.andyao.activemq.DefaultMessageConverter" />
   
   
    <bean id="queueListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="destination" ref="QUEUE" />
<property name="messageListener" ref="queueListener" />
</bean>



自动启动配置：
web.xml
<!-- spring配置 -->
<context-param>
<param-name>spring.profiles.default</param-name>
<param-value>development</param-value>
</context-param>
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>/WEB-INF/applicationContext*.xml,classpath*:applicationContext*.xml</param-value>
</context-param>

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

spring中

<bean id="jms" lazy-init="false" class="TestJms.TestMain" init-method="test" >
</bean>




===========================A==================================
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://activemq.org/config/1.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://activemq.org/config/1.0 http://activemq.apache.org/schema/core/activemq-core-5.0.0.xsd">

<amq:broker useJmx="false" persistent="true">
<amq:persistenceAdapter>
<amq:amqPersistenceAdapter directory="d:/amq"/>
</amq:persistenceAdapter>
<amq:transportConnectors>
<amq:transportConnector uri="tcp://localhost:61616" />
</amq:transportConnectors>
</amq:broker>


  
<amq:connectionFactory id="jmsConnectionFactory" brokerURL="tcp://localhost:61616" />

    <!--  使用Queue方式-->
    <amq:queue name="QUEUE" physicalName="JMS-TEST-QUEUE" />
<amq:topic name="TOPIC" physicalName="JMS-TEST-TOPIC" />
<!--  Spring JmsTemplate config -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory">
<!--  lets wrap in a pool to avoid creating a connection per send -->
<bean class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="jmsConnectionFactory" />
</bean>
</property>
<!-- custom MessageConverter -->
<property name="messageConverter" ref="defaultMessageConverter" />
</bean>

<!-- converter  -->
<bean id="defaultMessageConverter" class="TestJms.DefaultMessageConverter" />

<bean id="queueMessageProducer" class="TestJms.QueueMessageProducer">
<property name="template" ref="jmsTemplate" />
<property name="destination" ref="QUEUE" />
</bean>
<bean id="topicMessageProducer" class="TestJms.TopicMessageProducer">
<property name="template" ref="jmsTemplate" />
<property name="destination" ref="TOPIC" />
</bean>

</beans>


===============================B====================================



<beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://activemq.org/config/1.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://activemq.org/config/1.0 http://activemq.apache.org/schema/core/activemq-core-5.0.0.xsd">

<amq:connectionFactory id="jmsConnectionFactory" brokerURL="tcp://localhost:61616" />

<amq:queue name="QUEUE" physicalName="JMS-TEST-QUEUE" />
  <!--  使用topic方式-->
<amq:topic name="TOPIC" physicalName="JMS-TEST-TOPIC" />
  <bean id="topicConsumerA" class="TestJms.TopicConsumerA" />

    <!-- consumer2 for topic a -->
    <bean id="topicConsumerB" class="TestJms.TopicConsumerB" />
<bean id="queueConsumer" class="TestJms.QueueConsumer" />
<!-- Message Listener for  -->
<bean id="topicListenerA" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<constructor-arg ref="topicConsumerA" />
<!--  may be other method -->
<property name="defaultListenerMethod" value="receive" />
<!-- custom MessageConverter define -->
<property name="messageConverter" ref="defaultMessageConverter" />
</bean>

<bean id="topicListenerB" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<constructor-arg ref="topicConsumerB" />
<!--  may be other method -->
<property name="defaultListenerMethod" value="receive" />
<!-- custom MessageConverter define -->
<property name="messageConverter" ref="defaultMessageConverter" />
</bean>
    <bean id="queueListener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<constructor-arg ref="queueConsumer" />
<!--  may be other method -->
<property name="defaultListenerMethod" value="receive" />
<!-- custom MessageConverter define -->
<property name="messageConverter" ref="defaultMessageConverter" />
</bean>

   <!-- converter -->
<bean id="defaultMessageConverter" class="TestJms.DefaultMessageConverter" />
   
   
    <bean id="queueListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="destination" ref="QUEUE" />
<property name="messageListener" ref="queueListener" />
</bean>
  <!--  listener container，MDP无需实现接口 -->
<bean id="topicListenerContainerA" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="destination" ref="TOPIC" />
<property name="messageListener" ref="topicListenerA" />
</bean>

    <bean id="topicListenerContainerB" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="destination" ref="TOPIC" />
<property name="messageListener" ref="topicListenerB" />
</bean>


</beans>

====================用原型中的例子就需要启动服务=======================

详见附件
activemq5.2.0
http://andyao.iteye.com/blog/234101
分享到：
| jms消息中间件
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    javax.jms.jar

    Classes contained in javax.jms.jar: javax.transaction.xa.XAResource.class javax.jms.BytesMessage.class javax.jms.Message.class javax.jms.JMSException.class javax.jms.Destination.class javax.jms....

    PDS-17001_JMS583_Datasheet_(Rev._1.0)_JMS583_jmicron_jms583开发_

    **JMS583芯片详解** JMS583是一款由JMicron科技公司设计的高性能USB 3.1 Gen 2至PCIe Gen3x2桥接芯片，旨在为存储设备提供高速数据传输能力。这款芯片是针对现代数据密集型应用而优化的，如SSD固态硬盘和外部存储...

    java.jms.jar JMS需要的JAR包

    `javax.jms.jar` 文件中包含了如`javax.jms.Queue`, `javax.jms.Topic`, `javax.jms.MessageProducer`, `javax.jms.MessageConsumer`, `javax.jms.ConnectionFactory`等关键接口，以及其他辅助类和异常类，开发者...

    javax.jms包,sun的JMS接口规范包

    Java消息服务（Java Message Service，简称JMS）是Java平台中用于企业级应用集成的API，它定义了一组标准接口，允许应用程序创建、发送、接收和读取消息。`javax.jms`包是JMS规范的核心部分，包含了各种与消息传递...

    jms-1.1.jar（jms工具jar包）

    Java消息服务（Java Message Service，简称JMS）是Java平台中用于企业级应用间异步通信的标准接口。它提供了一种可靠的消息传递机制，允许应用程序创建、发送、接收和读取消息。`jms-1.1.jar` 是一个包含了JMS 1.1...

    JMS583 USB PCIE 桥接芯片方案

    **JMS583 USB转PCIE桥接芯片方案** JMS583是一款由JMicron科技公司设计的高效能USB到PCI Express (PCIe)桥接芯片，旨在为电子设备提供一种灵活的方式来实现高速数据传输。这款芯片能够将USB接口转换成PCIe接口，以...

    jms-1.1.jar

    《JMS 1.1 API详解与应用实践》 Java消息服务（Java Message Service，简称JMS）是Java平台中用于企业级应用间异步通信的一种标准接口。JMS 1.1是其一个重要的版本，它为分布式系统中的应用程序提供了一种可靠的...

    USB转SATA硬盘盒JMS583量产工具

    标题中的“USB转SATA硬盘盒JMS583量产工具”是指一种专门用于将USB接口转换为SATA接口的硬件设备，其中JMS583是该转换器的主控芯片。这种硬盘盒允许用户将传统的SATA硬盘通过USB接口连接到电脑上，方便数据迁移、...

    javax.jms.jar下载

    javax.jms.BytesMessage.class javax.jms.Connection.class javax.jms.ConnectionConsumer.class javax.jms.ConnectionFactory.class javax.jms.ConnectionMetaData.class javax.jms.DeliveryMode.class javax.jms....

    JMS583量产工具.zip

    【JMS583量产工具】是一款专门针对JMS583芯片进行批量生产操作的软件工具，主要用于USB闪存盘的制作与修复。这款工具的全称可能为"JMS583 Mass Production Tool"，它允许用户一次性对多个JMS583芯片驱动的USB设备...

    JMS1.1规范(中文)

    Java消息服务（Java Message Service，简称JMS）是Java平台中用于企业级应用集成的API，主要用于在分布式环境中传递消息。JMS1.1规范是该API的一个版本，提供了标准接口，使得不同的消息中间件（Message Oriented ...

    USB3.0移动硬盘盒 JMS578 固件2018最新固件， G-Technology 移动硬盘盒固件 for JMS578

    标题中的“USB3.0移动硬盘盒 JMS578 固件2018最新固件， G-Technology 移动硬盘盒固件 for JMS578”揭示了这个压缩包文件主要关注的是一个特定型号的USB3.0移动硬盘盒，该盒子采用JMS578主控芯片，并且提供了2018年...

    javax.jms-1.1.jar

    `javax.jms-1.1.jar` 是一个Java Message Service（JMS）的API库，它属于Java标准版（Java Standard Edition, Java SE）的一部分。JMS是Java平台上的一个规范，用于在分布式环境中进行异步消息传递。这个库主要用于...

    JMS的中文教程（Java的消息驱动）

    ### JMS的中文教程（Java的消息驱动）知识点详解 #### 一、JMS简介与重要性 **JMS**(Java Message Service)是一种消息传递中间件的API标准，它定义了一套标准接口，允许应用程序创建、发送、接收和读取消息。JMS的...

    JMS578多达13个固件打包升级工具包 可修改休眠时间

    文件包含： 13个不同固件 两个固件升级工具 其中一个是量产工具可以修改休眠时间和盒子信息 TRIM检查工具 有几个固件版本为全网首发，别人没有的资源 固件列表： JMS578_00.01.00.05 ...JMS578_254.02.03.09_NoUAS

    weblogic中使用JMS发送和接受消息

    WebLogic Server是一款由Oracle公司提供的企业级应用服务器，它支持Java Message Service (JMS) 规范，允许在分布式环境中可靠地发送和接收消息。JMS是Java平台上的标准接口，用于实现应用程序间的异步通信。本文将...

    Weblogic JMS 依赖jar包下载

    Weblogic JMS 依赖jar包是Oracle公司的中间件产品Weblogic Server中用于实现Java Message Service (JMS) 功能的关键组件。JMS是一种标准API，它允许应用程序在分布式环境中发送和接收消息，提供了异步通信的能力。在...

    JMS 简介以及Weblogic配置JMS图解

    Java Messaging Service（JMS）是一种标准的API，用于在Java应用程序之间交换消息，特别是在分布式环境中。JMS提供了一种与平台无关的方式，使得应用程序可以与各种消息中间件提供商进行交互，就像JDBC允许Java应用...

    JMS（JMS（JMS（JMS（

    JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS（JMS

Magicbox
Global site tag (gtag.js) - Google Analytics