first commit

Author: jzzoo

LICENSE.md

@@ -0,0 +1,8 @@
+#laravel-mqtt
+
+A simple Laravel MQTT client provides Publish/Subscribe methods.
+
+Source code is mainly based on [phpMQTT](https://github.com/bluerhinos/phpMQTT)
+
+Once the configuration is complete, it is ready to use.
+

composer.json

@@ -0,0 +1,35 @@
+{
+    "name": "jzzoo/laravel-mqttx",
+    "description": "mqtt client",
+    "type": "library",
+    "license": "MIT",
+    "authors": [
+        {
+            "name": "jzzoo",
+            "email": "[email protected]"
+        }
+    ],
+    "require": {
+        "php": ">=7.0"
+    },
+    "require-dev": {
+        "laravel/framework": ">=5.8"
+    },
+    "minimum-stability": "dev",
+    "prefer-stable": true,
+    "autoload": {
+        "psr-4": {
+            "Jzzoo\\Laravel\\Mqttx\\": "src/"
+        }
+    },
+    "extra": {
+        "laravel": {
+            "providers": [
+                "Jzzoo\\Laravel\\Mqttx\\MqttxProvider"
+            ],
+            "aliases": {
+                "Mqtt": "Jzzoo\\Laravel\\Mqttx\\Facades\\Mqttx"
+            }
+        }
+    }
+}

config/mqttx.php

@@ -0,0 +1,12 @@
+<?php
+
+return [
+    'host'     => env('mqtt_host','127.0.0.1'),
+    'password' => env('mqtt_password',''),
+    'username' => env('mqtt_username',''),
+    'certfile' => env('mqtt_cert_file',''),
+    'port'     => env('mqtt_port','1883'),
+    'debug'    => env('mqtt_debug',false),
+    'qos'      => env('mqtt_qos', 0),
+    'retain'   => env('mqtt_retain', 0)
+];

src/Facades/Mqttx.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Jzzoo\Laravel\Mqttx;
+
+use Illuminate\Support\Facades\Facade;
+
+class Mqttx extends Facade
+{
+    protected static function getFacadeAccessor()
+    {
+        return 'Mqttx';
+    }
+}

src/Mqttx.php

@@ -0,0 +1,68 @@
+<?php
+
+namespace Jzzoo\Laravel\Mqttx;
+
+class Mqttx
+{
+    public function __construct() {
+        $this->host      = config('mqtt.host');
+        $this->username  = config('mqtt.username');
+        $this->password  = config('mqtt.password');
+        $this->cert_file = config('mqtt.certfile');
+        $this->port      = config('mqtt.port');
+        $this->debug     = config('mqtt.debug');
+        $this->qos       = config('mqtt.qos');
+        $this->retain    = config('mqtt.retain');
+    }
+
+    /**
+     * 发布消息
+     *
+     * @param $topic
+     * @param $msg
+     * @param null $client_id
+     * @return bool
+     */
+    public function Publish($topic, $msg, $client_id = null) {
+
+        empty($client_id) && $client_id = rand(10000, 99999);
+
+        $mqtt = new MqttxNear($this->host,$this->port, $client_id, $this->cert_file, $this->debug);
+
+        if ( $mqtt->connect(true, null, $this->username, $this->password) )  {
+            $mqtt->publish($topic, $msg, $this->qos, $this->retain);
+            $mqtt->close();
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * 订阅消息
+     *
+     * @param $topic
+     * @param $function
+     * @param null $client_id
+     * @return bool
+     */
+    public function Subscribe($topic, $function, $client_id = null) {
+
+        empty($client_id) && $client_id = mt_rand(10000, 99999);
+
+        $mqtt = new MqttxNear($this->host,$this->port, $client_id);
+        if( $mqtt->connect(true, null, $this->username, $this->password) ) {
+
+            $topics[$topic] = [ 'qos' => 0, 'function' => $function ];
+            $mqtt->subscribe($topics, 0);
+
+            do {
+                $rs = $mqtt->proc();
+            } while($rs);
+
+            $mqtt->close();
+            return true;
+        }
+        return false;
+    }
+}