直接上使用步驟

1.官網下載activemq服務端，直接解壓，無需安裝，

，我用的是windows 64bit環境，直接啟動。

2.spring.xml配置

1 <!-- ++++++++++++++++++++++++++++++++++++++++++++消息隊列activeMQ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ --> 2 <!--++++++++++++++++++++++++++++++++++++++++++++++++++++發送者+++++++++++++++++++++++++++++++++++++++++++++++++++++ --> 3 <!-- 真正可以產生Connection的ConnectionFactory，由對應的 JMS服務廠商提供 --> 4 <!-- <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 5 <property name="brokerURL" value="tcp://192.168.1.101:61616" /> 6 </bean> --> 7 8 <!-- Spring用于管理真正的ConnectionFactory --> 9 <!-- <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"> --> 10 <!-- 目標ConnectionFactory對應真實的可以產生JMS Connection的ConnectionFactory --> 11 <!-- <property name="targetConnectionFactory" ref="targetConnectionFactory" /> --> 12 <!-- </bean> --> 13 14 <!-- 使用pool進行鏈接 --> 15 <!-- 真正可以產生Connection的ConnectionFactory，由對應的 JMS服務廠商提供--> 16 <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 17 <property name="brokerURL" value="tcp://192.168.1.101:61616"/> 18 <!-- 消息傳輸監聽器 處理網絡及服務器異常 --> 19 <property name="transportListener"> 20 <bean class="com.haobai.activeMQ.ActiveMQTransportListener" /> 21 </property> 22 </bean> 23 24 <bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory"> 25 <property name="connectionFactory" ref="targetConnectionFactory"/> 26 <property name="maxConnections" value="10"/> 27 </bean> 28 29 <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"> 30 <property name="targetConnectionFactory" ref="pooledConnectionFactory"/> 31 </bean> 32 33 <!-- Spring提供的JMS工具類，它可以進行消息發送、接收等 --> 34 <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> 35 <!-- 這個connectionFactory對應的是我們定義的Spring提供的那個ConnectionFactory對象 --> 36 <property name="connectionFactory" ref="connectionFactory" /> 37 </bean> 38 39 <!--這個是隊列目的地 --> 40 <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue"> 41 <constructor-arg> 42 <value>queue</value> 43 </constructor-arg> 44 </bean> 45 46 <!--這個是主題目的地，一對多的--> 47 <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic"> 48 <constructor-arg value="topic"/> 49 </bean> 50 <!--++++++++++++++++++++++++++++++++++++++++++++++++++++接收者+++++++++++++++++++++++++++++++++++++++++++++++++++++ --> 51 <!-- 消息監聽器 --> 52 <bean id="consumerMessageListener" class="com.haobai.activeMQ.ConsumerMessageListener" /> 53 <!-- 消息監聽容器 --> 54 <bean id="jmsContainer" 55 class="org.springframework.jms.listener.DefaultMessageListenerContainer"> 56 <property name="connectionFactory" ref="connectionFactory" /> 57 <property name="destination" ref="queueDestination" /> 58 <property name="messageListener" ref="consumerMessageListener" /> 59 </bean>

3.實現消息傳輸接口TransportListener

1 public class ActiveMQTransportListener implements TransportListener { 2 3 private Logger logger = LoggerFactory.getLogger(this.getClass()); 4 5 /** 6 * 對消息傳輸命令進行監控 7 * @param o 8 */ 9 public void onCommand(Object o) { 10 logger.info("onCommand -> 消息服務器消息傳輸正常..."); 11 } 12 13 /** 14 * 監控到異常時觸發 15 * @param e 16 */ 17 public void onException(IOException e) { 18 logger.error("onException -> 消息服務器連接錯誤......", e); 19 } 20 21 /** 22 * 當failover時觸發 23 */ 24 public void transportInterupted() { 25 logger.warn("transportInterupted -> 消息服務器連接發生中斷..."); 26 } 27 28 /** 29 * 監控到failover恢復后進行觸發 30 */ 31 public void transportResumed() { 32 logger.info("transportResumed -> 消息服務器連接已恢復..."); 33 } 34 35 }

4.生產者的配置，用于發消息

4.1JmsTestController? 由于發送對象需要實例化，所以這里直接轉成String了

@Controller public class JmsTestController {@Autowiredprivate ProducerService producerService;@Autowired@Qualifier("queueDestination")private Destination destination;@RequestMapping("test")@ResponseBody public String testSend() throws Exception {//向message中放2個user對象List<UserInfo> list = new LinkedList<UserInfo>();UserInfo en = new UserInfo();en.setId(100);en.setUsername("name1");list.add(en);UserInfo en2 = new UserInfo();en2.setId(1002);en2.setUsername("name2");list.add(en2);Map<String,Object> mapEntity = new HashMap<String, Object>();mapEntity.put("user", list);Map<String,Object> map = new HashMap<String, Object>();map.put("update", mapEntity);System.out.println("發送方發送內容為：" + map.toString());//發送更新數據請求 System.out.println(destination);producerService.sendMessage(destination, map.toString());return "jms exute complete";} }

4.2?ProducerService

@Service("producerService")
public class ProducerService {

　　 @Autowired private JmsTemplate jmsTemplate;

　　 public void sendMessage(Destination destination, final String message) {
　　　　jmsTemplate.send(destination, new MessageCreator() {

　　　　　　public Message createMessage(Session session) throws JMSException {
　　　　　　　　TextMessage textMessage = session.createTextMessage(message);

　　　　　　　　return textMessage;
　　　　　　}
　　　　});
　　}
}

5.消息接收者，需要實現MessageListener接口

1 public class ConsumerMessageListener implements MessageListener { 2 private Logger logger = LoggerFactory.getLogger(this.getClass()); 3 4 /** 5 * 監聽發送到消息隊列的文本消息 6 * 7 * @param message 8 */ 9 public void onMessage(Message message) { 10 TextMessage textMessage = (TextMessage) message; 11 try { 12 System.out.println("接收到的消息內容是：" + textMessage.getText()); 13 System.out.println("開始進行解析并調用service執行...."); 14 } catch (JMSException e) { 15 logger.error("消息解析失敗", e); 16 } 17 } 18 19 }

到此 ，所有配置完成。

tips：如果想要服務器A給服務器B發消息，則需要注意兩點：

1.服務器A發消息和 服務器B接受消息需要在同一個隊列。

2.服務器A不能實現MessageListener，或者不能和服務器B監聽同一個隊列，因為activemq的消息隊列，消息只能被一個消費者得到，誰先搶到算誰的。A、B同時監聽一個隊列，有可能A發的消息直接被A搶了，B啥都沒有接收到。

?

好了，暫時就記這么多，以后遇到問題繼續增加

?

轉載于:https://www.cnblogs.com/yzx2018/p/8951150.html

總結

以上是生活随笔為你收集整理的spring 整和activemq的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。