Public
/
MQTT-Laravel
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Compare commits

base: Public:master
Branches Tags
Public:master
Public:development
Public:1.0.4
Public:v1.0.3
Public:v1.0.2
Public:v1.0.1
Public:v1.0.0
..
compare: Public:v1.0.0
Branches Tags
Public:master
Public:development
Public:1.0.4
Public:v1.0.3
Public:v1.0.2
Public:v1.0.1
Public:v1.0.0

No commits in common. "master" and "v1.0.0" have entirely different histories.
master ... v1.0.0

5 changed files with 34 additions and 72 deletions
Show Stats Expand all files Collapse all files

22
Readme.md
View File

@ -1,11 +1,9 @@
# Laravel MQTT Package
A simple Laravel 5 and 6 Library to connect/publish/subscribe to MQTT broker
A simple Laravel 5 Library to connect/publish to MQTT broker
Based on [bluerhinos/phpMQTT](https://github.com/bluerhinos/phpMQTT)
For Example see this [repo](https://github.com/salmanzafar949/Laravel-Mqtt-Example)
## Installation
```
composer require salmanzafar/laravel-mqtt
@ -15,12 +13,8 @@ composer require salmanzafar/laravel-mqtt
* Name and Password Authentication
* Certificate Protection for end to end encryption
* Enable Debug mode to make it easier for debugging
* Now you can also set Client_id of your choice and if you don't want just simply don't use or set it to null
* Set QOS flag directly from config file
* Set Retain flag directly from config file
## Enable the package (Optional)
This package implements Laravel auto-discovery feature. After you install it the package provider and facade are added automatically for laravel >= 5.5.
__This step is only required if you are using laravel version <5.5__
@ -53,8 +47,6 @@ php artisan vendor:publish --provider="Salman\Mqtt\MqttServiceProvider"
'certfile' => env('mqtt_cert_file',''),
'port' => env('mqtt_port','1883'),
'debug' => env('mqtt_debug',false) //Optional Parameter to enable debugging set it to True
'qos' => env('mqtt_qos', 0), // set quality of service here
'retain' => env('mqtt_retain', 0) // it should be 0 or 1 Whether the message should be retained.- Retain Flag
```
#### Publishing topic
@ -64,8 +56,7 @@ use Salman\Mqtt\MqttClass\Mqtt;
public function SendMsgViaMqtt($topic, $message)
{
$mqtt = new Mqtt();
$client_id = Auth::user()->id;
$output = $mqtt->ConnectAndPublish($topic, $message, $client_id);
$output = $mqtt->ConnectAndPublish($topic, $message);
if ($output === true)
{
@ -82,9 +73,7 @@ use Mqtt;
public function SendMsgViaMqtt($topic, $message)
{
$client_id = Auth::user()->id;
$output = Mqtt::ConnectAndPublish($topic, $message, $client_id);
$output = Mqtt::ConnectAndPublish($topic, $message);
if ($output === true)
{
@ -103,12 +92,11 @@ use Salman\Mqtt\MqttClass\Mqtt;
public function SubscribetoTopic($topic)
{
$mqtt = new Mqtt();
$client_id = Auth::user()->id;
$mqtt->ConnectAndSubscribe($topic, function($topic, $msg){
echo "Msg Received: \n";
echo "Topic: {$topic}\n\n";
echo "\t$msg\n\n";
}, $client_id);
});
}
@ -124,7 +112,7 @@ public function SubscribetoTopic($topic)
echo "Msg Received: \n";
echo "Topic: {$topic}\n\n";
echo "\t$msg\n\n";
},$client_id);
});
}

4
composer.json
View File

@ -1,6 +1,6 @@
{
"name": "salmanzafar-chenc/laravel-mqtt",
"description": "A simple Laravel 5 and 6 Library to connect/publish/subscribe to MQTT broker",
"name": "salmanzafar/laravel-mqtt",
"description": "A simple Laravel 5 Library to connect/publish to MQTT broker",
"type": "library",
"license": "MIT",
"authors": [

20
src/MqttClass/Mqtt.php
View File

@ -40,8 +40,6 @@ class Mqtt
protected $password = null;
protected $port = null;
protected $debug = null;
protected $qos = 0;
protected $retain = 0;
public function __construct()
{
@ -51,21 +49,17 @@ class Mqtt
$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');
}
public function ConnectAndPublish($topic, $msg, $client_id=null)
public function ConnectAndPublish($topic, $msg)
{
$id = empty($client_id) ? rand(0,999) : $client_id;
$client = new MqttService($this->host,$this->port, $id, $this->cert_file, $this->debug);
$client = new MqttService($this->host,$this->port, rand(0,100), $this->cert_file, $this->debug);
if ($client->connect(true, null, $this->username, $this->password))
{
$client->publish($topic,$msg, $this->qos, $this->retain);
$client->publish($topic,$msg);
$client->close();
return true;
@ -75,17 +69,15 @@ class Mqtt
}
public function ConnectAndSubscribe($topic, $proc, $client_id=null)
public function ConnectAndSubscribe($topic, $proc)
{
$id = empty($client_id) ? rand(0,999) : $client_id;
$client = new MqttService($this->host,$this->port,$id, $this->cert_file, $this->debug);
$client = new MqttService($this->host,$this->port, rand(0,100), $this->cert_file, $this->debug);
if ($client->connect(true, null, $this->username, $this->password))
{
$topics[$topic] = array("qos" => 0, "function" => $proc);
$client->subscribe($topics, $this->qos);
$client->subscribe($topics, 0);
while($client->proc())
{

52
src/MqttClass/MqttService.php
View File

@ -9,22 +9,21 @@
namespace Salman\Mqtt\MqttClass;
/*
A simple php class to connect/publish/Subscribe to an MQTT broker
A simple php class to connect/publish to an MQTT broker
*/
/* phpMQTT */
class MqttService
{
private $socket; /* holds the socket */
private $msgid = 1; /* counter for message id */
public $keepalive = 10; /* default keepalive timer */
public $timesinceping; /* host unix time, used to detect disconnects */
public $keepalive = 10; /* default keepalive timmer */
public $timesinceping; /* host unix time, used to detect disconects */
public $topics = array(); /* used to store currently subscribed topics */
public $debug = false; /* should output debug messages */
public $address; /* broker address */
public $port; /* broker port */
public $clientid; /* client id sent to broker */
public $clientid; /* client id sent to brocker */
public $will; /* stores the will of the client */
private $username; /* stores username */
private $password; /* stores password */
@ -34,7 +33,6 @@ class MqttService
$this->debug = $debug;
$this->broker($address, $port, $clientid, $cafile);
}
/* sets the broker details */
function broker($address, $port, $clientid, $cafile = NULL){
$this->address = $address;
@ -42,14 +40,12 @@ class MqttService
$this->clientid = $clientid;
$this->cafile = $cafile;
}
function connect_auto($clean = true, $will = NULL, $username = NULL, $password = NULL){
while($this->connect($clean, $will, $username, $password)==false){
sleep(10);
}
return true;
}
/* connects to the broker
inputs: $clean: should the client send a clean session flag */
function connect($clean = true, $will = NULL, $username = NULL, $password = NULL){
@ -107,22 +103,21 @@ class MqttService
if($this->username) $buffer .= $this->strwritestring($this->username,$i);
if($this->password) $buffer .= $this->strwritestring($this->password,$i);
$head = " ";
$head[0] = chr(0x10);
$head[1] = chr($i);
$head{0} = chr(0x10);
$head{1} = chr($i);
fwrite($this->socket, $head, 2);
fwrite($this->socket, $buffer);
$string = $this->read(4);
if(ord($string[0])>>4 == 2 && $string[3] == chr(0)){
if(ord($string{0})>>4 == 2 && $string{3} == chr(0)){
if($this->debug) echo "Connected to Broker\n";
}else{
error_log(sprintf("Connection failed! (Error: 0x%02x 0x%02x)\n",
ord($string[0]),ord($string[3])));
ord($string{0}),ord($string{3})));
return false;
}
$this->timesinceping = time();
return true;
}
/* read: reads in so many bytes */
function read($int = 8192, $nb = false){
// print_r(socket_get_status($this->socket));
@ -145,7 +140,6 @@ class MqttService
return $string;
}
/* subscribe: subscribes to topics */
function subscribe($topics, $qos = 0){
$i = 0;
@ -171,7 +165,6 @@ class MqttService
$bytes = ord(substr($string,1,1));
$string = $this->read($bytes);
}
/* ping: sends a keep alive ping */
function ping(){
$head = " ";
@ -180,21 +173,18 @@ class MqttService
fwrite($this->socket, $head, 2);
if($this->debug) echo "ping sent\n";
}
/* disconnect: sends a proper disconnect cmd */
/* disconnect: sends a proper disconect cmd */
function disconnect(){
$head = " ";
$head[0] = chr(0xe0);
$head[1] = chr(0x00);
$head{0} = chr(0xe0);
$head{1} = chr(0x00);
fwrite($this->socket, $head, 2);
}
/* close: sends a proper disconect, then closes the socket */
function close(){
$this->disconnect();
stream_socket_shutdown($this->socket, STREAM_SHUT_WR);
}
/* publish: publishes $content on a $topic */
function publish($topic, $content, $qos = 0, $retain = 0){
$i = 0;
@ -212,15 +202,14 @@ class MqttService
$cmd = 0x30;
if($qos) $cmd += $qos << 1;
if($retain) $cmd += 1;
$head[0] = chr($cmd);
$head{0} = chr($cmd);
$head .= $this->setmsglength($i);
fwrite($this->socket, $head, strlen($head));
fwrite($this->socket, $buffer, $i);
}
/* message: processes a received topic */
/* message: processes a recieved topic */
function message($msg){
$tlen = (ord($msg[0])<<8) + ord($msg[1]);
$tlen = (ord($msg{0})<<8) + ord($msg{1});
$topic = substr($msg,2,$tlen);
$msg = substr($msg,($tlen+2));
$found = 0;
@ -238,8 +227,7 @@ class MqttService
}
if($this->debug && !$found) echo "msg recieved but no match in subscriptions\n";
}
/* proc: the processing loop for an "always on" client
/* proc: the processing loop for an "allways on" client
set true when you are doing other stuff in the loop good for watching something else at the same time */
function proc( $loop = true){
if(1){
@ -303,20 +291,18 @@ class MqttService
}
return 1;
}
/* getmsglength: */
function getmsglength(&$msg, &$i){
$multiplier = 1;
$value = 0 ;
do{
$digit = ord($msg[$i]);
$digit = ord($msg{$i});
$value += ($digit & 127) * $multiplier;
$multiplier *= 128;
$i++;
}while (($digit & 128) != 0);
return $value;
}
/* setmsglength: */
function setmsglength($len){
$string = "";
@ -330,7 +316,6 @@ class MqttService
}while ( $len > 0 );
return $string;
}
/* strwritestring: writes a string to a buffer */
function strwritestring($str, &$i){
$ret = " ";
@ -343,13 +328,12 @@ class MqttService
$i += ($len+2);
return $ret;
}
function printstr($string){
$strlen = strlen($string);
for($j=0;$j<$strlen;$j++){
$num = ord($string[$j]);
$num = ord($string{$j});
if($num > 31)
$chr = $string[$j]; else $chr = " ";
$chr = $string{$j}; else $chr = " ";
printf("%4d: %08b : 0x%02x : %s \n",$j,$num,$num,$chr);
}
}

4
src/config/mqtt.php
View File

@ -13,7 +13,5 @@ return [
'username' => env('mqtt_username',''),
'certfile' => env('mqtt_cert_file',''),
'port' => env('mqtt_port','1883'),
'debug' => env('mqtt_debug',false), //Optional Parameter to enable debugging set it to True
'qos' => env('mqtt_qos', 0), // set quality of service here
'retain' => env('mqtt_retain', 0) // it should be 0 or 1 Whether the message should be retained.- Retain Flag
'debug' => env('mqtt_debug',false) //Optional Parameter to enable debugging set it to True
];