phpMqttClient is an MQTT client library for PHP. Its based on the reactPHP socket-client and added the MQTT protocol specific functions. I hope its a better starting point that the existing PHP MQTT libraries.
Goal of this project is easy to use MQTT client for PHP in a modern architecture without using any php modules. Currently, only protocol version 4 (mqtt 3.1.1) is implemented.
- Protocol specifications: http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/csprd02/mqtt-v3.1.1-csprd02.html
$config = require 'config.php';
$connector = ClientFactory::createClient(new Version4());
$p = $connector->create($config['server'], $config['port'], $config['options']);
$p->then(function(Stream $stream) use ($connector) {
return $connector->publish($stream, 'a/b', 'example message');
});
$connector->getLoop()->run();$config = require 'config.php';
$connector = ClientFactory::createClient(new Version4());
$p = $connector->create($config['server'], $config['port'], $config['options']);
$p->then(function(\React\Stream\Stream $stream) use ($connector) {
$stream->on(Publish::EVENT, function(Publish $message) {
print_r($message);
});
$connector->subscribe($stream, 'a/b', 0);
$connector->subscribe($stream, 'a/c', 0);
});
$connector->getLoop()->run();This is library is not stable currently. Its an early state, but I am working on it. I will add more features if I need them. If you need features: please give feedback or contribute to get this library running.
Currently works:
- connect (clean session, no other connect flags)
- disconnect
- publish
- subscribe
./vendor/bin/phpunit -c ./tests/phpunit.xml ./tests
The answer is simple: In the example is the DNS 8.8.8.8 configured. Your local server is not visible for them, so you can't connect.
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent