其他分享
首页 > 其他分享> > MQTT——EMQX学习笔记01——EMQX安装使用

MQTT——EMQX学习笔记01——EMQX安装使用

作者：互联网

目录标题

一、MQTT协议介绍

（一）什么是MQTT

MQTT 是基于 Publish/Subscribe（发布/订阅） 模式的物联网通信协议，凭借简单易实现、支持 QoS、报文小等特点，占据了物联网协议的半壁江山。
简单来说：MQTT是一种通讯协议，不能直接使用，如果需要使用这个协议就需要使用实现了这种协议的组件，比如：EMQX 。

（二）MQTT角色组成

  1. 服务端（Broker）
    EMQX就是一个MQTT的Broker，此外还要其他的Broker如下：

    到目前为止，比较流行的 MQTT Broker 有几个：
    1. Eclipse Mosquitto: https://github.com/eclipse/mosquitto
    使用 C 语言实现的 MQTT Broker。Eclipse 组织还还包含了大量的 MQTT 客户端项目：https://www.eclipse.org/paho/#
    2. EMQX: https://github.com/emqx/emqx
    使用 Erlang 语言开发的 MQTT Broker，支持许多其他 IoT 协议比如 CoAP、LwM2M 等
    3. Mosca: https://github.com/mcollina/mosca
    使用 Node.JS 开发的 MQTT Broker，简单易用。
    4. VerneMQ: https://github.com/vernemq/vernemq
    同样使用 Erlang 开发的 MQTT Broker

  2. 客户端（消费者【订阅】、生产者【发布】）

    • EMQX 通过里面的websocket 可以实现消息的发布与订阅
    • 当然我们常常会通过java代码来实现我们消息的生产者和消费者
    MQTT与EMQX
    MQTT属于是物联网的通信协议，在MQTT协议中有两大角色：客户端（发布者/订阅者），服务端（Mqttbroker）；针对客户端和服务端需要有遵循该协议的的具体实现， EMQ/EMQ X就是MQTT Broker的一种实现。

注意：

在安装好EMQX代理服务器后，EMQX 不仅仅为我们提供了Mqtt broker，EMQX 的dashboard(一个EMQX的web界面)可以通过 websocket 这个功能实现消息的发布与订阅
EMQX 的dashboard如下：

在这里插入图片描述

（三）三种消息发布服务质量：QoS

MQTT有三种消息发布服务质量：

（四）消息的组成

MQTT传输的消息分为：主题（Topic）和负载（payload）两部分：
（1） Topic，可以理解为消息的类型，订阅者订阅（Subscribe）后，就会收到该主题的消息内容。
（2） payload，可以理解为消息的内容，是指订阅者具体要使用的内容。

（五） MQTT协议数据包结构

（1）固定头（Fixed header）。存在于所有MQTT数据包中，表示数据包类型及数据包的分组类标识，
如连接，发布，订阅，心跳等。其中固定头是必须的，所有类型的MQTT协议中，都必须包含固定头。
（2）可变头（Variable header）。存在于部分MQTT数据包中，数据包类型决定了可变头是否存在及其
具体内容。可变头部不是可选的意思，而是指这部分在有些协议类型中存在，在有些协议中不存在。
（3）消息体（Payload）。存在于部分MQTT数据包中，表示客户端收到的具体内容。 与可变头一样，
在有些协议类型中有消息内容，有些协议类型中没有消息内容。

二、安装EMQX

（一）安装单机版

官方下载地址：https://www.emqx.com/zh/downloads?product=broker
官方文档：https://docs.emqx.cn/enterprise/v4.3/

注意：产品部署建议 Linux 服务器，不推荐 Windows 服务器。我们这里使用docker 进行安装

如果你不知道怎么使用docker可以参考一下内容：
https://blog.csdn.net/a123123sdf/category_11081930.html

  1. 搜索镜像

    [root@iz2zedg4ylq9iqtwm11wecz ~]# docker search emqx
