Spring集成ActiveMQ实现

骑猪看日落 2022-01-07 22:09 210阅读 0赞

## 参考资料 ##

[Spring Framework 5.1.8.RELEASE API][]

## 导入依赖 ##

<dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-all</artifactId>
        <version>5.9.0</version>
    </dependency>
    
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jms</artifactId>
        <version>4.3.18.RELEASE</version>
    </dependency>

## 配置application.xml中的JMS模板 ##

<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://127.0.0.1:61616" />
    </bean>
    
    
    <bean id="JMSconnectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
        <property name="targetConnectionFactory" ref="targetConnectionFactory" />
    </bean>
    
    
    <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
        <constructor-arg value="SpringActiveMQMsg"/>
    </bean>
    
    
    <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">      
        <constructor-arg value="SpringActiveMQMsgTopic"/>
    </bean>
    
    
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="JMSconnectionFactory"/>
    </bean>
    
    
    <bean id="consumerMessageListener" class="com.scheduleserver.Listener.MyMessageListener"/>
    
    
    <bean id ="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        
        <property name="connectionFactory" ref="JMSconnectionFactory"/>
        
        <property name="destination" ref="queueDestination"/>
        
        <property name="messageListener" ref="consumerMessageListener"/>
    </bean>

## 生产者发送信息 ##

@Autowired private JmsTemplate jmsTemplate; // 可能存在多个目的地，所以用按名称注入 @Resource(name = "queueDestination") private Destination destination; @PostMapping("/test") public ResponseObject test(@RequestParam String msg) { jmsTemplate.send(destination , new MessageCreator() { @Override public Message createMessage(Session session) throws JMSException { TextMessage textMessage = session.createTextMessage(msg); return textMessage; } }); System.out.println("费哥爱你哦： " + msg); return ResponseObject.generateSuccessResponse(); }

## 消费者接收信息 ##

package com.scheduleserver.Listener; import javax.jms.JMSException; import javax.jms.MessageListener; import javax.jms.TextMessage; public class MyMessageListener implements MessageListener { @Override public void onMessage(javax.jms.Message message) { TextMessage tmes = (TextMessage) message; try { System.out.println(tmes.getText()); } catch (JMSException e) { e.printStackTrace(); } } }

**控制台输出：**  
费哥爱你哦： 自律使我自由！  
自律使我自由！

## 总结 ##

若想按主题发送消息，生产者和消费者的目标地址换成主题目标地址就行了。

转载于:https://www.cnblogs.com/feiqiangsheng/p/11016939.html

[Spring Framework 5.1.8.RELEASE API]: https://docs.spring.io/spring/docs/current/javadoc-api/overview-summary.html