%20(2).svg)
项目简介
本项目是基于RabbitMQ的消息队列系统，用于实现跨进程的通信机制，进行上下游信息传递。RabbitMQ作为消息中间件，能对系统间的信息传递解耦，并保障数据可靠性。项目支持多种消息队列模式，有丰富的应用场景，如异构系统的数据传递、高并发程序的流量控制、分布式系统的事务一致性等。
项目的主要特性和功能
- 消息队列模式
- 发布 - 订阅模式：可将消息发布到交换机，多个消费者能订阅同一交换机上的消息。
- 路由模式：在发布订阅模式基础上筛选数据，通过精确匹配路由键降低数据传输总量。
- 主题模式：在路由模式上进行模糊匹配，支持用通配符匹配路由键。
- 消息确认机制
- Confirm模式：确保生产者将消息送到Broker时的可靠传输。
- Return模式：消息被Broker正常接受但无对应队列投递时，消息退回生产者。
- 多种应用场景：异构系统的数据传递、高并发程序的流量控制、分布式系统的事务一致性、高可靠性的交易系统。
- 集群架构模式
- 主备模式：一主一备，一台工作一台备用。
- 镜像模式：所有设备数据同步。
- 远程模式：在不同数据中心复制消息，跨地域互联两个MQ集群。
- 多活模式：实现异地数据复制和持续可靠的AMQP数据通信。
安装使用步骤
1. 安装RabbitMQ
Windows下安装
- 安装Erlang运行环境。
- 下载并安装RabbitMQ服务器程序。
- 启用RabbitMQ管理控制台。
Linux下安装
- 下载并安装Erlang运行环境RPM包。
- 下载并安装RabbitMQ服务器程序RPM包。
- 启用RabbitMQ管理控制台。
- 启动RabbitMQ服务并设置防火墙放行端口。
2. 启动RabbitMQ服务
```bash rabbitmq-server
rabbitmq-server -detached ```
3. 常用命令
```bash rabbitmq-server
rabbitmqctl stop
rabbitmqctl start_app rabbitmqctl stop_app ```
4. 编译和运行项目
- 复制项目代码到本地。
- 进入项目目录：
bash cd your-repo - 编译项目：
bash mvn clean install - 运行项目：
bash java -jar target/your-project.jar
5. 配置RabbitMQ连接
在项目配置文件中配置RabbitMQ的连接信息，包括主机地址、端口号、用户名和密码等。
properties
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
6. 启动生产者和消费者
分别启动生产者和消费者程序，确保消息能够正确发送和接收。 ```bash java -cp target/your-project.jar com.ntuzy.rabbitmq.Producer
java -cp target/your-project.jar com.ntuzy.rabbitmq.Consumer ``` 通过以上步骤，可成功安装并运行基于RabbitMQ的消息队列系统，实现跨进程的通信和数据传递。
下载地址
点击下载 【提取码: 4003】【解压密码: www.makuang.net】