支持MQTT3.1和3.1.1版本。安装composer需要try-to/swoole_mqttExamplesubscribe.phpfalse,'client_id'=>'demo-subscribe-123456','username'=>'','password'=>'',];$mqtt=newClient('127.0.0.1',1883,$options);$mqtt->onConnect=function($mqtt){$mqtt->subscribe('/World');};$mqtt->onMessage=function($topic,$content){var_dump($topic,$content);};$mqtt->onError=function($exception)使用($mqtt){echo"error\n";//$mqtt->reconnect(1000);};$mqtt->onClose=function(){echo"close\n";};$mqtt->connect();命令运行phpsubscribe.php启动发布。phpfalse,'client_id'=>'demo-publish-123456','username'=>'','password'=>'',];$mqtt=新客户端('127.0.0.1',1883,$options);$mqtt->onConnect=function($mqtt){$mqtt->publish('/World','helloswoolemqtt');};$mqtt->onError=函数($exception){echo"error\n";};$mqtt->onClose=function(){echo"close\n";};$mqtt->connect();命令行运行phppublish.php开始实现InterfaceofClient::__construct()Client::connect()Client::reconnect()Client::publish()Client::subscribe()Client::unsubscribe()Client::disconnect()Client::close()回调onConnect回调onMessage回调onError回调onClose地址github地址码云地址
