swoole_mqtt
swoole_mqtt copied to clipboard
一个基于swoole的异步mqtt 客户端库,可用于接收或者发送mqtt协议的消息。支持QoS 0、QoS 1、QoS 2。支持MQTT 3.1和3.1.1版本。 参考workerman-mqtt
  

publish方法只能接收onConnect内部的参数,无法从外部获取参数,有什么解决办法么? $mqtt = new Client('127.0.0.1', 1883, $options); $mqtt->onConnect = function ($mqtt) { $mqtt->publish('/World', ); };
100线程并发,publish会丢失7%左右,有什么解决办法么