INDEX       NAME                                    DESCRIPTION                                     STARS     OFFICIAL   AUTOMATED
docker.io   docker.io/emqx/emqx                     An Open-Source, Cloud-Native, Massive-Scal...   126                  
docker.io   docker.io/emqx/emqx-ee                  EMQ X Enterprise - Cloud-Native IoT Messag...   8                    
docker.io   docker.io/emqx/emqx-edge                EMQ X Broker - Massively Scalable MQTT Mes...   2                    
docker.io   docker.io/emqx/kuiper                   A lightweight IoT edge analytics software ...   2                    
docker.io   docker.io/emqx/kuiper-manager                                                           2                    
docker.io   docker.io/emqx/edge-manager                                                             1                    
docker.io   docker.io/emqx/neuron                   Neuron - Industrial IoT Gateway Software f...   1                    
docker.io   docker.io/raymondmm/emqx                                                                1                    
docker.io   docker.io/alpine/emqx                   old versions of emqx (https://github.com/e...   0

  2. 拉取镜像

    [root@iz2zedg4ylq9iqtwm11wecz ~]# docker pull docker.io/emqx/emqx
Using default tag: latest
Trying to pull repository docker.io/emqx/emqx ... 
latest: Pulling from docker.io/emqx/emqx
e519532ddf75: Pull complete 
3b27d5f517c7: Pull complete 
f859fdd14890: Pull complete 
f547136f53b1: Pull complete 
3b98da427992: Pull complete 
580d982288df: Pull complete 
d9267f25196b: Pull complete 
Digest: sha256:0f5db8f114f051a89f1d9ec4364773be853508a08c305da9e2a89844ef967086

  3. 开发端口号
    注意：如果你使用的是阿里云的服务器，那么你需要开发阿里云的端口号和服务器本机的端口号
    1883、 8083、 8883 、 8084 、 18083

Broker TCP 端口: 1883
Broker SSL 端口: 8883
emqx dashboard 需要的端口号：18083
emqx 自带的客户端端口号：8083

在这里插入图片描述
在这里插入图片描述

  1. 运行镜像生产容器
# 先运行一个容器
[root@iz2zedg4ylq9iqtwm11wecz etc]# docker run  --name myemqx -p 1883:1883 -p 8083:8083 -p 8883:8883 -p 8084:8084 -p 18083:18083  -d dc9ce1aa4b05
a226549fa8d75b1673904e1389e74e2f810a80f987729625a0e0137f6048bc7c
# 进入容器
[root@iz2zedg4ylq9iqtwm11wecz etc]# docker exec -it myemqx /bin/bash
bash-5.0$ pwd
/opt/emqx
bash-5.0$ ls
bin          data         erts-11.1.8  etc          lib          log          releases
bash-5.0$ cd etc/
bash-5.0$ ls
acl.conf       certs          emqx.conf      lwm2m_xml      plugins        psk.txt        ssl_dist.conf  vm.args 
bash-5.0$ pwd
/opt/emqx/etc
bash-5.0$ exit
# 将需要挂载的配置文件复制到宿主主机中
[root@iz2zedg4ylq9iqtwm11wecz conf]# pwd
/my/emqx/conf
[root@iz2zedg4ylq9iqtwm11wecz conf]# docker cp myemqx:/opt/emqx/etc .
[root@iz2zedg4ylq9iqtwm11wecz conf]# cd etc
[root@iz2zedg4ylq9iqtwm11wecz etc]# ls
acl.conf  certs  emqx.conf  lwm2m_xml  plugins  psk.txt  ssl_dist.conf  vm.args
[root@iz2zedg4ylq9iqtwm11wecz etc]# pwd
/my/emqx/conf/etc
# 删除容器
[root@iz2zedg4ylq9iqtwm11wecz conf]# docker rm myemqx -f
myemqx
# 再新建一个容器
[root@iz2zedg4ylq9iqtwm11wecz conf]# docker run  --name myemqx -p 1883:1883 -p 8083:8083 -p 8883:8883 -p 8084:8084 -p 18083:18083 -v /my/emqx/conf/etc:/opt/emqx/etc -d dc9ce1aa4b05
cc4e2017defe03705a331d0b73197079329abdc51d697972da5c4003189b8010

注意：这里目录挂载的是整个文件夹，因此需要确保，宿主主机和容器的etc目录下文件的数量和名字保持一致，也就是文件结构需要一样吗，文件写的内容可以不一样。因此，我们需要先运行一个不需要挂载目录的容器，将容器中etc目录的内容通过docker cp 复制到宿主主机中。再删除容器，最后再docker run 一个新的容器

  1. 测试
    浏览器输入：http://39.96.52.225:18083/

默认登录账号密码为：默认用户名是 admin ，密码是 public 。
在这里插入图片描述

（二）集群

可以参照官方文档进行搭建集群：https://docs.emqx.cn/broker/v4.3/getting-started/cluster.html#%E8%8A%82%E7%82%B9%E5%8F%91%E7%8E%B0%E4%B8%8E%E8%87%AA%E5%8A%A8%E9%9B%86%E7%BE%A4

三、Websocket发布与订阅

使用EMQX的Websocket实现发布与订阅消息

  1. 连接Websocket
    在这里插入图片描述
    在这里插入图片描述

  2. 订阅消息
    在这里插入图片描述
    在这里插入图片描述

  3. 发布消息
    在这里插入图片描述
    在这里插入图片描述

  4. 通过EMQX Broker进行收发消息
    在这里插入图片描述

标签：01,conf,MQTT,io,emqx,EMQX,docker
来源： https://blog.csdn.net/a123123sdf/article/details/120902585