消息模式 消息模式官方文档地址：https://www.rabbitmq.com/getstarted.html没有绑定交换机时采用默认交换机（路由模式）1、简单模式注：消息预览时，选择Nack 模式，ack模式预览会消费当前在队列中的消息2、工作模式类型：无特点：分发机制3、发布订阅模式类型：fanout特点：它是一种广播模式（不包含路由key）Prodducer:package com.sw.docker.rabbitmq.routing; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; /** * @Author suaxi * @Date 2021/4/8 23:26 * fanout模式（绑定队列的操作已通过图形化界面实现） */ public class Producer { public static void main(String[] args) { //1.创建连接工厂 ConnectionFactory conn = new ConnectionFactory(); conn.setHost("x.x.x.x"); conn.setPort(5672); conn.setUsername("admin"); conn.setPassword("123456"); conn.setVirtualHost("/"); Connection connection = null; Channel channel = null; try { //2.创建连接 connection = conn.newConnection("生产者"); //3.通过连接获取通道 channel = connection.createChannel(); //5.准备消息内容 String msg = "你好，谢谢"; //准备交换机 String exchangeName = "fanout-exchange"; //定义路由key String routeKey = ""; //指定交换机类型 String type = "fanout"; //6.发送消息给队列queue channel.basicPublish(exchangeName, routeKey, null, msg.getBytes()); System.out.println("消息发送成功"); }catch (Exception e){ //7.关闭通道 if (channel != null && channel.isOpen()){ try{ channel.close(); }catch (Exception e1){ e.printStackTrace(); } } //8.关闭连接 if (connection != null && connection.isOpen()){ try{ connection.close(); }catch (Exception e1){ e.printStackTrace(); } } } } } Consumer:package com.sw.docker.rabbitmq.routing; import com.rabbitmq.client.*; import java.io.IOException; /** * @Author suaxi * @Date 2021/4/8 23:26 */ public class Comsumer { private static Runnable runnable = new Runnable() { public void run() { //1.创建连接工厂 ConnectionFactory conn = new ConnectionFactory(); conn.setHost("x.x.x.x"); conn.setPort(5672); conn.setUsername("admin"); conn.setPassword("123456"); conn.setVirtualHost("/"); //获取队列名称 final String queueName = Thread.currentThread().getName(); Connection connection = null; Channel channel = null; try { //2.创建连接 connection = conn.newConnection("生产者"); //3.通过连接获取通道 channel = connection.createChannel(); //4.创建交换机，声明队列，绑定关系，路由key，发送消息，接收消息 channel.basicConsume(queueName, true, new DeliverCallback() { public void handle(String s, Delivery delivery) throws IOException { System.out.println(queueName + "收到消息：" + new String(delivery.getBody(), "UTF-8")); } }, new CancelCallback() { public void handle(String s) throws IOException { System.out.println(queueName + "接收消息失败！"); } }); System.out.println(queueName + "开始接收消息"); System.in.read(); } catch (Exception e) { //7.关闭通道 if (channel != null && channel.isOpen()) { try { channel.close(); } catch (Exception e1) { e.printStackTrace(); } } //8.关闭连接 if (connection != null && connection.isOpen()) { try { connection.close(); } catch (Exception e1) { e.printStackTrace(); } } } } }; public static void main(String[] args) { //启动三个线程接收消息 new Thread(runnable, "queue01").start(); new Thread(runnable, "queue02").start(); new Thread(runnable, "queue03").start(); } } 4、路由模式类型：direct特点：支持routing - key匹配模式Producer:package com.sw.docker.rabbitmq.direct; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; /** * @Author suaxi * @Date 2021/4/8 23:26 * direct模式 */ public class Producer { public static void main(String[] args) { //1.创建连接工厂 ConnectionFactory conn = new ConnectionFactory(); conn.setHost("x.x.x.x"); conn.setPort(5672); conn.setUsername("admin"); conn.setPassword("123456"); conn.setVirtualHost("/"); Connection connection = null; Channel channel = null; try { //2.创建连接 connection = conn.newConnection("生产者"); //3.通过连接获取通道 channel = connection.createChannel(); //5.准备消息内容 String msg = "你好，谢谢"; //准备交换机 String exchangeName = "routing_exchange"; //定义路由key String routeKey = "email"; //指定交换机类型 String type = "direct"; //6.发送消息给队列queue channel.basicPublish(exchangeName, routeKey, null, msg.getBytes()); System.out.println("消息发送成功"); }catch (Exception e){ //7.关闭通道 if (channel != null && channel.isOpen()){ try{ channel.close(); }catch (Exception e1){ e.printStackTrace(); } } //8.关闭连接 if (connection != null && connection.isOpen()){ try{ connection.close(); }catch (Exception e1){ e.printStackTrace(); } } } } } Consumer:消费者的代码与fanout模式同理5、主题Topic模式类型：topic特点：模糊的routing - key匹配模式匹配规则 #.test.# 可以有0个，1个或多个 *.test.* 必须有一级，有且只有一级Producer:package com.sw.docker.rabbitmq.topics; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; /** * @Author suaxi * @Date 2021/4/8 23:26 * topic模式 */ public class Producer { public static void main(String[] args) { //1.创建连接工厂 ConnectionFactory conn = new ConnectionFactory(); conn.setHost("x.x.x.x"); conn.setPort(5672); conn.setUsername("admin"); conn.setPassword("123456"); conn.setVirtualHost("/"); Connection connection = null; Channel channel = null; try { //2.创建连接 connection = conn.newConnection("生产者"); //3.通过连接获取通道 channel = connection.createChannel(); //5.准备消息内容 String msg = "你好，谢谢"; //准备交换机 String exchangeName = "topic_exchange"; //定义路由key String routeKey = "sw.test.com"; //指定交换机类型 String type = "topic"; //6.发送消息给队列queue channel.basicPublish(exchangeName, routeKey, null, msg.getBytes()); System.out.println("消息发送成功"); }catch (Exception e){ //7.关闭通道 if (channel != null && channel.isOpen()){ try{ channel.close(); }catch (Exception e1){ e.printStackTrace(); } } //8.关闭连接 if (connection != null && connection.isOpen()){ try{ connection.close(); }catch (Exception e1){ e.printStackTrace(); } } } } } Consumer:消费者的代码与fanout模式同理6、参数模式类型：headers特点：参数匹配

