WEB 項目中JMS的簡單應用

1.如今pom.xml 文件中引入所需的依賴

2. 配置application.xml

<!-- Activemq 鏈接工廠 -->
<bean id="activeMQConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<constructor-arg value="admin" />
<constructor-arg value="admin" />
<constructor-arg value="failover:(tcp://192.168.100.109:61616)?timeout=2000" />
</bean>

<!-- ConnectionFactory Definition -->
<bean id="amqConnectionFactory"
class="org.springframework.jms.connection.CachingConnectionFactory">
<constructor-arg ref="activeMQConnectionFactory" />
</bean>

<!-- Default Destination Queue Definition -->
<!-- 測試配置多個Destination -->
<bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="MC_MESSAGE" />
</bean>

<!-- JmsTemplate Definition -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="amqConnectionFactory" />
<property name="defaultDestination" ref="destination" />
</bean>

<!-- Message Sender Definition -->
<bean id="messageSender" class="com.xxx.config.MessageSender">
<constructor-arg index="0" ref="jmsTemplate" />
<constructor-arg index="1" ref="destination" />
</bean>
<!-- 消息監聽器，主要監聽的目的地址 Message Receiver Definition -->
<bean id="messageReceiver" class="com.xxx.config.MessageReceiver">
</bean>
<bean class="org.springframework.jms.listener.SimpleMessageListenerContainer">
<property name="connectionFactory" ref="amqConnectionFactory" />
<property name="destinationName" value="MC_MESSAGE" />
<property name="messageListener" ref="messageReceiver" />
</bean>

3. 書寫MessageSender 

package com.xxx.config;

import javax.jms.Destination;

import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;

@Component
public class MessageSender {
private final JmsTemplate jmsTemplate;
private final Destination destination;

public MessageSender(final JmsTemplate jmsTemplate, final Destination destination) {
this.jmsTemplate = jmsTemplate;
this.destination = destination;
}

public void send(final String text) {
try {
jmsTemplate.setDefaultDestination(destination);
jmsTemplate.convertAndSend(text);
// System.out.println("發送消息 : " + text);
} catch (Exception e) {
e.printStackTrace();
}
}
}

4.消息MessageReceiver 

package com.xxx.config;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

public class MessageReceiver implements MessageListener {

public void onMessage(Message message) {
if (message instanceof TextMessage) {
TextMessage textMessage = (TextMessage) message;
try {
textMessage.getText();
// System.out.println("接收到消息: " + text);
} catch (JMSException e) {
e.printStackTrace();
}
}
}

}

 5接口.調用 便可將消息發送到指定的消息隊列當中

@Resource(name="messageSender")
private MessageSender messageSender;

//定義消息實體，存儲內容，並將實體轉化爲字符串  調用send方法 將消息發送出去，同時消息監聽會打印監聽到的消息

QueneVo Vo = new QueneVo(); Vo.setId(problem.getProblemId()); Vo.setTitle("建立了新問題【"+problem.getProblemId()+"】,須要您處理"); Vo.setContent(problem.getProblemDescribe()); Vo.setMsgTime(DateUtil.getTime(0)); this.messageSender.send(JsonUtils.writeObject(Vo));