使用Spring JMS和SonicMQ实现异步通信
2010-04-09 15:39
309 查看
第一步: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
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
相关文章推荐
- JMS(Jboss Messaging)的一点使用心得(十一)Spring扩展应用-可自动重连的JmsMessageListenerContainer的另一种实现
- 使用Spring JMS轻松实现异步消息传递
- Spring+JMS+使用JMS+ActiveMQ中间件+实现简单聊天功能的小例子
- 使用Spring JMS轻松实现异步消息传递
- spring-jms(activemq实现)使用queue发送消息简单例子
- 使用Spring JMS轻松实现异步消息传递
- Spring学习笔记 —— AOP(面向切面编程) 之使用ProxyFactoryBean实现AOP
- 使用Spring AOP结合自定义Java注解实现动态数据源设置
- spring整合JMS - 基于ActiveMQ实现
- Spring+JMS实现消息的发送与接收
- 使用Spring设计和实现Web应用程序 开发指引(二)
- Spring Boot使用过滤器和拦截器分别实现REST接口简易安全认证
- Spring Boot使用过滤器和拦截器分别实现REST接口简易安全认证
- 使用自定义注解+Spring AOP 实现日志记录
- java 使用spring实现读写分离
- 使用Spring JMS简化异步消息处理
- Quartz触发器的使用(Spring实现)
- spring与dwr整合实现js直接使用java代码
- Spring环境下使用多个JMS队列时找不到JMS队列的问题
- spring camel 使用一个实现类去处理web service的请求