init

Author: ovim

.gitignore

@@ -0,0 +1,2 @@
+.idea
+.vscode

composer.json

@@ -0,0 +1,5 @@
+{
+    "require": {
+        "bluerhinos/phpmqtt": "@dev"
+    }
+}

composer.lock

@@ -0,0 +1,89 @@
+<?php
+/**
+ * @Descripttion:
+ * @Author: ovim <[email protected]>
+ * @Date: 2021/9/24 3:10 下午
+ */
+
+error_reporting(E_ALL);
+
+require_once 'vendor/autoload.php';
+
+function d($data) {
+    echo "<pre>";
+    var_dump($data);
+}
+
+function echoDie($data) {
+    print_r($data);
+    die;
+}
+
+class Test {
+
+    /**
+     * @var string
+     */
+    protected $cliendId;
+
+    /**
+     * @var null
+     */
+    protected $broker;
+
+    public function __construct($cliendId)
+    {
+        $this->cliendId = $cliendId;
+
+        $this->connect();
+    }
+
+    private function connect() {
+        list($address, $port, $clientId, $username, $password) = [
+            'ip for server',
+            'port',
+            $this->cliendId,
+            'username',
+            'password'
+        ];
+
+        $broker = new Bluerhinos\phpMQTT($address, $port, $clientId);
+        $connectResult = $broker->connect(true, null, $username, $password);
+        if (!$connectResult) echoDie('EMQ 服务端连接失败');
+        $this->broker = $broker;
+    }
+
+    /**
+     * publish message
+     *
+     * @param $topic
+     * @param $content
+     * @param int $qos
+     * @param bool $retain
+     */
+    public function pub($topic, $content, $qos = 0, $retain = true)
+    {
+        $result = $this->broker->publish($topic, $content, $qos, $retain);
+        d($result);
+    }
+
+    /**
+     * subscribe message
+     *
+     * @param $topic
+     * @param int $qos
+     */
+    public function sub($topic, $qos = 0)
+    {
+        $result = $this->broker->subscribeAndWaitForMessage($topic, $qos);
+        // $result = $this->broker->subscribe($topic, $qos);
+        // 这个地方如果获取到脏数据 如何处理【 订阅之前，向此主题发送一个空的消息，清空保留消息 】
+        d($result);
+    }
+
+}
+
+$clientId = mt_rand();
+$topic = 'test';
+(new Test($clientId))->pub($topic, 'ovimTest1');
+(new Test($clientId))->sub($topic);

index.php

