Spring 中對JMS的支援如何實現？
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;
@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的配置檔案：
複製程式碼