spring cloud 搭建消息中间件 RabbitMQ 环境、Mac/Windows下载安装RabbitMQ、配置RabbitMQ环境变量

**Spring Cloud 搭建消息中间件 RabbitMQ 环境**

在微服务架构中，消息中间件是非常重要的组成部分，它可以帮助我们实现服务之间的通信、解耦以及异步处理。RabbitMQ 是一个流行的开源消息中间件，支持多种协议和语言。在本文中，我们将一步一步地搭建 Spring Cloud 环境下的 RabbitMQ。

**下载安装 RabbitMQ**

首先，我们需要在 Mac 或 Windows 上下载并安装 RabbitMQ。

### 在 Mac 上安装 RabbitMQ1. 打开终端，运行以下命令：

bashbrew install rabbitmq

2. 等待安装完成后，启动 RabbitMQ服务：

bashbrew services start rabbitmq

### 在 Windows 上安装 RabbitMQ1. 下载 RabbitMQ 的安装包（例如 `rabbitmq-server-3.8.14.exe`）。
2. 运行安装程序，按照提示进行安装。
3. 安装完成后，启动 RabbitMQ服务。

**配置 RabbitMQ 环境变量**

在 Windows 上，我们需要配置环境变量来让我们的应用程序找到 RabbitMQ服务。

1. 右键点击 "计算机"，选择 "属性"。
2. 在 "系统属性" 窗口中，单击 "高级系统设置"。
3. 单击 "环境变量"。
4. 在 "系统变量" 部分，新建一个变量名为 `RABBITMQ_HOME`，值为 RabbitMQ 的安装目录（例如 `C:Program FilesRabbitMQ Serverrabbitmq_server-3.8.14`）。
5. 新建另一个变量名为 `PATH`，值为 `%RABBITMQ_HOME%sbin;%PATH%`。

**Spring Cloud 搭建 RabbitMQ 环境**

现在，我们可以开始搭建 Spring Cloud 环境下的 RabbitMQ。

###依赖配置在我们的 `pom.xml` 文件中，我们需要添加以下依赖：

xml<dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

### 配置文件我们需要创建一个 `application.yml` 文件来配置 RabbitMQ 的连接信息：

ymlspring:
 rabbitmq:
 host: localhost port:5672 username: guest password: guest

### RabbitTemplate 配置我们需要在我们的应用程序中注入一个 `RabbitTemplate` 来发送消息到 RabbitMQ：

java@Configurationpublic class RabbitConfig {
 @Bean public RabbitTemplate rabbitTemplate() {
 return new RabbitTemplate();
 }
}

### 消息生产者我们可以创建一个简单的消息生产者来测试我们的 RabbitMQ 环境：

java@Servicepublic class MessageProducer {
 @Autowired private RabbitTemplate rabbitTemplate;
 public void sendMessage(String message) {
 rabbitTemplate.convertAndSend("myQueue", message);
 }
}

### 消息消费者我们可以创建一个简单的消息消费者来测试我们的 RabbitMQ 环境：

java@Servicepublic class MessageConsumer {
 @Autowired private RabbitTemplate rabbitTemplate;
 public void receiveMessage(String message) {
 System.out.println("Received message: " + message);
 }
}

### 测试我们可以在我们的测试类中使用 `@SpringBootTest` 和 `@AutoConfigureTestAnnotations` 来测试我们的 RabbitMQ 环境：

java@SpringBootTestpublic class RabbitMqTest {
 @Autowired private MessageProducer messageProducer;
 @Autowired private MessageConsumer messageConsumer;
 @Test public void testSendMessage() {
 String message = "Hello, World!";
 messageProducer.sendMessage(message);
 messageConsumer.receiveMessage(message);
 }
}

通过以上步骤，我们成功地搭建了 Spring Cloud 环境下的 RabbitMQ。