EMP 实现消息发布订阅

深碍√TFBOYSˉ_ 2022-05-04 15:28 176阅读 0赞

### 官网文档 ###

[http://emqtt.com/docs/v2/index.html][http_emqtt.com_docs_v2_index.html]

### php 实现消息发布 ###

*  使用第三方包`bluerhinos/phpmqtt`

$mqtt = new phpMQTT("localhost", 1883, "clientId");
    //Change ClientId to something unique,此处必须唯一，一个客户端对应一个id
    if ($mqtt->connect()) { 
        for($i = 0; $i < 20; $i++) { 
           sleep(1);
    // $mqtt->publish('/Worldd','Hello new '.$i.'laravel!',0);
           $mqtt->publish("World","Hello laravel! at ".date("r"),0);
       }
       $mqtt->close();
    }

### 消息订阅 ###

*  php实现

<?php
    require dirname(__DIR__) . "/vendor/autoload.php";
    use Bluerhinos\phpMQTT;
    
    $server = "localhost";    // change if necessary
    $port = 1883;                     // change if necessary
    $username = "";                   // set your username
    $password = "";                   // set your password
    $client_id = "phh-subscriber"; // make sure this is unique for connecting to sever - you could use uniqid()
    $micro_time = round(microtime(true) * 1000);
    $client_id = $client_id . $micro_time;
    
    $mqtt = new phpMQTT($server, $port, $client_id);
    
    if (!$mqtt->connect(true, NULL, $username, $password)) { 
        exit(1);
    }
    
    function procmsg($topic, $msg)
    { 
        echo "Msg Recieved: " . date("r") . "\n";
        echo "Topic: { $topic}\n\n";
        echo "\t$msg\n\n";
    }
    
    $topics['World'] = array("qos" => 0, "function" => "procmsg");
    $mqtt->subscribe($topics, 0);
    
    while ($mqtt->proc()) { 
    
    }
    
    $mqtt->close();

*  js websocket 订阅消息

### 端口监听 ###

![在这里插入图片描述][70]

[http_emqtt.com_docs_v2_index.html]: http://emqtt.com/docs/v2/index.html
[70]: /images/20220504/b67e3ef086e240609ca0de4de4032dff.png