spring配置并使用rabbitmq

本篇博客默认你已经成功安装了rabbitmq。如未安装，可参照官网https://www.rabbitmq.com/docs/platforms，选择对应平台进行安装

一、虚拟主机

1. 虚拟主机的概念：
   虚拟主机不是指vm虚拟机，而是指一个通过逻辑进行资源隔离和分区的机制，类似于一个独立的“逻辑服务器”，通过虚拟主机，可以在同一个 RabbitMQ 实例中为不同团队、项目或客户提供独立的环境。
2. 为什么要使用虚拟主机
   1. 虚拟主机允许在单个实例中实现多环境隔离，无需部署多个 RabbitMQ 服务。
   2. 可以集中管理权限和资源，降低运维成本。
3. 虚拟主机命名规则：
   虚拟主机的名称是一个字符串，可以是任意合法字符（例如 /, _, - 等）。RabbitMQ 安装后会自动创建一个名为“/”的默认虚拟主机。
4. 虚拟主机应用场景
   1. 环境隔离：如/dev是开发环境，/test是测试环境，/prod是生产环境等
   2. 多用户系统：为每个用户分配一个客户端，如client1，client2
   3. 项目隔离：不同项目使用不同的虚拟主机，如project1，project2。
5. 创建、删除或查询虚拟主机：
   创建虚拟主机：rabbitmqctl add_vhost 虚拟主机名称
   删除虚拟主机：rabbitmqctl delete_vhost 虚拟主机名称
   查询虚拟主机：rabbitmqctl list_vhosts
   查询虚拟主机权限：rabbitmqctl list_permissions -p 虚拟主机名称

二、用户管理

1. 添加用户：rabbitmqctl add_user 用户名 用户密码
2. 列出用户：rabbitmqctl list_users
3. 删除用户：rabbitmqctl delete_user 'username'

三、身份验证和授权

在客户端链接到rabbitmq时，需要使用用户名/密码、JWT令牌或X509证书进行身份验证和授权。简单来说，就是“识别用户是谁”（身份验证），“确定用户可以做什么和不可以做什么”（授权）。

1. 用户授权：rabbitmqctl set_permissions -p "虚拟机名称" "username" ".*" ".*" ".*"
   • 第一个 “.*”：表示该用户可以对此虚拟机的所有交换机（Exchange）进行配置。
   • 第二个 “.*”：表示该用户对此虚拟机的所有队列（Queue）都有写入消息的权限。
   • 第三个 “.*”：表示该用户对此虚拟机的所有队列（Queue）都有读取消息的权限。
2. 撤销用户权限：rabbitmqctl clear_permissions -p "虚拟机名称" "username"

四、虚拟主机资源创建、删除与查询

1. 启用管理插件
   执行有以下命令启用rabbitmqadmin：

rabbitmq-plugins enable rabbitmq_management
sudo systemctl restart rabbitmq-server	#部分环境需要重启生效
wget http://localhost:15672/cli/rabbitmqadmin	#下载rabbitmqadmin脚本，如果是在其他主机访问，则localhost替换为安装rabbitmq-server的设备ip
chmod +x rabbitmqadmin
sudo mv rabbitmqadmin /usr/local/bin/

2. 启用rabbitmqadmin脚本后，执行以下命令进行资源管理：
   1. 创建交换机：rabbitmqadmin declare exchange name=exchange_name type=direct
   2. 创建持久化队列：rabbitmqadmin declare queue name=worker_manage_queue durable=true
   3. 绑定队列到交换机：rabbitmqadmin declare binding source=my_exchange destination=my_queue routing_key=routing_key
      routing_key的作用：当消息从交换器发出时，只有那些具有匹配路由键的消息才会被路由到目标队列。如果交换器类型是主题（topic）或直连（direct）类型，这个路由键非常关键，它决定了哪些消息会被发送到特定的队列。
   4. 删除交换机：rabbitmqctl delete_exchange -p 虚拟主机名称 交换机名称
   5. 删除队列：rabbitmqctl delete_queue -p 虚拟主机名称 队列名称
   6. 列出所有交换机：rabbitmqctl list_exchanges
   7. 列出所有队列：rabbitmqctl list_queues

五、spring配置rabbitmq

在理解上述概念并创建相关资源后，就可以在spring项目里进行相关配置

1. application.yaml配置如下：

spring:rabbitmq:host: 192.168.100.136	#rabbitmq-server所在主机的ipport: 5672username: abcpassword: abcdefgvirtual-host: /dev	#这里使用的是名为/dev的虚拟主机publisher-confirm-type: correlated  # 异步确认模式template:mandatory: true  # 开启路由失败回调

2. 在配置yaml后，需要在启动类上方添加@EnableRabbit，还需要编写rabbitmq配置代码：

@Configuration
public class RabbitMQConfig {public static final String QUEUE_NAME="worker_manage_queue";public static final String EXCHANGE_NAME="worker_manage_exchange";public static final String ROUTING_KEY="worker_manage_routingKey";@Beanpublic Queue queue() {return new Queue(QUEUE_NAME,true);//持久化队列}@Beanpublic DirectExchange exchange() {return new DirectExchange(EXCHANGE_NAME, true, false); // 持久化直连交换机}@Beanpublic Binding binding(Queue queue, DirectExchange exchange) {return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);}
}

3. 配置完成后，编写发送函数和接收函数即可：
   发送函数如下：

@Service
public class MessageSender {@Autowiredprivate RabbitTemplate rabbitTemplate;public void sendOrder(String order) {rabbitTemplate.convertAndSend("worker_manage_exchange",   // 交换机名称"worker_manage_routingKey",// 路由键order              // 发送的对象);}
}

接收函数如下：

@Component
public class ReciveClass {@RabbitListener(queues="worker_manage_queue")public void receiveMessage(String message) {System.out.print("这是一个消息："+message);}
}