@@ -0,0 +1,3 @@
+EMQ X 的 PHP SDK 使用DEMO
+
+[查看 EMQ 的官方文档](https://docs.emqx.cn/broker/v4.3/)

readme.md

@@ -0,0 +1,7 @@
+<?php
+
+// autoload.php @generated by Composer
+
+require_once __DIR__ . '/composer/autoload_real.php';
+
+return ComposerAutoloaderInit155a8ed16bd5ee7ecef74e126f5bf068::getLoader();

vendor/autoload.php

@@ -0,0 +1,2 @@
+/vendor/
+.idea

vendor/bluerhinos/phpmqtt/.gitignore

@@ -0,0 +1,20 @@
+Copyright (c) 2010 Blue Rhinos Consulting | Andrew Milsted
+[email protected] | http://www.bluerhinos.co.uk
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.

vendor/bluerhinos/phpmqtt/LICENSE

@@ -0,0 +1,15 @@
+**2020 Update**
+I am restarting the project so watch this space
+
+
+Blue Rhinos Consulting
+Andrew Milsted | [email protected] | http://www.bluerhinos.co.uk | @bluerhinos
+
+A simple php class to connect/publish/subscribe to an MQTT broker
+
+Documentation: Coming Soon
+Source: http://github.com/bluerhinos/phpMQTT
+
+To install via Composer
+-----------------------
+`composer require bluerhinos/phpmqtt=@dev`

vendor/bluerhinos/phpmqtt/README.md

@@ -0,0 +1,21 @@
+{
+    "name": "bluerhinos/phpmqtt",
+    "description": "Simple MQTT Class",
+    "license": "BSD",
+    "type": "library",
+    "authors": [
+        {
+            "name": "Andrew Milsted",
+            "email": "[email protected]"
+        }
+    ],
+    "minimum-stability": "dev",
+    "require": {
+        "php": ">=7.2"
+    },
+    "autoload": {
+        "psr-4": {
+            "Bluerhinos\\": "./"
+        }
+    }
+}

vendor/bluerhinos/phpmqtt/composer.json

@@ -0,0 +1,44 @@
+# Output example
+
+For info on MQTT: https://mntolia.com/fundamentals-mqtt/#4_Advantages_of_MQTT_for_IoT_over_HTTP_UDP
+
+> Before running each file be sure to review the four connection parameters in the headers.
+
+subscribe.php
+--
+This example is to demonstrate using MQTT for a long-running script that will wait for subscribed topics.
+This script is not suitable to be run as web requests, instead should be run on the commandline.
+
+Let `subscribe.php` listening the broker: 
+```console
+$ php subscribe.php 
+Msg Recieved: Fri, 13 Jan 2017 01:58:23 +0000
+Topic: bluerhinos/phpMQTT/examples/publishtest
+
+	Hello World! at Fri, 13 Jan 2017 01:58:23 +0000
+
+Msg Recieved: Fri, 13 Jan 2017 01:58:35 +0000
+Topic: bluerhinos/phpMQTT/examples/publishtest
+
+	Hello World! at Fri, 13 Jan 2017 01:58:35 +0000
+
+^C
+```
+
+publish.php
+---
+This example will publish a message to a topic.
+
+The results shown above corresponds to publisher's two actions:
+```console
+$ php publish.php
+$ php publish.php
+```
+
+When run as a web request you it is ok to just `$mqtt->connect()`, `$mqtt->publish()` and `$mqtt->close()`.
+If it is being run as long-running command line script you should run `$mqtt->proc()` regularly in order maintain the connection with the broker.
+ 
+subscribeAndWaitForMessage.php
+--
+In order to use this library to display messages on a website you can use `$mqtt->subscribeAndWaitForMessage()`, this will subscribe to a topic and then wait for, and return the message.
+If you want messages to appear instantly, you should use retained messages (https://mntolia.com/mqtt-retained-messages-explained-example/)  

vendor/bluerhinos/phpmqtt/examples/README.md

@@ -0,0 +1,18 @@
+<?php
+
+require('../phpMQTT.php');
+
+$server = 'localhost';     // change if necessary
+$port = 1883;                     // change if necessary
+$username = '';                   // set your username
+$password = '';                   // set your password
+$client_id = 'phpMQTT-publisher'; // make sure this is unique for connecting to sever - you could use uniqid()
+
+$mqtt = new Bluerhinos\phpMQTT($server, $port, $client_id);
+
+if ($mqtt->connect(true, NULL, $username, $password)) {
+	$mqtt->publish('bluerhinos/phpMQTT/examples/publishtest', 'Hello World! at ' . date('r'), 0, false);
+	$mqtt->close();
+} else {
+    echo "Time out!\n";
+}

vendor/bluerhinos/phpmqtt/examples/publish.php

@@ -0,0 +1,32 @@
+<?php
+
+require('../phpMQTT.php');
+
+
+$server = 'localhost';     // change if necessary
+$port = 1883;                     // change if necessary
+$username = '';                   // set your username
+$password = '';                   // set your password
+$client_id = 'phpMQTT-subscriber'; // make sure this is unique for connecting to sever - you could use uniqid()
+
+$mqtt = new Bluerhinos\phpMQTT($server, $port, $client_id);
+if(!$mqtt->connect(true, NULL, $username, $password)) {
+	exit(1);
+}
+
+$mqtt->debug = true;
+
+$topics['bluerhinos/phpMQTT/examples/publishtest'] = array('qos' => 0, 'function' => 'procMsg');
+$mqtt->subscribe($topics, 0);
+
+while($mqtt->proc()) {
+
+}
+
+$mqtt->close();
+
+function procMsg($topic, $msg){
+		echo 'Msg Recieved: ' . date('r') . "\n";
+		echo "Topic: {$topic}\n\n";
+		echo "\t$msg\n\n";
+}

vendor/bluerhinos/phpmqtt/examples/subscribe.php

@@ -0,0 +1,18 @@
+<?php
+
+require('../phpMQTT.php');
+
+$server = 'localhost';     // change if necessary
+$port = 1883;                     // change if necessary
+$username = '';                   // set your username
+$password = '';                   // set your password
+$client_id = 'phpMQTT-subscribe-msg'; // make sure this is unique for connecting to sever - you could use uniqid()
+
+$mqtt = new Bluerhinos\phpMQTT($server, $port, $client_id);
+if(!$mqtt->connect(true, NULL, $username, $password)) {
+	exit(1);
+}
+
+echo $mqtt->subscribeAndWaitForMessage('bluerhinos/phpMQTT/examples/publishtest', 0);
+
+$mqtt->close();