Spring 中对JMS的支持如何实现?
2018-01-04 15:12
323 查看
JMS(java消息服务)整合Spring项目案例
转载自云栖社区
摘要: Sprng-jms消息服务小项目 所需的包: spring的基础包 spring-jms-xx包 spring-message–xx包 commons-collection-xx包 commons-pool2-xx包 aop切面的包: spring-aop,spring-aspect…
Sprng-jms消息服务小项目
所需的包:
spring的基础包
spring-jms-xx包
spring-message–xx包
commons-collection-xx包
commons-pool2-xx包
aop切面的包: spring-aop,spring-aspect,aopalliance,aspectjrt.jar,aspectjweaver.jar
配置:
1.配置ConnectionFactory
2.配置jmsTemplate;
3.配置Destination
4.配置listener
5.配置container
话不多说,直接上代码
前提是你已经开启了activemq服务
看一下项目架构
临听器有两种实现方案: 一种是采用原生的jms的MessageListener
另一种是采用spring的方案:SessionAwareMessageListener
前一种只能消费消息,不能发送回送消息
后一种可以再接到消息后,给生产者回送消息,它自己即是生产者也是消费者
所有所需的连接工、目的地等都是通过Spring注入的,具体看后面的配置文件
发送消息的接口:
复制代码
package com.tg.service;
public interface PersonService {
public void sendMessage(String message);
}
复制代码
生产者一:
复制代码
package com.tg.service;
import javax.annotation.Resource;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import org.springframework.context.annotation.Scope;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Service;
}
复制代码
消费者一:
复制代码
package com.tg.service;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
//临听器有两种实现方案: 一种是采用原生的jms的MessageListener
// 另一种是采用spring的方案:SessionAwareMessageListener
//注意: 这里的MessageListener接口是 jms的接口
public class ConsumerMessageListener1 implements MessageListener {
}
复制代码
生产者二:
复制代码
package com.tg.service;
import javax.annotation.Resource;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Service;
@Service(“personServiceImpl2”)
public class PersonServiceImpl2 implements PersonService {
private Destination destination; //用于存发送信息的队列
private JmsTemplate jsmTemplate; //jms操作模板
private Destination replyQueueDestination; //用于存回复信息的队列,
@Override
public void sendMessage(final String message) {
System.out.println(“生产者2->发送消息” + message);
// 回调
jsmTemplate.send(destination, new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
Message msg = session.createTextMessage(message);
// 设置回复的信息的目的地.
msg.setJMSReplyTo(replyQueueDestination);
// 设置发送的信息类型 为非持久化信息
msg.setJMSDeliveryMode(DeliveryMode.NON_PERSISTENT);
}
复制代码
消费者二:
复制代码
package com.tg.service;
import javax.annotation.Resource;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.springframework.jms.listener.SessionAwareMessageListener;
import org.springframework.stereotype.Component;
/**
* SessionAwareMessageListener:是由spring提供,它可以在回调方法中传入session,以此回送信息到生产者
* @author Administrator
*
*/
@Component(“consumerMessageListener2”)
public class ConsumerMessageListener2 implements SessionAwareMessageListener {
}
复制代码
Spring的配置文件:
复制代码
转载自云栖社区
摘要: Sprng-jms消息服务小项目 所需的包: spring的基础包 spring-jms-xx包 spring-message–xx包 commons-collection-xx包 commons-pool2-xx包 aop切面的包: spring-aop,spring-aspect…
Sprng-jms消息服务小项目
所需的包:
spring的基础包
spring-jms-xx包
spring-message–xx包
commons-collection-xx包
commons-pool2-xx包
aop切面的包: spring-aop,spring-aspect,aopalliance,aspectjrt.jar,aspectjweaver.jar
配置:
1.配置ConnectionFactory
2.配置jmsTemplate;
3.配置Destination
4.配置listener
5.配置container
话不多说,直接上代码
前提是你已经开启了activemq服务
看一下项目架构
临听器有两种实现方案: 一种是采用原生的jms的MessageListener
另一种是采用spring的方案:SessionAwareMessageListener
前一种只能消费消息,不能发送回送消息
后一种可以再接到消息后,给生产者回送消息,它自己即是生产者也是消费者
所有所需的连接工、目的地等都是通过Spring注入的,具体看后面的配置文件
发送消息的接口:
复制代码
package com.tg.service;
public interface PersonService {
public void sendMessage(String message);
}
复制代码
生产者一:
复制代码
package com.tg.service;
import javax.annotation.Resource;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import org.springframework.context.annotation.Scope;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Service;
@Service("personServiceImpl") @Scope("prototype") public class PersonServiceImpl implements PersonService { private Destination destination; private JmsTemplate jsmTemplate; private Destination replyQueueDestination; @Override public void sendMessage(final String message) { System.out.println("生产者发送消息"+ message); //回调 jsmTemplate.send(destination, new MessageCreator(){ @Override public Message createMessage(Session session) throws JMSException { //创建一个文本消息 Message msg = session.createTextMessage(message); //指定为非持久化方式 msg.setJMSDeliveryMode( DeliveryMode.NON_PERSISTENT ); return msg; } }); } @Resource(name="queueDestination") public void setDestination(Destination destination) { this.destination = destination; } @Resource(name="jmsTemplate") public void setJsmTemplate(JmsTemplate jsmTemplate) { this.jsmTemplate = jsmTemplate; } @Resource(name = "replyQueueDestination") public void setReplyDestination(Destination replyDestination) { this.replyQueueDestination = replyDestination; }
}
复制代码
消费者一:
复制代码
package com.tg.service;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
//临听器有两种实现方案: 一种是采用原生的jms的MessageListener
// 另一种是采用spring的方案:SessionAwareMessageListener
//注意: 这里的MessageListener接口是 jms的接口
public class ConsumerMessageListener1 implements MessageListener {
@Override public void onMessage(Message message) { if( message instanceof TextMessage){ TextMessage text=(TextMessage) message; System.out.println("接收到的消息是一个文本消息:"+ text); //这种方式无法回复 所以采用第二种 } }
}
复制代码
生产者二:
复制代码
package com.tg.service;
import javax.annotation.Resource;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Service;
@Service(“personServiceImpl2”)
public class PersonServiceImpl2 implements PersonService {
private Destination destination; //用于存发送信息的队列
private JmsTemplate jsmTemplate; //jms操作模板
private Destination replyQueueDestination; //用于存回复信息的队列,
@Override
public void sendMessage(final String message) {
System.out.println(“生产者2->发送消息” + message);
// 回调
jsmTemplate.send(destination, new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
Message msg = session.createTextMessage(message);
// 设置回复的信息的目的地.
msg.setJMSReplyTo(replyQueueDestination);
// 设置发送的信息类型 为非持久化信息
msg.setJMSDeliveryMode(DeliveryMode.NON_PERSISTENT);
//创建一个消费者,用于接收对方回复的信息 注意,这个消费者临听 replyDestination
MessageConsumer comsumer2 = session.createConsumer(replyQueueDestination);
comsumer2.setMessageListener(new MessageListener() {
public void onMessage(Message m) {
try {
System.out.println("接收到的回复信息:" + ((TextMessage) m).getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
});
return msg;
}
});
}
@Resource(name = "replyQueueDestination")
public void setReplyDestination(Destination replyDestination) {
this.replyQueueDestination = replyDestination;
}
@Resource(name = "sendQueueDestination")
public void setDestination(Destination destination) {
this.destination = destination;
}
@Resource(name = "jmsTemplate")
public void setJsmTemplate(JmsTemplate jsmTemplate) {
this.jsmTemplate = jsmTemplate;
}
}
复制代码
消费者二:
复制代码
package com.tg.service;
import javax.annotation.Resource;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.springframework.jms.listener.SessionAwareMessageListener;
import org.springframework.stereotype.Component;
/**
* SessionAwareMessageListener:是由spring提供,它可以在回调方法中传入session,以此回送信息到生产者
* @author Administrator
*
*/
@Component(“consumerMessageListener2”)
public class ConsumerMessageListener2 implements SessionAwareMessageListener {
private Destination destination; @Override public void onMessage(TextMessage message, Session session) throws JMSException { System.out.println("接收到的消息是一个文本消息:"+ message.getText()); //通过session 创建 producer对象,再回送信息 //从message中取出信息回送的目的地,以便创建生产者. MessageProducer producer=session.createProducer( message.getJMSReplyTo() ); //创建一条消息 Message textMessage=session.createTextMessage( "生产者发过来的信息已经处理完毕,game over..." ); //调用发送 producer.send(textMessage); } @Resource(name="sendQueueDestination") public void setDestination(Destination destination) { this.destination = destination; }
}
复制代码
Spring的配置文件:
复制代码
相关文章推荐
- [转]ssh中如何实现定时任务(spring对quartz的支持)
- 关于spring 2.0自定义xml 标记 (二 如何实现)
- 字符集之:如何(在程序中)加入并使用 Unicode 以实现外语支持
- 问题:Spring如何支持Hibernate
- 如何实现webwork+spring+hibernate框架的结合应用
- 问题:Spring如何支持IBatis
- Spring ProxyFactoryBean 是如何实现所有的AOP proxy都有可能转为Advised接口的?
- 如何自己实现IEnumerable和IEnumerator接口以支持foreach语句
- ActiveMQ5.0.1+Spring实现JMS异步消息发送
- .Net中的异步编程模式 (APM) (三): 如何实现支持APM的设备操作
- Spring如何实现IOC与AOP的
- 使用Spring JMS和SonicMQ实现异步通信
- Blazeds+JMS(ActiveMQ)+Spring实现消息[转]
- 如何对WordPress主题实现多语言化支持之简单教程(转载)
- JMS(Jboss Messaging)的一点使用心得(十一)Spring扩展应用-可自动重连的JmsMessageListenerContainer的另一种实现
- 使用Spring JMS轻松实现异步消息传递
- spring对jboss与weblogic的jms的支持不一样
- 关于spring 2.0自定义xml 标记 (二 如何实现)
- Spring 对 JMS的支持
- 关于spring 2.0自定义xml 标记 (二 如何实现)