您当前的位置： 首页 >  docker

止步前行

暂无认证

  • 2浏览

    0关注

    247博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文

消息中间件RabbitMQ（一）——Docker环境安装及说明

止步前行 发布时间：2018-12-14 18:41:58 ，浏览量：2

文章目录
  • 1. Docker下安装RabbitMQ
    • 1.1 查询RabbitMQ镜像
    • 1.2 获取镜像
    • 1.3 检查镜像
    • 1.4 运行镜像
    • 1.5 查询镜像运行情况
    • 1.6 验证客户端
  • 2. RabbitMQ管理页面
    • 2.1 总体概览
    • 2.2 Overview
      • 2.2.1 Totals
      • 2.2.2 Nodes
      • 2.2.3 Churn statistics
      • 2.2.4 Ports and contexts
      • 2.2.5 Export definitions / Import definitions
    • 2.3 Connections
    • 2.4 Channels
      • 2.4.1 通道
    • 2.5 Exchange
    • 2.6 Queue
    • 2.7 Admin
  • 3. 使用Web管理页面操作RabbitMQ
    • 3.1 根据消息队列图，创建交换器
    • 3.2 添加消息队列
    • 3.3 为交换器绑定消息队列
    • 3.4 测试为交换器发送消息
  • 4. 小结

1. Docker下安装RabbitMQ 1.1 查询RabbitMQ镜像

进Docker网站，查询RabbitMQ镜像，获取后缀带management的镜像，因为此种镜像带Web管理页面。

https://hub.docker.com/
1.2 获取镜像 
docker pull registry.docker-cn.com/library/rabbitmq:3-management

在这里插入图片描述

注意：这里一定要拉去后缀带management的镜像，这种镜像才带web管理页面

1.3 检查镜像 
docker images

在这里插入图片描述

1.4 运行镜像 
# 简单命令
docker run -d -p 5672:5672 -p 15672:15672 --name myrabbitmq 镜像id

# 带数据卷及开机自启动命令
docker run -d -p 5672:5672 -p 15672:15672 --name myrabbitmq -v /mydata/rabbitmq/data:/mydata/rabbitmq/data --restart always rabbitmq

在这里插入图片描述

1.5 查询镜像运行情况 
docker ps

在这里插入图片描述

1.6 验证客户端

打开浏览器，访问RabbitMQ的Web客户端并登陆，本机虚拟机地址为：http://192.168.1.106:15672/

默认用户名和密码为：guest

在这里插入图片描述

2. RabbitMQ管理页面 2.1 总体概览

Web管理页面如下图：

在这里插入图片描述

这里注意下Disk space红色部分！！！

Tab页共有六个选项卡

  • Overview：是 RabbitMQ概览情况，可以查看单个机器和集群中各个节点的情况，包括 RabbitMQ的端口映射信息等，都可以在这个选项卡中查看
  • Connections：可以查看连接上 RabbitMQ的生产者和消费者的情况
  • Channels：可以查看通道信息
  • Exchange：展示所有的交换机信息
  • Queue：展示所有队列信息
  • Admin：展示所有用户信息

页面默认是 5 秒刷新一次，展示的是所有的 Virtual host，右上角可调整

2.2 Overview

Overview中有如下功能

在这里插入图片描述

2.2.1 Totals

Totals里有准备消费的消息数、待确认的消息数、消息总数以及消息的各种处理速率（发送速率、确认速率、写入硬盘速率等等）

在这里插入图片描述

2.2.2 Nodes

Nodes展示 RabbitMQ运行的节点，点击每个节点，可以查看节点的详细信息

在这里插入图片描述

在这里插入图片描述

这里需要注意下红色部分的Disk space！！！

这个问题也很诡异，说明下具体情况：本人使用docker镜像安装的RabbitMQ，由于C盘空间快用满了，所以每次向RabbitMQ发送消息时，总是失败，后来定位问题，是由于这个磁盘原因。

正常情况应该是第二张图！！！

2.2.3 Churn statistics

展示的是 Connection、Channel以及 Queue的创建/关闭速率

在这里插入图片描述

2.2.4 Ports and contexts

在这里插入图片描述

这里展示端口映射以及 Web上下文信息

  • 5672是 RabbitMQ通信端口
  • 15672是 Web管理页面端口
  • 25672是集群通信端口
2.2.5 Export definitions / Import definitions

可以导入导出当前实例的一些配置信息

在这里插入图片描述

2.3 Connections

展示当前连接上 RabbitMQ信息，无论是消息生产者还是消息消费者，只要连接上来了这里都会显示出来

在这里插入图片描述

属性含义如下：

  • Name：连接地址，可点击进入查看具体信息，在详情中可以查看每一个连接的通道数以及其他详细信息，也可以强制关闭一个连接
  • User name：当前连接使用的用户名
  • State：当前连接的状态，running表示运行中；idle表示空闲；blocked表示阻塞
  • SSL/TLS：表示是否使用 ssl进行连接
  • AMQP 0-9-1：AMQP协议的版本号
  • Channels：当前连接创建的通道总数
  • From client：每秒发出的数据包
  • To client：每秒收到的数据包

State状态为blocked的原因就是Disk Space不足引起的

2.4 Channels

展示通道信息

在这里插入图片描述

2.4.1 通道

  • 一个连接可以有多个通道，这么多个通道通过多线程实现，一般情况下，我们在通道中创建队列、交换机等

  • 生产者的通道一般会立马关闭，消费者是一直监听的，通道几乎是会一直存在

