最新动态 > 详情

php mosquitto(mqtt)的安装、配置、测试完整流程

发布时间:2019-10-15 09:54:00

第一步:没有安装mosquitto的可以看一下链接先安装一下
MQTT服务器搭建-mosquitto1.4.4安装指南

MQTT学习——Centos7上安装Mosquitto和使用
前言
MQTT是IBM开发的一个即时通讯协议。MQTT是面向M2M和物联网的连接协议,采用轻量级发布和订阅消息传输机制。Mosquitto是一款实现了 MQTT v3.1 协议的开源消息代理软件,提供轻量级的,支持发布/订阅的的消息推送模式,使设备对设备之间的短消息通信简单易用。
若初次接触MQTT协议,可先理解以下概念:

【MQTT协议特点】——相比于RESTful架构的物联网系统,MQTT协议借助消息推送功能,可以更好地实现远程控制。
【MQTT协议角色】——在RESTful架构的物联网系统,包含两个角色客户端和服务器端,而在MQTT协议中包括发布者,代理器(服务器)和订阅者。
【MQTT协议消息】——MQTT中的消息可理解为发布者和订阅者交换的内容(负载),这些消息包含具体的内容,可以被订阅者使用。
【MQTT协议主题】——MQTT中的主题可理解为相同类型或相似类型的消息集合。

安装和使用
1 安装
截止2017年12月,最新版本为mosquitto-1.4.14

# 下载源代码包
wget http://mosquitto.org/files/source/mosquitto-1.4.14.tar.gz
# 解压
tar zxfv mosquitto-1.4.14.tar.gz
# 进入目录
cd mosquitto-1.4.14
# 编译
make
# 安装
sudo make instal

2 问题
【1】编译过程找不到ares.h

sudo yum install c-ares-devel
1
【2】编译过程中找不到libwebsockets.h

sudo yum -y install libwebsockets-devel.x86_64
1
【3】使用过程中找不到libmosquitto.so.1
error while loading shared libraries: libmosquitto.so.1: cannot open shared object file: No such file or directory
【解决方法】——修改libmosquitto.so位置
创建链接

sudo ln -s /usr/local/lib/libmosquitto.so.1 /usr/lib/libmosquitto.so.1
1
更新动态链接库

sudo ldconfig
1
简单测试
一个完整的MQTT示例包括一个代理器,一个发布者和一个订阅者。测试分为以下几个步骤:
【1】启动服务mosquitto。
【2】订阅者通过mosquitto_sub订阅指定主题的消息。
【3】发布者通过mosquitto_pub发布指定主题的消息。
【4】代理服务器把该主题的消息推送到订阅者
【测试说明】
测试环境:Centos 7
在本例中,发布者、代理和订阅者均为localhsot,但是在实际的情况下三种并不是同一个设备,在mosquitto中可通过-h(–host)设置主机名称(hostname)。为了实现这个简单的测试案例,需要在linux中打开三个控制台,分别代表代理服务器、发布者和订阅者。


1 启动代理服务
在第一个终端中输入如下命令:

mosquitto -v
1
【-v】打印更多的调试信息

2 订阅主题
在第二个终端中输入如下命令:

mosquitto_sub -v -t sensor
1
【-t】指定主题,此处为sensor
【-v】打印更多的调试信息

3 发布内容
在第三个终端中输入如下命令:

mosquitto_pub -t sensor  -m 12
1
【-t】指定主题
【-m】指定消息内容

4 运行结果
当发布者推送消息之后,订阅者(也就是第二个终端)获得以下内容:

sensor 12
1
而代理服务器控制台(也就是第一个终端)中会出现——连接、消息发布和心跳等调试信息。通过代理服务器的调试输出可以对MQTT协议的相关过程有所了解。


总结
通过Mosquitto实现MQTT协议代理器(服务器),为今后的MQTT协议应用做准备。本文并没有分析MQTT协议的种种细节,但是希望通过一个简单的例子把MQTT协议“使用起来”,通过使用过程来理解MQTT协议,在过程中关注细节收集疑问,再阅读MQTT协议具体内容。
1
参考:
http://blog.csdn.net/jiesa/article/details/50635222

有 0 个人打赏
文章最后发布于: 2017-12-18 13:53:06

原文链接:https://blog.csdn.net/xj178926426/article/details/78832296


第二步:
然后我们来安装php扩展
如果你已经使用预先建立的软件包来安装Mosquitto,你需要确保你已经安装了开发头文件。在红帽派生的系统上,这可能是叫做libmosquitto-devel,在基于 Debian的系统上叫做libmosquitto-dev。

你可以使用pecl来来安装这个拓展包:

pecl install Mosquitto-alpha(可能下载成功了,但是无法安装)
所以通过查看到下载文件位置找到安装包,如(/tmp/pear/download)

解压下载的文件,进入文件目录

然后使用常规的安装拓展的方法来安装:

phpize
./configure --with-php-config=/usr/local/php/bin/php-config(这里一般在实际php安装目录下)
make
make install

然后添加extension=mosquitto.so到你的PHP配置文件php.ini中。重要!!!

--with-mosquitto 

是可选参数,只有当安装程序找不到libmosquitto拓展包,才需要添加这个参数

原文链接:https://blog.csdn.net/black_little_/article/details/88556193

第三步:
php写发布和订阅
发布代码:
<?php
 
$client = new Mosquitto\Client();
$client->connect(MQTT_IP, MQTT_PORT, 5);//MQTT_IP是mqtt服务器ip  MQTT_PORT一般是1883
$client->loop();
$client->publish($topic, $message, 1, 0);
$client->disconnect();//断开链接
unset($client);


 订阅代码(也可以通过配置时的方式监听订阅信息):
<?php
 
$client = new Mosquitto\Client();
$client->onMessage('message');    //回调函数 
$client->connect(IP, 1883, 5);
$client->subscribe('订阅主题', 1);
$payload='';
 
$client->loop();
$client->publish('发布主题', "发布信息", 1, 0);
$nowtime=time();
 
while(true){
        $client->loop();
        global $payload;
        if(!empty($payload)){
            
                echo $payload;  //订阅到的消息
                break;
        }
       if($nowtime==(time()-2)){
        break;
    }
}
 
$client->unsubscribe('订阅主题');//取消订阅
$client->disconnect();//断开链接
unset($client);
 
 
function message($message) {
//printf("Got a message ID %d on topic %s with payload:\n%s\n\n", $message->mid, $message->topic, $message->payload);
global $payload;
$payload=$message->payload;
 

上一篇: Jmeter下载安装及基本使用

下一篇:phpstorm完整破解方法