角色分类及核心组成部分 RabbitMQ角色分类none不能访问management pluginmanagement列出自己可以通过AMQP登入的虚拟机查看自己的虚拟机节点virtual hosts的queues、exchange、bindings登信息查看和关闭自己的channels和connections查看有关自己的虚拟机节点的统计信息（包括其他用户在这个节点中的活动信息）Policymaker包含management的所有权限查看、创建、删除自己的virtual hosts所属的policies和parametersMonitoring包含management所有权限列出所有的virtual hosts（包括不能登录的virtual hosts）查看其它用户的connections和channels信息查看节点级别的数据，如clustering、memory查看所有的virtual hosts全局统计信息Administrator最高权限创建、删除virtual hosts查看、创建、删除 user查看、创建 permissions关闭所有用户的connectionsRabbitMQ核心组成部分工作流程：图片来源：学相伴 飞哥-RabbitMQ

RabbitMQ 安装官网下载RabbitMQ和Erlang的包（以CentOS7为例）# RabbitMQ https://www.rabbitmq.com/download.html # Erlang https://packages.erlang-solutions.com/erlang-solutions-2.0-1.noarch.rpm安装Erlang1、创建rabbitmq文件夹mkdir -p /usr/rabbitmq2、上传下载的压缩包到刚刚创建的文件夹3、安装Erlang# 解压 rmp -Uvh esl-erlang_23.2.3-1_centos_7_amd64.rpm # 安装 yum install -y erlang # 查看版本号 erl -v # 安装socat yum install -y socat 安装rabbitmqcurl方式安装（速度较慢）：curl -s https://packagecloud.io/install/repositories/rabbitmq/rabbitmq-server/script.rpm.sh | sudo bash上传压缩包解压安装：# 解压 rpm -Uvh rabbitmq-server-3.8.14-1.el7.noarch.rpm # 安装 yum install -y rabbitmq-server # 启动并查看状态 systemctl start rabbitmq-server.service systemctl status rabbitmq-server.service # 设置开机自启 systemctl enable rabbitmq-server.service管理界面及授权操作1.开启客户端Web插件rabbitmq-plugins enable rabbitmq_management注：默认账户guest只能在本机访问管理界面，所以需要进行授权操作2.授权账户# 新增用户 rabbitmqctl add_user admin 123456 # 分配操作权限 rabbitmqctl set_user_tags admin administrator # 为用户添加资源权限 # administrator默认拥有所以权限（无需再添加） rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"用户级别：administrator 登录、查看、管理monitoring 监控者：登录、查看policymaker 策略制定者：登录、指定策略management 普通管理员：登录rabbitmqctl add_user [username] password # 添加用户 rabbitmqctl set_user_tags [permissions] administrator # 分配操作权限 rabbitmqctl change_password [username] NewPassword # 更改密码 rabbitmqctl delete_user [username] # 删除用户 rabbitmqctl list_user # 查看用户列表 rabbitmqctl set_permissions -p / [username] ".*" ".*" ".*" # 分配资源权限Docker安装RabbitMQdocker run -d -p 15672:15672 -p 5672:5672 -p 25672:25672 -p 61613:61613 -p 1883:1883 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=123456 --name myrabbitmq rabbitmq:management查看运行日志：docker logs -f myrabbitmq查看端口是否被占用：netstat -naop|grep [port]