`

使用Spring JMS和SonicMQ实现异步通信

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


第一步:SonicMQ的安装准备

    1、安装SonicMq7.0,一切按默认配置(Domain1,tcp://localhost:2506,Administrator,Administrator),在程序菜单中生产“SonicMQ DomainManager”,“SonicMQ Management Console”等。

    2、先启动“SonicMQ DomainManager”,然后在“SonicMQ Management Console”界面,选择Tools/JMS Administered Objects菜单中,打开一个面板,使用第二个选项“JNDI Naming Service”,并选中“Sonic Storage”,填写安装是输入的连接信息,连接。连接后分别在“Destinations”和“Connection Factories”面板创建一个Queue("SampleQ1")和Connection Factory("seashellSonicSendXAConnectionFactory")。



第二步:Spring JMS配置文件(jmsconfig.xml)

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">

<beans>
    <!-- jndiTemplate -->
    <bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
      <property name="environment">
        <props>
          <prop key="java.naming.factory.initial">
             com.sonicsw.jndi.mfcontext.MFContextFactory
          </prop>
          <prop key="java.naming.provider.url">tcp://localhost:2506</prop>
          <prop key="com.sonicsw.jndi.mfcontext.domain">Domain1</prop>
          <prop key="com.sonicsw.jndi.mfcontext.idleTimeout">60000</prop>
          <prop key="java.naming.security.principal">Administrator</prop>
          <prop key="java.naming.security.credentials">Administrator</prop>
        </props>
      </property>
    </bean>
  
    <!-- JMS队列 -->
    <bean id="destination" class="org.springframework.jndi.JndiObjectFactoryBean">
      <property name="jndiName" value="SampleQ1" />
      <property name="jndiTemplate">
        <ref local="jndiTemplate"></ref>
      </property>
    </bean>
  
     <!-- JMS连接工厂 -->
    <bean id="connectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
      <property name="jndiName" value="seashellSonicSendXAConnectionFactory" />
      <property name="jndiTemplate" ref="jndiTemplate" />
    </bean>
    <bean id="cachedConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
      <property name="targetConnectionFactory" ref="connectionFactory"/>
    </bean>

    <!-- jmsTemplate -->
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
      <property name="connectionFactory">
        <ref local="cachedConnectionFactory" />
      </property>
      <property name="sessionTransacted" value="true" />
      <property name="sessionAcknowledgeModeName" value="SESSION_TRANSACTED" />
    </bean>

    <!-- JMS 消息监听容器 -->
    <bean id="listenerContainer"
          class="org.springframework.jms.listener.DefaultMessageListenerContainer">

      <property name="connectionFactory" ref="cachedConnectionFactory" />
      <property name="destination" ref="destination" />
      <property name="messageListener" ref="messageListener" />
      <property name="concurrentConsumers" value="2" />
      <property name="sessionTransacted" value="true" />
    </bean>
  
    <!-- Message Driven POJO (MDP 消息驱动POJO) -->
    <bean id="messageListener" class="com.tsinghuatec.dawn.waf.jms.JmsQueueListener" />
  
    <!-- JMS 消息发送者 配置-->
    <bean id="jmsQueueSender" class="com.tsinghuatec.dawn.waf.jms.JmsQueueSender">
      <property name="jmsTemplate" ref="jmsTemplate"/>
      <property name="queue" ref="destination" />
    </bean>

</beans>

web.xml

    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>classpath:jmsconfig.xml</param-value>
    </context-param>

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



第三步:Java Source:

服务端MDB(com.tsinghuatec.dawn.waf.jms.JmsQueueListener)

public class JmsQueueListener implements MessageListener {

    @Override
    public void onMessage(Message message) {
        if (message instanceof TextMessage) {
            try {
                String msg = ((TextMessage) message).getText();
                System.out.println("已经收到消息:" + msg);
            } catch (Exception ex) {
                throw new RuntimeException(ex);
            }
        }
    }

}



客户端(com.tsinghuatec.dawn.waf.jms.JmsQueueSender)

public class JmsQueueSender {
    private JmsTemplate jmsTemplate;
    private Queue queue;

    public void send(final String message) {
        jmsTemplate.send(queue, new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
                return session.createTextMessage(message);
            }
        });
    }

    public void setJmsTemplate(JmsTemplate template) {
        this.jmsTemplate = template;
    }
    public void setQueue(Queue queue) {
        this.queue = queue;
    }

    public static void main(String[] args) {
        ApplicationContext context = new ClassPathXmlApplicationContext("classpath:jmsconfig.xml");
        JmsQueueSender sender = (JmsQueueSender) context.getBean("jmsQueueSender");
        sender.send("test a message");
    }

}



第四步:将服务端MDB打jar包放在WEB-INF/lib下,运行客户端JmsQueueSender。

输出结果:

已经收到消息:test a message
已经收到消息:test a message
已经收到消息:test a message
分享到:
评论

相关推荐

    SonicMQ中jms小程序

    通过“SonicMQ中jms小程序”,开发者可以学习如何在SonicMQ环境下利用JMS API编写Java程序,实现消息的发送和接收,从而构建出高效、稳定的分布式系统。这些技能对于任何需要进行异步通信和解耦设计的项目都至关重要...

    JMS 简单使用指南

    Java消息服务(JMS,Java Message Service)是...通过理解并熟练掌握这些知识点,开发者可以构建高效、可靠的分布式系统,实现系统的解耦和异步通信。在实际开发中,选择合适的JMS供应商和理解其编程接口是至关重要的。

    GlassFish配置SonicMQ

    如果你需要进一步了解如何在源代码中与SonicMQ交互,可以查看这些文件,尤其是那些使用JMS API的类,如`javax.jms.QueueSender`和`javax.jms.QueueReceiver`。 了解并熟练掌握这个配置过程对于开发基于Java EE的...

    sonicmq&activemq资料

    消息中间件作为应用程序间的通信桥梁,能够实现异步处理、解耦和系统扩展性,是构建可扩展、高可用系统的关键组件。 首先,我们来了解SonicMQ。SonicMQ是由Progress Software公司开发的一款高性能、可伸缩的消息...

    SonicMQ

    SonicMQ通过异步、保证消息传递的方式,实现了不同应用间的理想连接,并内置了安全、可扩展性和可靠性。 **核心特性** 1. **高性能发布/订阅和点对点消息传递**:SonicMQ支持两种主要的消息传递模式,发布/订阅...

    MQ、JMS以及ActiveMQ关系的理解

    消息队列允许应用程序之间进行异步通信,从而提高系统的性能和可靠性。 消息队列的特点包括解耦、异步、可靠、灵活和可伸缩。解耦意味着发送者不需要知道接收者的任何信息,异步意味着发送者发送完消息后可以立即...

    SonicMQ 7.6 文档

    Progress Software Corporation对SonicMQ 7.6的知识产权保护非常重视,同时用户在使用SonicMQ时应关注最新的官方发布信息,并且可以期待SonicMQ与其他Progress产品的协同效应,以实现企业应用的高效集成和信息流通。...

    JMS 简介以及Weblogic配置JMS图解

    例如,IBM的MQSeries、BEA的WebLogic JMS服务和Progress的SonicMQ都是JMS提供者。 2. **JMS客户**:基于Java的应用程序或对象,它们是消息的生产者或消费者。 3. **JMS生产者**:创建并发送消息的组件。 4. **JMS...

    JMS与ActiveMQ

    ActiveMQ的异步通信模型和消息队列机制有助于实现应用解耦,提高系统的可扩展性和容错性。消息的持久化特性保证了即使在系统故障后,消息也不会丢失。此外,ActiveMQ的广泛连接选项和多语言支持使得它成为跨平台集成...

    论文研究-一个基于JMS和XML的用户状态实时监控系统的设计与实现.pdf

    基于JMS和XML的用户状态实时监控系统的设计与实现这一主题的研究,是围绕如何利用消息驱动架构实现用户状态监控的系统设计。在这一过程中,JMS(Java消息服务)用作消息的交换基础设施,而XML(可扩展标记语言)则...

    Basic Send Receive SonicMQ in C#-开源

    在IT行业中,消息队列(Message Queue)是分布式系统中常用的一种组件,它允许不同服务之间异步通信,提高系统的可扩展性和容错性。SonicMQ是TIBCO公司提供的一款高性能、企业级的消息中间件,它支持多种协议,如JMS...

    jMS简介和解析.doc

    常见的JMS提供者有IBM的MQSeries、BEA的Weblogic JMS服务和Progress的SonicMQ等。 2. **JMS客户**:基于Java的应用程序或对象,它们可以生产或消费消息。 3. **JMS生产者**:这部分负责创建并发送消息。 4. **JMS...

    《JAVA消息服务》PDF]

    构建应用程序使用点至点和发布与订阅消息传递模式使用情况,如交易和持久订阅的功能,使应用程序的可靠消息内实施企业JavaBeans(EJB)的使用REST风格的应用程序和消息驱动bean使用的JMS Spring应用框架 消息是一个...

    实现独立于供应商的JMS解决方案

    为了更好地理解如何设置连接,我们可以考虑两个不同的供应商实现示例:IIT SwiftMQ 2.1.3 和 Progress SonicMQ 3.5。 ##### IIT SwiftMQ 2.1.3 SwiftMQ 提供了一个 `QueueConnectionFactory` 类来创建连接工厂。...

    Java消息服务(第2版)

    · 使用JMS时结合RESTful应用程序和Spring应用程序框架 消息传递是一个强大的范例,可以更容易地使企业应用程序的不同部分分离。《Java消息服务》第二版将迅速教会你如何运用其背后的关键技术。

    Advanced Send and Receive Sonic MQ C#-开源

    AdvancedSendandReceive是功能强大的SonicMQ客户端应用程序,已在C#中实现,用于发送和接收JMS消息。 它受到BasicSendandReceive C#sonicmq所做工作的启发

    Sybase EAServer 4.1高级程序员教程,讲解了如何采用该中间件进行程序开发。

    - **前端**: 使用JSP 和 Servlet 实现用户界面。 - **后端**: 利用EJB 2.0 来处理业务逻辑。 - **数据库**: 使用Sybase 数据库存储商品信息和订单记录。 **开发步骤**: 1. **需求分析**:明确项目需求和目标。 2....

    mq产品对比

    - **RabbitMQ**主要支持AMQP协议,这是一种开放标准的协议,可以实现不同系统间的通信。 - **RocketMQ**采用了一套自定义的协议,但它提供了JMS的支持,虽然该支持尚不成熟。 **8. 持久化方式** - 大多数MQ产品...

Global site tag (gtag.js) - Google Analytics