一個基于 swoole 的異步 mqtt 客戶端庫，可用于接收或者發(fā)送 mqtt 協(xié)議的消息

張漢慶發(fā)布于2019-07-01 11:05 / 3519人閱讀

摘要：支持和版本安裝命令行運行啟動命令行運行啟動實現(xiàn)的接口地址地址碼云地址

一個基于 swoole 的異步 mqtt 客戶端庫，可用于接收或者發(fā)送 mqtt 協(xié)議的消息。支持 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 啟動

實現(xiàn)的接口

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地址
碼云地址

云服務(wù)器 GPU云服務(wù)器 mqtt協(xié)議 mqtt協(xié)議詳解阿里云mqtt協(xié)議 mqtt消息類型

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/29817.html

相關(guān)文章

基于MQTT的物聯(lián)網(wǎng)云測量解決方案

摘要：本文是其中的一個解決方案。地址客戶端服務(wù)端前端網(wǎng)頁介紹，消息隊列遙測傳輸是開發(fā)的一個即時通訊協(xié)議，有可能成為物聯(lián)網(wǎng)的重要組成部分。必須用于在頂層分隔符之后，除了當自己指定時。 1. 問題描述最近，本實驗室大量上馬云測量，云監(jiān)控方面的項目，大概是屬于物聯(lián)網(wǎng)應用的一個分支。老板也有將舊有儀器改造的想法，所以要實現(xiàn)儀器設(shè)備的云控制。本文是其中的一個解決方案。 2. 技術(shù)選型消息隊列：M...

張金寶 2019-06-28 10:57 評論0 收藏0
MQTT

摘要：協(xié)議版本介紹互聯(lián)網(wǎng)的基礎(chǔ)網(wǎng)絡(luò)協(xié)議是協(xié)議消息隊列遙測傳輸是基于協(xié)議棧而構(gòu)建的已成為通信的標準為什么選擇有多好多好多么牛逼我就不說了說的再多不如一個一個試試完了做比對剩下的那個就是要選擇的實在不想這樣搞技術(shù)就跟著一線走發(fā)布和訂閱模型協(xié)議在網(wǎng)絡(luò)中 mqtt 協(xié)議版本: 3.1.1 MQTT 介紹互聯(lián)網(wǎng)的基礎(chǔ)網(wǎng)絡(luò)協(xié)議是 TCP/IP協(xié)議. MQTT(消息隊列遙測傳輸)是基于 TCP/IP 協(xié)...

lastSeries 2019-08-16 13:47 評論0 收藏0
搭建IM服務(wù) so easy

摘要：現(xiàn)在很多網(wǎng)站都通過服務(wù)來實現(xiàn)消息推送及數(shù)據(jù)即時同步功能，即時通訊組件逐漸成為產(chǎn)品的標配。目前國內(nèi)有很多成熟穩(wěn)定的第三方即時通訊服務(wù)廠家，比如融云。現(xiàn)在很多網(wǎng)站、APP都通過IM服務(wù)來實現(xiàn)消息推送及數(shù)據(jù)即時同步功能，即時通訊組件逐漸成為產(chǎn)品的標配。目前國內(nèi)有很多成熟穩(wěn)定的第三方即時通訊服務(wù)廠家，比如：融云。使用這些專業(yè)的服務(wù)可以提高開發(fā)效率而且服務(wù)穩(wěn)定有保障。如果自己DIY或者需要在...

imccl 2019-08-14 15:25 評論0 收藏0
MQTT協(xié)議介紹

摘要：協(xié)議簡介，消息隊列遙測傳輸是一個輕量的發(fā)布訂閱模式消息傳輸協(xié)議，是專門針對低帶寬和不穩(wěn)定網(wǎng)絡(luò)環(huán)境的物聯(lián)網(wǎng)應用設(shè)計的。它是等級協(xié)議交換的第二個報文。 1.MQTT協(xié)議簡介 MQTT（Message Queuing Telemetry Transport，消息隊列遙測傳輸）是一個輕量的發(fā)布/訂...

lewinlee 2021-09-24 09:47 評論0 收藏0
MQTT如何快速助你產(chǎn)品化

摘要：時間就是金錢，效率就是生命本教程助力開發(fā)者使用協(xié)議快速產(chǎn)品化。摘要借助具備及聯(lián)網(wǎng)功能的，快速部署到客戶產(chǎn)品上，助力開發(fā)，縮短開發(fā)周期，快速實現(xiàn)產(chǎn)品商業(yè)化。時間就是金錢，效率就是生命本教程助力開發(fā)者使用MQTT協(xié)議快速產(chǎn)品化。摘要借助具備MQTT及聯(lián)網(wǎng)功能的DTU，快速部署到客戶產(chǎn)品...

sutaking 2021-10-08 10:04 評論0 收藏0