mosquitto服务器搭建
❶ 一台Ubuntu服务器是部署mosquitt和另一台Ubuntu服务器部署的EMQTT能做集群吗
在make之前编译mosquitto时把掘哗顷config.mk中芦尺的WITH_BRIDGE注释掉,把WITH_CLUSTER:=yes取消注释,然后make && make install安装mosquitto即可。判陆
❷ 在云服务器上搭建了mqtt,为什么手机连接不上mqtt,要怎么做才能连接上求求大神帮忙
MQTT协议是广泛应用的物联网协议,使用测试MQTT协议需要MQTT的代理。有两种方法使用MQTT服务,一是租用现成的MQTT服务器,如阿里云,网络云,华为云等公用的云平台提供的MQTT服务,使用公用的MQTT服务器的好处是省事,但如果仅仅用于测试学习还需要注册帐号,灵活性差些,有的平台还需要付费。另一方法是自己使用开源的MQTT组件来搭建。
MQTT服务器非常多,如apache的ActiveMQ,emtqqd,HiveMQ,Emitter,Mosquitto,Moquette等等。
这里介绍的是用轻量级的mosquitto开源项目来搭建一个属于自己的MQTT服务器。
第一步:需要安装一台linux主机,这不多介绍,可以使用真机安装也可以使用虚拟机安装。如果仅仅是自己测试使用都可以。
第二步:下载mosquitto需要的依赖
sudo apt-get install libssl-devsudo apt-get install uuid-devsudo apt-get install cmake
第三步:下载mosquitto并解压,现在mosquitto官网最新的版本是1.5.1
tar xzvf mosquitto-1.5.1.tar.gz
第四步:编译
cd mosquitto-1.5.1/
make
make install
第五步:启动mosquitto
./mosquitto -v
1535473957: mosquitto version 1.5.1 starting
1535473957: Using default config.
1535473957: Opening ipv4 listen socket on port 1883.
1535473957: Opening ipv6 listen socket on port 1883.
这时候mosquitto就会以默认的参数启动。如果需要带配置文件可以修改配置文件mosquitto.conf,
启动时候加上参数 -c,
./mosquitto -c mosquitto.conf
可以看到,mosquitto监听的端口为1883.
这时候我们的MQTT服务器就搭建好了。可找一个mqtt客户端来测试一下。
先发布一个主题“home/garden/fountain/2”
内容是“hello world”
这时候在mosquitto会打印出下面的log
535474247: New connection from 192.168.1.105 on port 1883.
1535474247: New client connected from 192.168.1.105 as MQTT_FX_Client (c1, k60).
1535474247: No will message specified.
1535474247: Sending CONNACK to MQTT_FX_Client (0, 0)
1535474307: Received PINGREQ from MQTT_FX_Client
1535474307: Sending PINGRESP to MQTT_FX_Client
1535474339: Received PUBLISH from MQTT_FX_Client (d0, q0, r0, m0, 'home/garden/fountain/2', ... (12 bytes))
1535474367: Received PINGREQ from MQTT_FX_Client
1535474367: Sending PINGRESP to MQTT_FX_Client
订阅主题“home/garden/fountain/2”
可以看到收到了自己发布的消息。
用wireshark抓包
可以看到抓到了一个MQTT的publish的报文。
❸ 如何设置mqtt服务器的账号密码
1、在这里下载Apollo服务器,下载后解压,然后运行apache-apollo-1.6\bin\apollo.cmd,输入create mybroker(名字任意取,这里是根据官网介绍的来取的)创建服务器实例,服务器实例包含了所有的配置,运行时数据等,并且和一个服务器进程关联。
2、create mybroker之后会在bin目录下生成mybroker文件夹,里面包含有很多信息,其中etc\apollo.xml文件下是配置服务器信息的文件,etc\users.properties文件包含连接MQTT服务器时用到的用户名和密码,后面会介绍,可以修改原始的admin=password,可以接着换行添加新的用户名密码。
3、打开cmd,运行…apache-apollo-1.6\bin\mybroker\bin\apollo-broker.cmd run 开启服务器,可以在浏览器中输入http://127.0.0.1:61680/查看是否安装成功,该界面展示了topic,连接数等很多信息。
经过上面的简单步骤,服务器基本上就已经完成,下一篇将介绍Android客户端的编写和注意事项。
客户端使用的API,开始我使用的是mqtt-client,使用过后发现问题百出,不能很好的满足要求,后来使用了官方推荐的Eclipse Paho
❹ 如何搭建android推送mptt服务器
近研究了一下Android推送,在网上搜到了很多种方式,觉得IBM的MQTT协议这种方式还是挺不错的。
下面介绍一下搭建过程:
需要准备的工具如下:
(1)、下载Mosquitto(MQTT的代理,也可以用IBM的ISMB)
http://mosquitto.org/download/
我下载的是mosquitto-1.1.2-install-win32.exe,根据自己的需要下载,不安装这个推送不了消息。
(2)、下载AndroidPushNotificationsDemo
https://github.com/toku/Androi ... /archive/master.zip
(3)、下载phpMQTTClient
https://github.com/toku/PhpMQTTClient/archive/master.zip
将PHPMQTTClient部署到PHP服务器上,运行,打开mosquitto安装目录的mosquitto.exe
❺ mqtt 服务器 哪个好 activemq rabbitmq mosquitto
1、 下载mosquitto安装文件()
2、 找到相应系统的安装文件安装,如果不想做任何设置直接在服务里启动就行。
3、配置文件
如果需要配置一些用户名、密码、用户权限的参数,则需要修改安装目录下的mosquitto.conf文件
下面来说说我用到的一些参数吧:
①用户密码: #password_file pwfile.example 后面跟着是用户密码配置文件,需写上绝对路径并且路径不带空格
②创建用户密码:打开doc窗口,进入mosquitto安装目录,运行mosquitto_passwd -c pwfile.example userName 回车,然后输入密码(密码输入两遍后,在该文件里会自动加密密码)
生成的文件内容格式例如:
userName:$6$Ls7JYQTdn9xagJJ2$/WArx/SAtFRKlvKKnHRCUg==
userName2:$6$bymgVcrtj+7wj8mR$+zmAxnOybqJvrBZboxX1XXPnz/TKZwz9aKQJ72zJym5A=
③如果想再增加用户,则执行mosquitto_passwd -u pwfile.example userName2即可
④用户权限:#acl_file aclfile.example 后面跟着是用户权限配置文件,需写上绝对路径并且路径
文件内容格式为:
user userName
/etc/ld.so.conf.d
mosquitto.conf
/usr/local/lib/python2.6/site-packages ( mosquitto.py )
/usr/local/bin
vi /etc/sysconfig/iptables
/usr/local/src/mosquitto-1.1.3/lib/python
make install
ldconfig
不改config.mk里面的东西
需要安装
yum -y install patch make gcc gcc-c++ gcc-g77 flex bison
centos5.6下 yum -y install gcc automake autoconf libtool make
yum -y install openssl openssl-devel vim-minimal
这里为只读
topic read 主题
user userName2
这里为可读可写
topic 主题
topic #(或+)表示可以读写任何主题
到这里用户密码及权限已配置完成,订阅和发布的时候加上用户名及密码即可验证:
例如:订阅
client = new MqttClient("tcp://127.0.0.1:1883","java_client0000000000");
// 回调处理类
Myback callback = new Myback();
client.setCallback(callback);
// 创建连接可选项信息
MqttConnectOptions conOptions = new MqttConnectOptions();
conOptions.setCleanSession(false);
conOptions.setUserName("userName");
conOptions.setPassword("pwd".toCharArray());
// 连接broker
client.connect(conOptions);
client.subscribe("主题");
}
发布:
MqttClient client = new MqttClient("tcp://127.0.0.1:1883","mqttserver-pub");
MqttTopic topic = client.getTopic("主题");
MqttMessage message = new MqttMessage(topic.getName().getBytes());
message.setQos(1);
MqttConnectOptions options = new MqttConnectOptions();
options.setUserName("userName");
options.setPassword("pwd".toCharArray());
client.connect(options);
topic.publish(message);
}
即可验证!
❻ php安装mqtt扩展【Mosquitto】
没有安装mosquitto的可以看一下链接先安装一下
MQTT服务器搭建-mosquitto1.4.4安装指南
然后我们来安装php扩展
如果你已经使用预先建立的软件包来安装Mosquitto,你需要确保你已经安装了开发头文件。在红帽派生的系统上,这可能是叫做libmosquitto-devel,在基于 Debian的系统上叫做libmosquitto-dev。
你可以使用pecl来来安装这个拓展包:
pecl install Mosquitto-alpha
1
或者,你也可以使用常规的安装拓展的方法来安装:
phpize
./configure --with-mosquitto=/path/to/libmosquitto
make
make install
1
2
3
4
然后添加extension=mosquitto.so到你的PHP配置文件php.ini中。
--with-mosquitto
1
是可选参数,只有当安装程序找不到libmosquitto拓展包,才需要添加这个参数
❼ 如何用mosquitto搭建服务器
Mosquitto是一款实现了消息推送协议MQTT v3.1的开源消息代理软件,提供轻量级的,支持可发布/可订阅的的消息推送模式,使设备对设备之间的短消息通信变得简单,比如现在应用广泛的低功耗传感器,手机、嵌入式计算机、微型控制器等移动设备。
Mosquitto官网:
MQTT协议:
客户端连接日志
1403334375: New connection from 121.201.8.163 on port 1883.
1403334375: New client connected from 121.201.8.163 as zhoujing (c0, k60, ujoyo).
1403334375: Sending CONNACK to zhoujing (0)
以上是一个客户端正常连接的日志。
第一行:服务器收到一个新的连接请求
1403334375: 表示连接的时间点
121.201.8.163: 客户端的IP地址
1883: 连接的服务器端口号
第二行:服务器为客户端建立连接
zhoujing (c0, k60, ujoyo): 客户端连接指定的ClientID为'zhoujing'
c0: 表示cleanSession=false,不清除session
k60: 表示keep-alive=60s
ujoyo: 表示使用的服务器账号为joyo
第三行:发送连接ACK包给客户端
客户端订阅过程日志
1403334375: Received SUBSCRIBE from zhoujing
1403334375: jiji/chat/9 (QoS 2)
1403334375: zhoujing 2 jiji/chat/9
1403334375: Sending SUBACK to zhoujing
第一行:服务器收到一个来自ClientID为zhoujing的订阅请求
第二行:服务器识别zhoujing订阅的主题为 jiji/chat/9,指定的QOS=2(有且只发送一次)
第三行:给ClientID=zhoujing客户端发送订阅ACK回包
服务器发送内容给客户端日志
1403334378: Sending PUBLISH to zhoujing (d0, q2, r0, m1, 'jiji/chat/9', ... (396 bytes))
1403334378: Received PUBREC from zhoujing (Mid: 1)
1403334378: Sending PUBREL to zhoujing (Mid: 1)
1403334378: Received PUBCOMP from zhoujing (Mid: 1)
第一行:服务器正在发送一个消息给ClientID=zhoujing的客户端,消息体大小为396 bytes,消息主题为‘jiji/chat/9’
(d0, q2, r0, m1)的解释, 以下参数具体含义,参考MQTT协议
d: 表示mqtt报头的DUP字段
q: 表示的QOS字段
r: 表示的是RETAIN
m: 表示的是消息ID,即mid
第二行:发布收稿阶段,有保证的交付第一部分
第三行:出版发行阶段,有保证的交付第二部分
第四行:发布完成,有保证的交付第三部分,至此一个内容发部过程完成
客户端主动断开连接的日志
客户端主动断开连接的只有一行日志,很简单。如下所示:
1403334380: Received DISCONNECT from JY_API_PUSH_CLIENT
接收客户端发布内容的过程日志
1403334389: Received PUBLISH from JY_API_PUSH_CLIENT (d0, q2, r0, m1, 'jiji/chat/9', ... (396 bytes))
1403334389: Sending PUBREC to JY_API_PUSH_CLIENT (Mid: 1)
1403334389: Received PUBREL from JY_API_PUSH_CLIENT (Mid: 1)
1403334389: Sending PUBCOMP to JY_API_PUSH_CLIENT (Mid: 1)
第一行:接收来自ClientID=JY_API_PUSH_CLIENT的发布请求,发布的消息主题为'jiji/chat/9',消息大小为396 bytes
第二行:服务器发送PUBREC给客户端,此过程与发送消息给客户端正好对称,只不过是Received和Sending的对象反过来而已
第三行:服务器接收到客户端已经释放的命令,内容交付第二步完成
第四行:通知客户端,接收完成,至此一个消息发布完成,内容交付第三步完成
同一个ClientID重复连接时
1403334510: New connection from 121.201.7.150 on port 1883.
1403334510: Client JY_API_PUSH_CLIENT already connected, closing old connection.
接收客户端心跳包
1403336716: Received PINGREQ from 36383A64663A6464003V0
1403336716: Sending PINGRESP to 36383A64663A6464003V0
客户端连接超时,服务器主动清除连接信息
1403336671: Client 33303A33393A3236003V0 has exceeded timeout, disconnecting.
客户端socket异常时的日志
1403337602: Socket error on client 351BBJKFX62C1, disconnecting.
1403337602: Socket error on client 351BBJKFX62C0, disconnecting.
❽ 如何在Ubuntu 16上搭建sock5代理服务器,如何实现用户名和密码的设置以防止被别人使用
1. 引入mosquitto仓库并更新
sudo apt-add-repository ppa:mosquitto-dev/mosquitto-ppa
sudo apt-get update
2. 执行以下命令安装mosquitto包
sudo apt-get install mosquitto
3. 安装mosquitto开发包
sudo apt-get install libmosquitto-dev
4. 安装mosquitto客户端
sudoapt-get install mosquitto-clients
5. 查询mosquitto是否正确运行
sudo service mosquitto status
6. 本机测试
打开一个终端,执行以下命令订阅主题"mqtt"
mosquitto_sub -h localhost -t "mqtt" -v
打开另外一个终端,发布消息到主题 “mqtt”
mosquitto_pub -h localhost -t "mqtt" -m "Hello MQTT"
❾ 三、NT35E标准MQTT
用户在使用CAT1模组MQTT协议对接自己的服务器,有时会遇到设备无法连接服务器问题(比如提示+ECMTCON:0,0,5连接服务器被拒绝,认证失败)。此时可以通过 标准的MQTT服务器 进行对比,因为用户自己的服务器一般加入校验信息,导致模组&MQTT服务器无法连接。
Eclipse Mosquitto是一个开源消息代理,实现了MQTT协议版本3.1和3.1.1,这里使用该服务器进行测试。针对该服务器更详细的介绍也可以参考 https://www.jianshu.com/p/b6a75bfbe82f 。
MQTT有个重要的参数QOS,因下面使用较多,这里列出便于后续查看:
AT+ECMTOPEN=<tcpconnectID>,“<host_name>”,<port>
<tcpconnectID> 整型。 MQTT Socket 标识符。范围: 0~4
<host_name> IP 地址或域名
<port> 整型。服务器端口
示例:AT+ECMTOPEN=0, "test.mosquitto.org",1883 //建立 tcp
返回值:+ECMTOPEN:<tcpconnectID>,<result>
<tcpconnectID> Integer type,MQTT socket identifier. The value is 0
<result> 1 Failed to open network,0 Opened network successfully
AT+ECMTCONN=<tcpconnectID>,“<clientID>”[,“<username>”[,“<password>”]]
<tcpconnectID> MQTT socket identifier. The value is 0
“<clientID>” 用户不指定标准服务器会自行创建
“<username>”,“<password>” 标准MQTT服务器不使用
示例:AT+ECMTCONN=0 //在 mosquitto 平台上注册设备
返回值:+ECMTCONN:<tcpconnectID>,<result>[,<ret_code>]
AT+ECMTSUB=<tcpconnectID>,<msgID>,“<topic>”,<qos>
<tcpconnectID> MQTT socket identifier. The value is 0
<msgID> 任意填写,Message identifier of packet. The range is 1-65535
<topic> String type,Topic that the client wants to subscribe to or unsubscribe from.
<qos> Message QoS, can be 0,1 or 2
示例:AT+ECMTSUB=0,1,”test”,2 //订阅 topic
返回值:+ECMTSUB:<tcpconnectID>,<msgID>,<result>[,<value>]
额外指令:AT+ECMTUNS=0,4, “test” //取消订阅 topic
AT+ECMTPUB=<tcpconnectID>,<msgID>,<qos>,<retain>,“<topic>”,“<payload>"
<tcpconnectID> MQTT socket identifier. The value is 0
<msgID> Message identifier of packet.
<qos> Message QoS, can be 0,1 or 2
<retain> 0 Server should not retain the message 1 Server should retain the message
<topic> String type
<payload> String type
示例:AT+ECMTPUB=0,0,0,0,"test","hello" //发送数据给 mosquitto 平台
+ECMTPUB:<tcpconnectID>,<msgID>,<result>[,<value>]
额外指令:AT+ECMTDISC=0 //删除 mqtt client 和 mqtt 连接
❿ 如何用python启动mosquitto mqtt服务器
配置文件路径 /etc/mosquitto/mosquitto.conf
启动服务进程mosquitto,除了可能用命令行参数,还要以通过配置文件,配置文件更为详细。
可以指定ip地址和端口,还可以使用用户名和密码!