一个基于 swoole 的异步 mqtt 客户端库，可用于接收或者发送 mqtt 协议的消息

张汉庆发布于2019-07-01 11:05 / 3240人阅读

摘要：支持和版本安装命令行运行启动命令行运行启动实现的接口地址地址码云地址

一个基于 swoole 的异步 mqtt 客户端库，可用于接收或者发送 mqtt 协议的消息。支持 QoS 0、QoS 1、QoS 2。支持 MQTT 3.1 和 3.1.1 版本.

安装

composer require try-to/swoole_mqtt

Example

subscribe.php

 false,
    "client_id" => "demo-subscribe-123456",
    "username" => "",
    "password" => "",
];

$mqtt = new Client("127.0.0.1", 1883, $options);

$mqtt->onConnect = function ($mqtt) {
    $mqtt->subscribe("/World");
};

$mqtt->onMessage = function ($topic, $content) {
    var_dump($topic, $content);
};

$mqtt->onError = function ($exception) use ($mqtt) {
    echo "error
";
    // $mqtt->reconnect(1000);
};

$mqtt->onClose = function () {
    echo "close
";
};

$mqtt->connect();

命令行运行 php subscribe.php 启动

publish.php

 false,
    "client_id" => "demo-publish-123456",
    "username" => "",
    "password" => "",
];

$mqtt = new Client("127.0.0.1", 1883, $options);

$mqtt->onConnect = function ($mqtt) {
    $mqtt->publish("/World", "hello swoole mqtt");
};

$mqtt->onError = function ($exception) {
    echo "error
";
};

$mqtt->onClose = function () {
    echo "close
";
};

$mqtt->connect();

命令行运行 php publish.php 启动

实现的接口

Client::__construct()

Client::connect()

Client::reconnect()

Client::publish()

Client::subscribe()

Client::unsubscribe()

Client::disconnect()

Client::close()

callback onConnect

callback onMessage

callback onError

callback onClose

地址

github地址
码云地址

专线服务私有云 mqtt协议 mqtt协议详解阿里云mqtt协议 mqtt消息类型

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/29817.html

基于MQTT的物联网云测量解决方案

摘要：本文是其中的一个解决方案。地址客户端服务端前端网页介绍，消息队列遥测传输是开发的一个即时通讯协议，有可能成为物联网的重要组成部分。必须用于在顶层分隔符之后，除了当自己指定时。 1. 问题描述最近，本实验室大量上马云测量，云监控方面的项目，大概是属于物联网应用的一个分支。老板也有将旧有仪器改造的想法，所以要实现仪器设备的云控制。本文是其中的一个解决方案。 2. 技术选型消息队列：M...

张金宝 2019-06-28 10:57 评论0 收藏0
MQTT

摘要：协议版本介绍互联网的基础网络协议是协议消息队列遥测传输是基于协议栈而构建的已成为通信的标准为什么选择有多好多好多么牛逼我就不说了说的再多不如一个一个试试完了做比对剩下的那个就是要选择的实在不想这样搞技术就跟着一线走发布和订阅模型协议在网络中 mqtt 协议版本: 3.1.1 MQTT 介绍互联网的基础网络协议是 TCP/IP协议. MQTT(消息队列遥测传输)是基于 TCP/IP 协...

lastSeries 2019-08-16 13:47 评论0 收藏0
搭建IM服务 so easy

摘要：现在很多网站都通过服务来实现消息推送及数据即时同步功能，即时通讯组件逐渐成为产品的标配。目前国内有很多成熟稳定的第三方即时通讯服务厂家，比如融云。现在很多网站、APP都通过IM服务来实现消息推送及数据即时同步功能，即时通讯组件逐渐成为产品的标配。目前国内有很多成熟稳定的第三方即时通讯服务厂家，比如：融云。使用这些专业的服务可以提高开发效率而且服务稳定有保障。如果自己DIY或者需要在...

imccl 2019-08-14 15:25 评论0 收藏0
MQTT协议介绍

摘要：协议简介，消息队列遥测传输是一个轻量的发布订阅模式消息传输协议，是专门针对低带宽和不稳定网络环境的物联网应用设计的。它是等级协议交换的第二个报文。 1.MQTT协议简介 MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是一个轻量的发布/订...

lewinlee 2021-09-24 09:47 评论0 收藏0
MQTT如何快速助你产品化

摘要：时间就是金钱，效率就是生命本教程助力开发者使用协议快速产品化。摘要借助具备及联网功能的，快速部署到客户产品上，助力开发，缩短开发周期，快速实现产品商业化。时间就是金钱，效率就是生命本教程助力开发者使用MQTT协议快速产品化。摘要借助具备MQTT及联网功能的DTU，快速部署到客户产品...

sutaking 2021-10-08 10:04 评论0 收藏0