mqtt服务器搭建php,MQTT服务端

* @param BinSoulNetMqttPacketConnectRequestPacket $request* @param ImiServerMQTTMessageReceiveData $receiveData* @return BinSoulNetMqttPacketConnectResponsePacket|null*/public function connect(ConnectRequestPacket $request, ReceiveData $receiveData): ?ConnectResponsePacket{$success = 'root' === $request->getUsername() && '123456' === $request->getPassword();$response = new ConnectResponsePacket;if($success){$response->setReturnCode(0);}else{$response->setReturnCode(4);}return $response;}/*** 断开连接** @param BinSoulNetMqttPacketDisconnectRequestPacket $request* @param ImiServerMQTTMessageReceiveData $receiveData* @return void*/public function disconnect(DisconnectRequestPacket $request, ReceiveData $receiveData): void{}/*** Ping** @param BinSoulNetMqttPacketPingRequestPacket $request* @param ImiServerMQTTMessageReceiveData $receiveData* @return BinSoulNetMqttPacketPingResponsePacket|null

*/public function ping(PingRequestPacket $request, ReceiveData $receiveData): ?PingResponsePacket{return new PingResponsePacket;}/*** 发布** @param BinSoulNetMqttPacketPublishRequestPacket $request* @param ImiServerMQTTMessageReceiveData $receiveData* @returnBinSoulNetMqttPacketPublishAckPacket|BinSoulNetMqttPacketPublishReceivedPacket|BinSoulNetMqttPacketPublis*/public function publish(PublishRequestPacket $request, ReceiveData $receiveData){switch($request->getTopic()){case 'a':$response = new PublishAckPacket;break;case 'b':$response = new PublishReceivedPacket;break;case 'c':$response = new PublishReleasePacket;break;case 'd':$response = new PublishCompletePacket;break;}$response->setIdentifier($request->getIdentifier());return $response;}/**

* 订阅** @param BinSoulNetMqttPacketSubscribeRequestPacket $request* @param ImiServerMQTTMessageReceiveData $receiveData* @return BinSoulNetMqttPacketSubscribeResponsePacket|null*/public function subscribe(SubscribeRequestPacket $request, ReceiveData $receiveData): ?SubscribeResponsePacket{$response = new SubscribeResponsePacket;$response->setIdentifier($request->getIdentifier());$response->setReturnCodes([0]);return $response;}/*** 取消订阅** @param BinSoulNetMqttPacketUnsubscribeRequestPacket $request* @param ImiServerMQTTMessageReceiveData $receiveData* @return BinSoulNetMqttPacketUnsubscribeResponsePacket|null*/public function unsubscribe(UnsubscribeRequestPacket $request, ReceiveData $receiveData): ?UnsubscribeResponsePacket{$response = new UnsubscribeResponsePacket;$response->setIdentifier($request->getIdentifier());return $response;}}