求关注

快速入门生产者与消费者，SpringBoot整合RabbitMQ！

前言

本章我们来一次快速入门RabbitMQ——生产者与消费者。需要构建一个生产端与消费端的模型。什么意思呢？我们的生产者发送一条消息，投递到RabbitMQ集群也就是Broker。

我们的消费端进行监听RabbitMQ，当发现队列中有消息后，就进行消费。

1. 环境准备

本次整合主要采用SpringBoot框架，需要对SpringBoot的使用有一定了解。

2.大概步骤

我们来看下大概步骤：

• ConnectionFacorty：获取连接工厂
• Connection：一个连接
• Channel：数据通信信道，可发送和接收消息
• Queue：具体的消息存储队列
• Producer & Consumer 生产者和消费者

这个连接工厂需要配置一些相应的信息，例如: RabbitMQ节点的地址，端口号，VirtualHost等等。

Channel是我们RabbitMQ所有消息进行交互的关键。

3. 项目实战

3.1 连接工厂

/** * * @ClassName: ConnectionUtils * @Description: 连接工具类* @author Coder编程* @date 2019年6月21日 上午22:28:22 * */public class ConnectionUtils { public static Connection getConnection() throws IOException, TimeoutException { //定义连接工厂 ConnectionFactory factory = new ConnectionFactory(); //设置服务地址 factory.setHost("127.0.0.1"); //端口 factory.setPort(5672);//amqp协议 端口 类似与mysql的3306 //设置账号信息，用户名、密码、vhost factory.setVirtualHost("/vhost_cp"); factory.setUsername("user_cp"); factory.setPassword("123456"); // 通过工程获取连接 Connection connection = factory.newConnection(); return connection; }}

3.2 生产端

/** * * @ClassName: Producer * @Description: 生产者* @author Coder编程* @date 2019年7月30日 上午21:04:43 * */public class Producer { public static void main(String[] args) throws Exception { System.out.println("Producer start..."); //1 创建ConnectionFactory Connection connection = ConnectionUtils.getConnection(); //2 通过connection创建一个Channel Channel channel = connection.createChannel(); //3 通过Channel发送数据 for(int i=0; i < 5; i++){ String msg = "Hello RabbitMQ!"; //1 exchange 2 routingKey  channel.basicPublish(