🍁博客主页：👉不会压弯的小飞侠
✨欢迎关注：👉点赞👍收藏⭐留言✒
✨系列专栏：👉Linux专栏
🔥欢迎大佬指正，一起学习！一起加油！

目录

• 🍁介绍
• 🍁简单模式完成消息传递
• 🍁总结

🍁介绍

• “P”是我们的生产者，“C”是我们的消费者。 中间的框是一个队列 - RabbitMQ 保留的消息缓冲区 代表消费者。
• 生产者将消息发送到“hello”队列。消费者收到 来自该队列的消息。
  
• 一个生产者、一个消费者，不需要设置交换机（使用默认的交换机）

🍁简单模式完成消息传递

• 创建工程（生成者、消费者）

• 往两个rabbitmq的pom.xml文件中添加依赖：

com.rabbitmqamqp-client5.6.0org.apache.maven.pluginsmaven-compiler-plugin3.8.01.81.8

• 编写生产者发送消息
  • 编写消息生产者 Producter

package com.study.rabbitmq.simple;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.concurrent.TimeoutException;//简单模式的生产者
public class Producer {public static void main(String[] args) throws IOException, TimeoutException {//创建连接工厂ConnectionFactory connectionFactory = new ConnectionFactory();//设置主机connectionFactory.setHost("*************");  //主机IP//设置端口号connectionFactory.setPort(5672);//虚拟主机名称;默认为 /connectionFactory.setVirtualHost("/");//连接用户名；默认为guestconnectionFactory.setUsername("admin");//连接密码；默认为guestconnectionFactory.setPassword("root");//创建连接Connection connection = connectionFactory.newConnection();//创建信道Channel channel = connection.createChannel();// 声明（创建）队列/*** queue      参数1：队列名称* durable    参数2：是否定义持久化队列,当mq重启之后,还在* exclusive  参数3：是否独占本次连接*            ① 是否独占,只能有一个消费者监听这个队列*            ② 当connection关闭时,是否删除队列* autoDelete 参数4：是否在不使用的时候自动删除队列,当没有consumer时,自动删除* arguments  参数5：队列其它参数*/channel.queueDeclare("simple_queue", true, false, false, null);// 要发送的信息String message = "Hello RabbitMQ！";/*** 参数1：交换机名称,如果没有指定则使用默认Default Exchage* 参数2：路由key,简单模式可以传递队列名称* 参数3：配置信息* 参数4：消息内容*/channel.basicPublish("", "simple_queue", null, message.getBytes());System.out.println("已发送消息：" + message);// 关闭资源channel.close();connection.close();}
}

• 测试生产者

• 编写消费者接收消息
  • 编写消息消费者Consumer

package rabbitmq.simple;import com.rabbitmq.client.*;import java.io.IOException;
import java.util.concurrent.TimeoutException;public class Consumer {public static void main(String[] args) throws IOException, TimeoutException {//1.创建连接工厂ConnectionFactory factory = new ConnectionFactory();//2. 设置参数factory.setHost("********************");//主机ipfactory.setPort(5672); //端口  默认值 5672factory.setVirtualHost("/");//虚拟机 默认值/factory.setUsername("admin");//用户名factory.setPassword("root");//密码//3. 创建连接 ConnectionConnection connection = factory.newConnection();//4. 创建信道Channel channel = connection.createChannel();/*消费者不需要声明队列，queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map arguments)参数：1. queue：队列名称2. durable：是否持久化,当mq重启之后,还在3. exclusive：* 是否独占。只能有一个消费者监听这队列* 当Connection关闭时,是否删除队列4. autoDelete：是否自动删除。当没有Consumer时,自动删除掉5. arguments：参数。*///如果没有一个名字叫simple_queue的队列,则会创建该队列,如果有则不会创建channel.queueDeclare("simple_queue",true,false,false,null);// 接收消息DefaultConsumer consumer = new DefaultConsumer(channel){/*回调方法,当收到消息后,会自动执行该方法1. consumerTag：标识2. envelope：获取一些信息,交换机,路由key...3. properties：配置信息4. body：数据*/@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println("consumerTag："+consumerTag);System.out.println("Exchange："+envelope.getExchange());System.out.println("RoutingKey："+envelope.getRoutingKey());System.out.println("properties："+properties);System.out.println("body："+new String(body));}};/*basicConsume(String queue, boolean autoAck, Consumer callback)参数：1. queue：队列名称2. autoAck：是否自动确认 ,类似咱们发短信,发送成功会收到一个确认消息3. callback：回调对象*/// 消费者类似一个监听程序,主要是用来监听消息channel.basicConsume("simple_queue",true,consumer);}
}

• 测试消费者

🍁总结

• P：生产者，也就是要发送消息的程序
• C：消费者：消息的接受者，会一直等待消息到来。
• queue：消息队列类似一个邮箱，可以缓存消息；生产者向其中投递消息，消费者从其中取出消息。