`
holdbelief
  • 浏览: 707482 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Spring实现IBMMQ的JMS消息发布/订阅模式

 
阅读更多

<?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"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-2.5.xsd">

<!--  IBM的mq配置 ConnectionFactory-->
   <bean id="mqConnectionFactoryTarget" class="com.ibm.mq.jms.MQTopicConnectionFactory">
   <!--   -->
<property name="transportType">
<util:constant static-field="com.ibm.mq.jms.JMSC.MQJMS_TP_CLIENT_MQ_TCPIP" />
</property>

<property name="queueManager" value="${ibm_queueManager}" />
<property name="hostName"     value="${ibm_hostName}" />
<property name="port"         value="${ibm_port}" />
</bean>


<bean id="mqConnectionFactory"
class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
<property name="targetConnectionFactory" ref="mqConnectionFactoryTarget" />
<property name="username" value=" " />
<property name="password" value=" " />
</bean>


<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"  >
   <property name="connectionFactory" ref="mqConnectionFactory" />

</bean>

<!-- Topic定义 -->
<bean id="notifyTopic" class="com.ibm.mq.jms.MQTopic">
<constructor-arg value="${ibm_topicName}" />
</bean>
</beans>


<!-- 异步接收Topic消息Container 
<property name="connectionFactory" ref="jmsFactory" />-->
<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer" lazy-init="false">
<property name="connectionFactory" ref="mqConnectionFactory" />
<property name="destination" ref="notifyTopic" />
<property name="messageListener" ref="notifyTopicListener" />
</bean>

<!-- 异步接收Topic消息处理类 -->
<bean id="notifyTopicListener" class="com.liuyu.examples.jms.NotifyTopicListener" />

分享到:
评论
1 楼 typeRos 2018-04-01  
只有配置文件,没有代码么大神

相关推荐

    JMS IBM MQ 订阅模式

    在本主题中,我们将深入探讨JMS如何与IBM MQ结合,实现订阅发布模式。 ### JMS基础 1. **消息模型**:JMS支持两种主要的消息传递模型——点对点(Queue)和发布/订阅(Topic)。点对点模式中,消息从一个生产者...

    在spring boot中使用jms集成IBM-MQ和TLQ,包含普通队列和主题订阅两种模式,并实现按需加载

    1) 本工程主要演示在SPRING BOOT工程中怎样使用JMS集成IBM-MQ及TLQ两种消息中间件产品 2) 使用SPRING BOOT Conditional机制实现了两种产品按需加载,工程会根据配置文件开关动态加载 3) 实现了普通队列消息发送与...

    spring boot jsm ibmmq topic queue

    标题"spring boot jsm ibmmq topic queue"涉及到的是如何在Spring Boot项目中使用JMS与IBM MQ进行交互,包括发布/订阅模型(Topic)和点对点模型(Queue)两种方式。下面将详细解释这两个概念以及如何在Spring Boot...

    编码实现MQ连接池实现JMS消息发送连接管理

    而在发布/订阅模式中,一个消息可以被多个消费者接收。JMS定义了生产者(Producer)、消费者(Consumer)以及消息代理(Message Broker)的角色,它们共同协作完成消息的发送、存储和接收。 连接池是管理数据库、MQ...

    jms-spring3-ibmmq:JMS 1.0.2 与 Spring 3.2.x 和 IBM MQ

    本项目"jms-spring3-ibmmq"是关于如何在Spring 3.2.x框架下集成JMS 1.0.2版本和IBM MQ的一个实例教程。 1. **JMS 1.0.2 知识点**: - JMS 是Java平台用于企业级应用间消息传递的API,支持点对点(Point-to-Point,...

    SpringJMS示例代码

    它定义了消息生产者、消费者和消息中间件之间的接口,使得不同的JMS提供商(如ActiveMQ、RabbitMQ、IBM WebSphere MQ等)之间具有互操作性。 3. **ActiveMQ简介** ActiveMQ是Apache软件基金会的一个开源项目,是一...

    Spring+JMS+消息处理

    IBM WebSphere MQ是一种强大的消息中间件,支持多种消息传递模式,包括点对点(P2P)和发布/订阅模式。其主要特点包括: - **高可靠性**:通过持久化存储和事务支持保证消息传输的可靠性。 - **广泛的平台支持**:...

    Spring JMS 消息处理-基于JNDI

    7. **发布/订阅模式支持**:除了点对点模式,Spring JMS还支持发布/订阅模式,可以用来实现广播消息,一个消息可以被多个消费者接收到。 在提供的压缩包文件中,"mq"可能包含与消息队列相关的配置或示例代码,而...

    基于soap over jms 的websphere mq与axis2的实现

    JMS支持两种消息模型:点对点(Point-to-Point, PTP)和发布/订阅(Publish/Subscribe, Pub/Sub)。 **Websphere MQ** IBM Websphere MQ,通常简称为MQ,是一个功能强大的消息中间件,它允许不同系统之间的应用程序...

    jms消息通讯

    在实际应用中,JMS通过JMS提供者(如ActiveMQ、RabbitMQ、IBM WebSphere MQ等)来实现。开发者需要配置JNDI(Java Naming and Directory Interface)以查找和连接到消息提供者,创建并管理MessageProducer、...

    jms-spring.zip

    在Spring中,JMS的集成主要依赖于`spring-jms`模块,该模块提供了对各种JMS供应商的抽象和支持,例如ActiveMQ,RabbitMQ,IBM WebSphere MQ等。ActiveMQ是Apache软件基金会的一个开源项目,是一个功能丰富的JMS提供...

    IBM jms 培训

    - **WebSphere MQ**:IBM提供的JMS实现,是一个高性能、高可靠性的消息中间件,支持多种平台和协议。 - **IBM Message Broker**:整合不同系统的消息传递,提供更高级的功能,如路由、转换和过滤。 4. **JMS API*...

    javax.jms-1.1.jar

    1. **JMS概述**:JMS提供了一个统一的接口,使得开发者可以使用多种不同的消息中间件(如IBM WebSphere MQ、Apache ActiveMQ等)。通过JMS,开发人员能够编写不依赖于特定消息服务提供商的应用程序,实现跨平台和跨...

    WebSphere MQ简单实例(发送消息)

    队列提供了一种可靠的一对一消息传递方式,而主题则支持一对多的发布/订阅模式。 在"WebSphere MQ简单实例(发送消息)"中,我们通常会经历以下几个步骤: 1. **设置环境**:安装WebSphere MQ服务器,并配置相应的...

    [重要]基于Websphere MQ持久化消息实现异步转同步—方案一

    - MQ提供点对点、发布/订阅等多种消息模型,支持多种协议和接口,如JMS(Java Message Service)。 - 持久化消息:即使MQ服务重启,消息也不会丢失,保证了高可用性。 2. **异步与同步通信**: - 异步通信:请求...

    java 消息服务(第二版)源码

    在深入学习JMS时,理解各种消息模式(如点对点和发布/订阅)、JMS接口(如`MessageProducer`、`MessageConsumer`、`Session`)和事务管理至关重要。此外,熟悉不同的消息中间件特性,如性能、安全性、管理工具等,也...

    spring-jms-demo

    这个"spring-jms-demo"项目显然是一个示例应用,它展示了如何在Spring环境中使用JMS来实现消息传递。让我们深入探讨Spring JMS的核心概念、功能以及如何在实际开发中应用。 首先,JMS是Java平台的一个标准接口,...

    Java Message Service 2nd Edition源代码

    IBM的WebSphere MQ是另一个著名的JMS实现,它在企业级应用中有广泛的应用。`JMS_2ed_spring_wmq.zip`可能包含了Spring与WMQ的集成示例,展示了如何在Spring环境中配置WMQ连接,创建消费者和生产者。WMQ以其高度的...

    javaEE 异步消息处理

    2. **消息队列(Message Queue)**:在JMS中,消息被发送到消息队列,客户端不直接与服务器交互,而是通过消息代理(如Apache ActiveMQ、RabbitMQ或IBM WebSphere MQ)进行通信。消息队列确保消息的可靠传输,即使...

Global site tag (gtag.js) - Google Analytics