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

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

阅读更多
第一步: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中的包含了topic,queue的收(异步)发代码。!!!!!!!!!!!!!!,

    sonicmq&activemq资料

    sonicmq&activemq资料,收集的关sonicmq&activemq的资料,介绍了消息中间介,简单ptp和发布式的概念,以及一点点activemq的例子。

    SonicMQ

    SonicMQ,不同于IBM MQ 的另外一种MQ 软件,这里是一些基本介绍

    SonicMQ 7.6 文档

    SonicMQ7.6 英文文档 Progress® SonicMQ® Installation and Upgrade Guide V7.6

    GlassFish配置SonicMQ

    NULL 博文链接:https://mybeautiful.iteye.com/blog/1233666

    JMS与ActiveMQ

    许多厂商目前都支持 JMS,包括 IBM 的 MQSeries、BEA的 Weblogic JMS service和 Progress 的 SonicMQ,这只是几个例子。 JMS 使您能够通过消息收发服务(有时称为消息中介程序或路由器)从一个 JMS 客户机向另一个 ...

    Basic Send Receive SonicMQ in C#-开源

    使用C#中实现的使用SonicMQ的发送接收应用程序的基本示例

    《JAVA消息服务》PDF]

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

    Java消息服务(第2版)

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

    Advanced Send and Receive Sonic MQ C#-开源

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

    ESB企业服务总线简介(1)

    ESB中间件产品利用的是Web服务标准和与公认的可靠消息MOM协议接口(例如IBM的WebSphere MQ、Tibco的Rendezvous和Sonic Software的SoniCMQ)。ESB产品的共有特性包括:连接异构的MOM、利用Web服务描述语言接口封装MOM...

    十种MQ的技术选型详细对比.docx

    ActiveMQ、RabbitMQ、RocketMq、Joram、HornetQ、OpenMQ、MuleMQ、SonicMQ、ZeroMQ、Kafka 从关注度,成熟度,社区活跃度、文档、特点、授权方式、语言、事务、集群、持久化、协议,部署方式、UI、评价等诸多维度

Global site tag (gtag.js) - Google Analytics