Easyswoole-Mqtt
原生使用说明
- 创建 tcp 服务
- 设置
swoole_server配置中open_mqtt_protocol配置为true - 加入以下代码
use EasySwoole\Mqtt\Protocol\MqttServerEvent;
/** @var \swoole_server $swooleSwoole */
$mqttServerEvent = MqttServerEvent::getInstance($swooleSwoole);Easyswoole 使用
可在主服务创建事件中加入
会自动配置服务 open_mqtt_protocol 为 true
public static function mainServerCreate(EventRegister $register)
{
$server = ServerManager::getInstance()->getSwooleServer();
$mqttServer = MqttServerEvent::getInstance($server);
}新端口开启
单独端口开启TCP服务器，需要添加子服务。
public static function mainServerCreate(EventRegister $register)
{
$server = ServerManager::getInstance()->getSwooleServer();
$newServer = $server->addlistener('0.0.0.0', 9502, SWOOLE_TCP);
if($newServer === false) {
$errorCode = $newServer->getLastError(); //https://wiki.swoole.com/wiki/page/554.html
} else {
$mqttServer = MqttServerEvent::getInstance($newServer);
}
}事件注册
/**
* 消息类型对应不同的事件
* @var array
*/
private $on = [
'connectToServer' => ConnectToServerEvent::class,
'confirmConnectionRequest' => '',
'partyMessage' => '',
'releaseConfirmation' => '',
'releaseReceiv' => '',
'releaseRelease' => '',
'releaseToComplete' => '',
'subscribeToTopic' => '',
'subscriptionConfirmation' => '',
'cancelSubscription' => '',
'cancelSubscriptionConfirmation' => '',
'heartRateRequest' => '',
'heartRateResponse' => '',
'disconnect' => '',
];Mqtt 有不同事件,你可以在协议处理过程插入自定义处理事件.
详细的处理事件需要继承并重写响应的抽象方法 vendor/easyswoole/mqtt/src/Protocol/Inherit/Event
默认使用自带的抽象事件实现.
推荐在重写方法后在服务注册后通过 on() 方法更改事件
$mqttServer->on('connectToServer', EasySwoole\Mqtt\Protocol\Event\DefaultEvent\ConnectToServerEvent::class);缓存驱动
实现 vendor/easyswoole/mqtt/src/Protocol/Face/Cache.php 接口
默认使用自提供驱动
$mqttServerEvent->setCacheDrive(EasySwoole\Mqtt\Protocol\CacheDrive\RedisDrive::class);