<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<!-- 如果需要配置连接池,添加如下依赖 -->
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-pool</artifactId>
</dependency>
# activemq 配置
spring.activemq.broker-url=tcp://192.168.2.61:61616
spring.activemq.user=admin
spring.activemq.password=admin
spring.activemq.pool.enabled=false
spring.activemq.pool.max-connections=50
# 使用发布/订阅模式时,下边配置需要设置成 true
spring.jms.pub-sub-domain=false
此处 spring.activemq.pool.enabled=false,表示关闭连接池。
@Configuration
public class JmsConfirguration {
public static final String QUEUE_NAME = "activemq_queue";
public static final String TOPIC_NAME = "activemq_topic";
@Bean
public Queue queue() {
return new ActiveMQQueue(QUEUE_NAME);
}
@Bean
public Topic topic() {
return new ActiveMQTopic(TOPIC_NAME);
}
}
@Component
public class JmsSender {
@Autowired
private Queue queue;
@Autowired
private Topic topic;
@Autowired
private JmsMessagingTemplate jmsTemplate;
public void sendByQueue(String message) {
this.jmsTemplate.convertAndSend(queue, message);
}
public void sendByTopic(String message) {
this.jmsTemplate.convertAndSend(topic, message);
}
}
@Component
public class JmsReceiver {
@JmsListener(destination = JmsConfirguration.QUEUE_NAME)
public void receiveByQueue(String message) {
System.out.println("接收队列消息:" + message);
}
@JmsListener(destination = JmsConfirguration.TOPIC_NAME)
public void receiveByTopic(String message) {
System.out.println("接收主题消息:" + message);
}
}
消息消费者使用 @JmsListener 注解监听消息。
@RunWith(SpringRunner.class)
@SpringBootTest
public class JmsTest {
@Autowired
private JmsSender sender;
@Test
public void testSendByQueue() {
for (int i = 1; i < 6; i++) {
this.sender.sendByQueue("hello activemq queue " + i);
}
}
@Test
public void testSendByTopic() {
for (int i = 1; i < 6; i++) {
this.sender.sendByTopic("hello activemq topic " + i);
}
}
}
接收队列消息:hello activemq queue 1
接收队列消息:hello activemq queue 2
接收队列消息:hello activemq queue 3
接收队列消息:hello activemq queue 4
接收队列消息:hello activemq queue 5
设置 spring.jms.pub-sub-domain=true
接收主题消息:hello activemq topic 1
接收主题消息:hello activemq topic 2
接收主题消息:hello activemq topic 3
接收主题消息:hello activemq topic 4
接收主题消息:hello activemq topic 5