RabbitMQ教程：Linux下安装、基本命令与Spring Boot集成
1. RabbitMQ简介
RabbitMQ是一个开源的消息代理和队列服务器，用于通过轻量级消息传递协议（AMQP）在分布式系统中传递消息。它支持多种编程语言，包括Java、Python、Ruby等。
2. Linux下安装RabbitMQ
2.1 下载RabbitMQ
访问RabbitMQ官方网站（https://www.rabbitmq.com/download.html），选择适合您操作系统的版本进行下载。
2.2 解压并安装
将下载的RabbitMQ压缩包解压到合适的目录，例如/opt。然后进入解压后的目录，执行以下命令进行安装：
sudo apt-get update
sudo apt-get install -y rabbitmq-server
2.3 启动RabbitMQ服务
sudo systemctl start rabbitmq-server
2.4 设置开机自启
为了让RabbitMQ服务在系统启动时自动运行，可以执行以下命令：
sudo systemctl enable rabbitmq-server
3. RabbitMQ基本命令
RabbitMQ提供了一些基本的命令来管理队列、交换机和绑定关系。以下是一些常用的命令：
3.1 创建队列
rabbitmqctl create_queue queue_name
3.2 删除队列
rabbitmqctl delete_queue queue_name
3.3 列出所有队列
rabbitmqctl list_queues name messages auto_delete
3.4 创建交换机
rabbitmqctl add_exchange exchange_name type
其中，exchange_name是交换机的名称，type是交换机的类型，可以是direct、fanout、topic等。
3.5 删除交换机
rabbitmqctl delete_exchange exchange_name
3.6 列出所有交换机
rabbitmqctl list_exchanges name type durable auto_delete internal
3.7 创建绑定关系
rabbitmqctl bind_queue queue_name exchange_name routing_key
其中，queue_name是要绑定的队列名称，exchange_name是交换机名称，routing_key是路由键。
3.8 删除绑定关系
使用rabbitmqctl命令删除一个绑定关系：
rabbitmqctl unbind_queue queue_name exchange_name routing_key
3.9 列出所有绑定关系
使用rabbitmqctl命令列出所有的绑定关系：
rabbitmqctl list_bindings source destination routing_key
4. RabbitMQ与Spring Boot集成
要将RabbitMQ与Spring Boot集成，需要遵循以下步骤：
4.1 添加依赖
在项目的pom.xml文件中添加RabbitMQ Spring Boot Starter依赖：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
4.2 配置RabbitMQ连接信息
在application.properties或application.yml文件中配置RabbitMQ连接信息：
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
4.3 创建消息生产者
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);
}
}
4.4 创建消息消费者
创建一个消息消费者类，用于从RabbitMQ队列中接收消息：
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);
}
}
4.5 测试集成效果
现在可以在项目中使用MessageProducer发送消息，并在MessageConsumer中接收消息。例如，在主类中调用sendMessage方法发送消息：
public static void main(String[] args) {
MessageProducer messageProducer = new MessageProducer(); // 假设已经注入了AmqpTemplate实例
messageProducer.sendMessage("Hello, RabbitMQ!");
}
这样，我们就完成了RabbitMQ在Linux下的安装、基本命令以及与Spring Boot的集成。
原文地址:https://blog.csdn.net/qq_38374397/article/details/134645056
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若转载，请注明出处：http://www.7code.cn/show_16779.html
如若内容造成侵权/违法违规/事实不符，请联系代码007邮箱：suwngjj01@126.com进行投诉反馈，一经查实，立即删除！
