RabbitMQ教程：Linux下安装、基本命令与Spring Boot集成

本文介绍: Ra b bitMQ是一个开源的消息代理和队列服务器，用于通过轻量级消息传递协议（AMQP）在分布式系统中传递消息。它支持多种编程语言，包括Jav a、Pyt h on、Ruby等。

Ra b bitMQ是一个开源的消息代理和队列服务器，用于通过轻量级消息传递协议（AMQP）在分布式系统中传递消息。它支持多种编程语言，包括Jav a、Pyth on、Ruby等。

访问Ra b bitMQ官方网站（https://www.rabbitmq.com/download.html），选择适合您操作系统的版本进行下载。

将下载的Ra b bitMQ压缩包解压到合适的目录，例如/opt。然后进入解压后的目录，执行以下命令进行安装：

sudo apt-get update
sudo apt-get install -y rabbitmq-server

安装完成后，启动RabbitMQ服务：

sudo systemctl start rabbitmq-server

为了让RabbitMQ服务在系统启动时自动运行，可以执行以下命令：

sudo systemctl enable rabbitmq-server

RabbitMQ提供了一些基本的命令来管理队列、交换机和绑定关系。以下是一些常用的命令：

使用rabbitmqctl命令创建一个新的队列：

rabbitmqctl create_queue queue_name

使用rabbitmqctl命令删除一个队列：

rabbitmqctl delete_queue queue_name

使用rabbitmqctl命令列出所有的队列：

rabbitmqctl list_queues name messages auto_delete

使用rabbitmqctl命令创建一个新的交换机：

rabbitmqctl add_exchange exchange_name type

其中，exchange_name是交换机的名称，type是交换机的类型，可以是direct、fanout、topic等。

使用rabbitmqctl命令删除一个交换机：

rabbitmqctl delete_exchange exchange_name

使用rabbitmqctl命令列出所有的交换机：

rabbitmqctl list_exchanges name type durable auto_delete internal

使用rabbitmqctl命令创建一个新的绑定关系：

rabbitmqctl bind_queue queue_name exchange_name routing_key

其中，queue_name是要绑定的队列名称，exchange_name是交换机名称，routing_key是路由键。

使用rabbitmqctl命令删除一个绑定关系：

rabbitmqctl unbind_queue queue_name exchange_name routing_key

使用rabbitmqctl命令列出所有的绑定关系：

rabbitmqctl list_bindings source destination routing_key

在项目的pom.xml文件中添加RabbitMQ Spring Boot Starter依赖：

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

在application.properties或application.yml文件中配置RabbitMQ连接信息：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class MessageProducer {
    private final AmqpTemplate amqpTemplate;
    private final String exchange = "my_exchange"; // 交换机名称，可自定义
    private final String routingKey = "my_routing_key"; // 路由键，可自定义（可选）

    @Autowired
    public MessageProducer(AmqpTemplate amqpTemplate) {
        this.amqpTemplate = amqpTemplate;
    }

    public void sendMessage(String message) {
        amqpTemplate.convertAndSend(exchange, routingKey, message);
    }
}

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class MessageConsumer {
    @RabbitListener(queues = "my_queue") // 队列名称，可自定义（可选）
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

现在可以在项目中使用MessageProducer发送消息，并在MessageConsumer中接收消息。例如，在主类中调用sendMessage方法发送消息：

public static void main(String[] args) {
    MessageProducer messageProducer = new MessageProducer(); // 假设已经注入了AmqpTemplate实例
    messageProducer.sendMessage("Hello, RabbitMQ!");
}