ActiveMQ教程
同步接收
jmsTemplate.receive()
一个线程在工作,没接收到就等待,接收到了就往下执行直到程序结束;
如果想循环不断地接收,那么就写个while true循环。
使用监听器监听ActiveMQ目的地,当有消息的时候,回调onMessage方法对消息进行处理,ActiveMQ与SpringBoot集成异步接收消息有两种实现方式。
A、 创建SpringBoot工程13-activemq-boot-receiver-async-01
B、 创建的工程的时候,勾选集成ActiveMQ,会在pom.xml中添加如下依赖
<!--SpringBoot集成ActiveMQ的起步依赖-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
C、 在application.properties文件中配置ActiveMQ信息
#配置activemq的连接信息
spring.activemq.broker-url=tcp://192.168.235.128:61616
#目的地
spring.jms.template.default-destination=bootQueue
#默认是缓存了jms的session的,所以主程序发送完消息后,不会退出
# 改为false主程序才可以退出 从SpringBoot2.1.0以后新增的
spring.jms.cache.enabled=false
D、 在com.bjpowernode.activemq.service包下创建MessageService类接收消息
@Service
public class MessageService {
/**
* SpringBoot程序启动后,会扫描到当前service类
* 监听器对象会被创建
* 通过注解指定了该监听器对象监听的目的地
* 如果目的地上有消息需要接收,会调用我们自定义的方法,并传递接收到的消息到方法中
* 方法名可以任意
*/
@JmsListener(destination="${spring.jms.template.default-destination}")
public void receiveMessage(Message message){
if(message instanceof TextMessage){
try {
String text = ((TextMessage) message).getText();
System.out.println("SpringBoot异步接收到的消息为:" + text);
} catch (JMSException e) {
e.printStackTrace();
}
}
}
}
E、 运行Application程序,发送一个消息,查看接收效果
2、@Configuration配置方式实现
这种方式其实就是将spring接收异步请求需要配置的xml文件信息,放到配置类中。
A、 创建SpringBoot工程13-activemq-boot-receiver-async-02
B、 创建的工程的时候,勾选集成ActiveMQ,会在pom.xml中添加如下依赖
<!--SpringBoot集成ActiveMQ的起步依赖-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
C、 在application.properties文件中配置ActiveMQ信息
#配置activemq的连接信息
spring.activemq.broker-url=tcp://192.168.235.128:61616
#目的地
spring.jms.template.default-destination=bootQueue
#默认是缓存了jms的session的,所以主程序发送完消息后,不会退出
# 改为false主程序才可以退出 从SpringBoot2.1.0以后新增的
spring.jms.cache.enabled=false
D、 自定义监听器接收处理消息(可以从12-activemq-spring-receiver-async拷贝)
该监听器没有在配置文件中注册bean,所有需要加@Component让Spring容器扫描
E、 在com.bjpowernode.activemq.config包下创建ActiveMQConfig类,用于替换我们前面在applicationContex-jms中配置的信息
@Configuration//相当于applicationContext-jms.xml文件
public class ActiveMQConfig {
/*
<!-- 配置一个连接工厂 -->
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.168.235.128:61616"/>
</bean>
因为SpringBoot已经自动配置好了ActiveMQ的连接工厂,所有我们在配置文件中就不需要对这个bean进行配置
我们在使用的时候,直接注入即可
*/
@Autowired
private ActiveMQConnectionFactory connectionFactory;
@Autowired //注入我们自定义的监听器
private MyMessageListener myMessageListener;
//通过@Value注解接收SpringBoot配置文件中的目的地配置
@Value("${spring.jms.template.default-destination}")
private String destination;
/**
<!-- 配置一个sping监听器的容器 -->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<!--引用连接工厂-->
<property name="connectionFactory" ref="connectionFactory"/>
<!--指定监听的目的地-->
<property name="destinationName" value="springQueue"/>
<!--监听到消息后,会回调onMessage方法,我们在自定义的监听器中对onMessage方法进行重写,完成消息的接收-->
<property name="messageListener" ref="myMessageListener" />
<!--pubSubDomain=false表示点对点消息,true表示发布订阅消息,默认是false-->
<property name="pubSubDomain" value="true"/>
</bean>
*/
@Bean //@Bean注解就相当于配置文件的bean标签
public DefaultMessageListenerContainer defaultMessageListenerContainer(){
DefaultMessageListenerContainer listenerContainer = new DefaultMessageListenerContainer();
listenerContainer.setConnectionFactory(connectionFactory);
listenerContainer.setDestinationName(destination);
listenerContainer.setMessageListener(myMessageListener);
//目前我们默认就是点对点的消息,暂时不配置发布订阅
return listenerContainer;
}
}
F、 运行Application程序,发送一个消息,查看接收效果