详解Java消息队列-Spring整合ActiveMq

简介

Java消息队列是一种常见的异步通信方式，可用于解耦系统各个模块间的耦合，提升系统性能和可靠性。本文将介绍如何使用Spring框架整合ActiveMq消息队列，并给出两个示例演示如何使用。

准备工作

• JDK 1.8+
• Maven 3.0+
• ActiveMq 5.15.9
• Spring 5.0.7

操作步骤

1. 下载ActiveMq并解压；

2. 启动ActiveMq。

进入ActiveMq的bin目录下，执行以下命令：

bash
./activemq start

启动后可访问 http://localhost:8161/admin进入ActiveMq的管理界面，默认用户名和密码均为admin。

1. 创建Spring项目并添加依赖。

引入Spring的消息队列依赖：

xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

1. 配置ActiveMq连接信息。

yaml
spring:
activemq:
broker-url: tcp://localhost:61616
user: admin
password: admin

1. 定义消息发送者和消息接收者Bean。

```java
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import javax.jms.Destination;
import javax.jms.Queue;

public class JmsProducer {
// 用于发送消息到消息队列
@Autowired
private JmsMessagingTemplate jmsMessagingTemplate;
// 消息队列
@Autowired
private Queue queue;

   public void send(String message) {
       this.jmsMessagingTemplate.convertAndSend(this.queue, message);
   }

}

public class JmsConsumer {
// 接收消息从消息队列
@JmsListener(destination = "queue")
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}
}
```

在上述代码中，JmsMessagingTemplate是Spring提供的用于操作消息队列的类，通过其convertAndSend()方法发送消息到队列；@JmsListener注解则是Spring提供的用于监听指定消息队列的注解。

1. 测试示例1：简单消息发送和接收。

发送消息：

java
String message = "Hello world!";
jmsProducer.send(message);

接收消息：

java
@JmsListener(destination = "queue")
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}

1. 测试示例2：使用消息监听器容器。

java
@Component
public class JmsMessageListener implements MessageListener {
@Override
public void onMessage(Message message) {
try {
TextMessage textMessage = (TextMessage) message;
System.out.println("Received message: " + textMessage.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
}

通过配置消息监听器容器org.springframework.jms.listener.DefaultMessageListenerContainer，可以实现监听指定队列的消息，并将其传递给指定的消息监听器：

```java
@Configuration
public class AppConfig {
@Bean
public Queue queue() {
return new ActiveMQQueue("queue");
}

   @Autowired
   private Queue queue;

   @Autowired
   private JmsMessageListener jmsMessageListener;

   @Bean
   public DefaultMessageListenerContainer messageListenerContainer() {
       DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
       container.setConnectionFactory(connectionFactory());
       container.setDestination(queue);
       container.setMessageListener(jmsMessageListener);
       return container;
   }

}
```

结语

本文详细介绍了如何使用Spring整合ActiveMq消息队列，并给出了两个示例演示如何使用。活用消息队列可提升系统的性能和可靠性，值得我们在开发过程中好好利用。