Spring + JMS + ActiveMQ實現簡單的訊息佇列（監聽器非同步實現）
阿新 • • 發佈：2019-02-17
首先宣告：以下內容均是在網上找別人的部落格綜合學習而成的，可能會發現某些程式碼與其他博主的相同，由於參考的文章比較多，這裡對你們表示感謝，就不一一列舉，如果有侵權的地方，請通知我，我可以把該文章刪除。
1、jms-xml Spring配置檔案
2、Listener程式碼<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd"> <bean id = "connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name = "brokerURL" value = "tcp://localhost:61616"/> </bean> <bean id = "topicDestination" class="org.apache.activemq.command.ActiveMQTopic" autowire="constructor"> <constructor-arg value="com.spring.xkey.jms.topic"/> </bean> <bean id="sendMessage" class="com.spring.xkey.jms.SendMessage"> <property name="username" value="xkey"/> <property name="password" value="1234567890"/> </bean> <bean id = "jmsMessageConverter" class="com.spring.xkey.jms.JmsMessageConverter"> <property name="sendMessage" ref="sendMessage"/> </bean> <!-- 建立JMS傳送資訊的模板的物件 --> <bean id = "jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory" ref="connectionFactory"/> <!--property name="defaultDestination" ref="topicDestination"/--> <property name="receiveTimeout" value="6000"/> <property name="messageConverter" ref="jmsMessageConverter"/> </bean> <bean id = "jmsMessageListener" class="com.spring.xkey.jms.JmsMessageListener"> </bean> <bean id = "publisher" class="com.spring.xkey.jms.Publisher"> <property name="jmsTemplate" ref="jmsTemplate"/> <property name="destinations" ref="topicDestination" /> <property name="sendMessage" ref="sendMessage"/> </bean> <bean id = "consumer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory" ref="connectionFactory"/> <property name="destination" ref="topicDestination" /> <property name="messageListener" ref="jmsMessageListener" /> </bean> </beans>
package com.spring.xkey.jms; import java.util.Date; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import org.apache.activemq.command.ActiveMQMapMessage; public class JmsMessageListener implements MessageListener { public void onMessage(Message message) { ActiveMQMapMessage msg = null; //System.out.println("ONMessage-----------------" + message.toString()); try { if (message instanceof ActiveMQMapMessage) { msg = (ActiveMQMapMessage) message; String username = msg.getString("username"); String password = msg.getString("password"); System.out.println("Message::: "+username+", "+password); // msg = (ActiveMQMapMessage) message; // String sentDate = msg.getString("date"); // String reMessage = msg.getString("message"); // int sentCount = msg.getInt("count"); // System.out // .println("-------------New Message Arrival-----------" // + new Date()); // System.out.println("It's " + sentCount + " time From Darcy: " // + reMessage + " ---Send time :" + sentDate); } } catch (JMSException e) { System.out.println("JMSException in onMessage(): " + e.toString()); } catch (Throwable t) { System.out.println("Exception in onMessage():" + t.getMessage()); } } }
3、Converter程式碼
package com.spring.xkey.jms; import javax.jms.JMSException; import javax.jms.MapMessage; import javax.jms.Message; import javax.jms.Session; import org.springframework.jms.support.converter.MessageConversionException; import org.springframework.jms.support.converter.MessageConverter; public class JmsMessageConverter implements MessageConverter{ private SendMessage sendMessage; public void setSendMessage(SendMessage sendMsg){ this.sendMessage = sendMsg; } public Object fromMessage(Message message) throws JMSException, MessageConversionException { // TODO Auto-generated method stub MapMessage mapmessage= (MapMessage)message; this.sendMessage.setUsername(mapmessage.getString("username")); this.sendMessage.setPassword(mapmessage.getString("password")); System.out.println("First"); return sendMessage; } public Message toMessage(Object arg0, Session session) throws JMSException, MessageConversionException { // TODO Auto-generated method stub this.sendMessage = (SendMessage)arg0; MapMessage mapmessage= (MapMessage) session.createMapMessage(); mapmessage.setString("username", this.sendMessage.getUsername()); mapmessage.setString("password", this.sendMessage.getPassword()); System.out.println("Second"); return mapmessage; } }
4、Publisher程式碼
package com.spring.xkey.jms;
import java.util.Scanner;
import javax.jms.Destination;
import org.springframework.jms.core.JmsTemplate;
public class Publisher {
private JmsTemplate template;
private Destination[] destinations;
private SendMessage sendMessage;
public void chart()
{
boolean chart = true;
int count = 0;
while(chart)
{
count ++;
Scanner cin=new Scanner(System.in);
System.out.println("輸入聊天內容，輸入N停止聊天");
String text=cin.nextLine();
if(text.equals("N"))
{
chart = false;
}
System.out.println("我："+text);
sendChartMessage(count,text);
}
}
public void sendMsgCon(){
Scanner cin=new Scanner(System.in);
String username = cin.nextLine();
String password = cin.nextLine();
this.sendMessage.setUsername(username);
this.sendMessage.setPassword(password);
sendConvertor(this.sendMessage);
}
public void sendConvertor(SendMessage sendMsg){
template.convertAndSend(destinations[0],sendMsg);
}
protected void sendChartMessage(int count , String strMessage)
{
MyMessageCreator creator = new MyMessageCreator(count,strMessage);
template.send(destinations[0], creator);
}
public JmsTemplate getJmsTemplate() {
return template;
}
public void setJmsTemplate(JmsTemplate template) {
this.template = template;
}
public Destination[] getDestinations() {
return destinations;
}
public void setDestinations(Destination[] destinations) {
this.destinations = destinations;
}
public void setSendMessage(SendMessage sendMsg){
this.sendMessage = sendMsg;
}
public SendMessage getSendMessage(){
return this.sendMessage;
}
}
5、SendMessage程式碼
package com.spring.xkey.jms;
public class SendMessage {
private String username;
private String password;
public void setUsername(String user){
this.username = user;
}
public void setPassword(String pass){
this.password = pass;
}
public String getUsername(){
return this.username;
}
public String getPassword(){
return this.password;
}
}
6、Test類
package com.spring.xkey.jms;
import javax.jms.JMSException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.listener.DefaultMessageListenerContainer;
public class Test {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
ApplicationContext context =
new ClassPathXmlApplicationContext("jms.xml");
/**Sender sender = (Sender)context.getBean("sender");
sender.SendInfo();
Receiver receiver = (Receiver)context.getBean("receiver");
try {
System.out.println(receiver.receiverInfo());
} catch (JMSException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}*/
Publisher pub = (Publisher)context.getBean("publisher");
DefaultMessageListenerContainer consumer =
(DefaultMessageListenerContainer)context.getBean("consumer");
consumer.start();
pub.sendMsgCon();
//pub.chart();
}
}
JMS還是有很多東西不會的，JMS的事務沒考慮，還有一些比較高階的應用，關於Spring JMS的全部知識點在下面這個連結應該全部體現了：