各参数含义如下：

  • Channel：通道名称
  • User name：该通道登录使用的用户名
  • Model：通道确认模式，C表示 confirm；T表示事务Transaction
  • State：通道当前的状态，running表示运行中；idle表示空闲
  • Unconfirmed：待确认的消息总数
  • Prefetch：Prefetch表示每个消费者最大的能承受的未确认消息数目，简单来说就是用来指定一个消费者一次可以从 RabbitMQ中获取多少条消息并缓存在消费者中，一旦消费者的缓冲区满了，RabbitMQ将会停止投递新的消息到该消费者中直到它发出有消息被 ack了。总的来说，消费者负责不断处理消息，不断 ack，然后只要 unAcked数少于prefetch * consumer 数目，RabbitMQ就不断将消息投递过去
  • Unacked：待 ack的消息总数
  • publish：消息生产者发送消息的速率
  • confirm：消息生产者确认消息的速率
  • unroutable (drop)：表示未被接收，且已经删除了的消息
  • deliver/get：消息消费者获取消息的速率
  • ack：消息消费者 ack消息的速率
2.5 Exchange

展示交换机详细信息

在这里插入图片描述

各参数含义如下：

  • Type：表示交换机的类型

  • Features： 有两个取值 D和I

D 表示交换机持久化，将交换机的属性在服务器内部保存，当 MQ 的服务器发生意外或关闭之后，重启 RabbitMQ 时不需要重新手动或执行代码去建立交换机，交换机会自动建立，相当于一直存在

I 表示这个交换机不可以被消息生产者用来推送消息，仅用来进行交换机和交换机之间的绑定

  • Message rate in： 表示消息进入的速率

  • Message rate out： 表示消息出去的速率

下方的Add a new exchange 可以在Web页面上创建一个新的交换机

2.6 Queue

展示消息队列详细信息

在这里插入图片描述

各项属性含义如下：

  • Name：表示消息队列名称

  • Type：表示消息队列的类型，除了上图的 classic，另外还有一种消息类型是 Quorum

  • Features：表示消息队列的特性，D 表示消息队列持久化

  • State：表示当前队列的状态，running表示运行中；idle表示空闲

  • Ready：表示待消费的消息总数

  • Unacked：表示待应答的消息总数

  • Total：表示消息总数Ready+Unacked

  • incoming：表示消息进入的速率

  • deliver/get：表示获取消息的速率

  • ack：表示消息应答的速率

点击 Add a new queue可以添加一个新的消息队列

点击每一个消息队列的名称，可以进入到消息队列中。进入到消息队列后，可以完成对消息队列的进一步操作，例如：

  • 将消息队列和某一个交换机进行绑定
  • 发送消息
  • 获取一条消息
  • 移动一条消息（需要插件的支持）
  • 删除消息队列
  • 清空消息队列中的消息
  • …

具体操作如下图：

在这里插入图片描述

注意：队列要和交换机进行绑定，在代码实现过程中必须的步骤

2.7 Admin

在这里插入图片描述

各项属性含义如下：

  • Name：表示用户名称。
  • Tags：表示角色标签，只能选取一个
  • Can access virtual hosts：表示允许进入的虚拟主机
  • Has password：表示这个用户是否设置了密码

常用的两个操作时管理用户和虚拟主机

点击 Add a user 可以添加一个新的用户，添加用户的时候需要给用户设置 Tags，其实就是用户角色，如下：

  • none：不能访问management plugin
  • management：用户可以通过 AMQP做的任何事 列出自己可以通过 AMQP登入的 virtual hosts 查看自己的 virtual hosts 中的 queues, exchanges和 bindings查看和关闭自己的 channels和 connections查看有关自己的 virtual hosts 的“全局”的统计信息，包含其他用户在这些virtual hosts中的活动
  • policymaker：management可以做的任何事 查看、创建和删除自己的 virtual hosts 所属的 policies 和 parameters
  • monitoring：management可以做的任何事 列出所有 virtual hosts，包括他们不能登录的 virtual hosts 查看其他用户的 connections 和 channels 查看节点级别的数据如 clustering 和 memory 使用情况 查看真正的关于所有 virtual hosts 的全局的统计信息
  • administrator：policymaker 和 monitoring 可以做的任何事 创建和删除 virtual hosts 查看、创建和删除 users 查看创建和删除 permissions关闭其他用户的 connections
  • impersonator(模拟者) 模拟者，无法登录管理控制台。
3. 使用Web管理页面操作RabbitMQ 3.1 根据消息队列图，创建交换器

在这里插入图片描述

消息队列图：

在这里插入图片描述

添加三种交换器

在这里插入图片描述

创建完交换器效果图

在这里插入图片描述

3.2 添加消息队列

创建消息队列 在这里插入图片描述

创建完消息队列效果图

在这里插入图片描述

3.3 为交换器绑定消息队列

在这里插入图片描述

将交换器与消息队列绑定

在这里插入图片描述

绑定完后的效果图

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

3.4 测试为交换器发送消息

在exchange.direct交换器中，发送一个消息，路由键的名称为：scorpios

在这里插入图片描述

进入到消息队列中，查看消息队列接受到消息的情况

在这里插入图片描述

在上图中，点击有消息的消息队列，进入详情页，查看具体消息信息

在这里插入图片描述

在这里插入图片描述

4. 小结

上面只是RabbitMQ的入门使用，下面会结合SpringBoot来介绍RabbitMQ如何使用。

关注
打赏
1657848381
查看更多评论

最近更新

热门博客

[ 申请 ]友情链接：

ClashX教程 绘画宝宝 配音宝宝
立即登录/注册

微信扫码登录

0.0393s