Swoole MQTT (物联网) 服务器环境搭建（一）

上下博客 2021-08-21

2101

本文采用[Docker]方式来搭建，对于[Docker]的使用或者一些知识有另一篇文章（暂未写好）来介绍，这里仅说明如何使用[Docker]进行[MQTT]的搭建。

首先搜索一下[Swoole]的镜像

wonmodeair:~ wonmo$ docker search swoole
NAME                                     DESCRIPTION                                     STARS     OFFICIAL   AUTOMATED
phpswoole/swoole                         Official Docker image for PHP Swoole : https…   75                   
twosee/swoole-coroutine                  Perfect Swoole Dockerfile for senior develop…   44                   [OK]
twosee/swoole                            Perfect Swoole Dockerfile for senior develop…   14                   [OK]
kakuilan/swoole-docker                   php7 swoole docker                              2
复制

这里选取了第一个镜像，现在将镜像下载下来。

docker pull phpswoole/swoole
复制

下载过程就不贴了，主要是一些镜像层的下载合并。然后根据这个镜像启动一个容器。

docker run --rm -t -i --name swoole -p 9503:9503 -v Users/wonmo/Desktop/docker_volumes/swoole:/var/www phpswoole/swoole:latest bin/bash
复制

这里要映射一个本地目录到容器里，命令的话会专门写一篇[Docker]文章进行解释。像这样[Swoole]的环境就搭建好了，剩下的我们需要进行[MQTT]包的安装。

composer create-project simple-swoole/skeleton swoole
复制

在容器里运行上述命令就会在本地目录创建一个[Swoole]文件夹，里面包含了一个简单的[WebSocket]实现例子，这里由于需要进行[MQTT]的实现，所以需要增加一些代码。

在增加代码前我们先执行以下命令

composer require simps/mqtt
复制

打开本地目录下的[.../swoole/simps/config/servers.php]文件，增加如下代码。

use Simps\Server\Protocol\MQTT; #注意别忘了命名空间
'mqtt' => [
     'ip' => '0.0.0.0',
     'port' => 9503,
     'callbacks' => [
     ],
     'receiveCallbacks' => [
         MQTT::CONNECT => [\App\Events\MqttServer::class, 'onMqConnect'],
         MQTT::PINGREQ => [\App\Events\MqttServer::class, 'onMqPingreq'],
         MQTT::DISCONNECT => [\App\Events\MqttServer::class, 'onMqDisconnect'],
         MQTT::PUBLISH => [\App\Events\MqttServer::class, 'onMqPublish'],
         MQTT::SUBSCRIBE => [\App\Events\MqttServer::class, 'onMqSubscribe'],
         MQTT::UNSUBSCRIBE => [\App\Events\MqttServer::class, 'onMqUnsubscribe'],
     ],
     'settings' => [
         'worker_num' => 1,
         'open_mqtt_protocol' => true,
     ],
],
复制

然后在[Events]文件夹增加[MqttServer.php]文件。

<?php


declare(strict_types=1);
/**
 * This file is part of Simps.
 *
 * @link     https://simps.io
 * @document https://doc.simps.io
 * @license  https://github.com/simple-swoole/simps/blob/master/LICENSE
 */


namespace App\Events;


use Simps\Server\Protocol\MQTT;
use Simps\Server\Protocol\MqttInterface;


class MqttServer implements MqttInterface
{
    public function onMqConnect($server, int $fd, $fromId, $data)
{
        if ($data['protocol_name'] != "MQTT") {
            // 如果协议名不正确服务端可以断开客户端的连接，也可以按照某些其它规范继续处理CONNECT报文
            $server->close($fd);
            return false;
        }


        $server->send(
            $fd,
            MQTT::getAck(
                [
                    'cmd' => 2, // CONNACK固定值为2
                    'code' => 0, // 连接返回码 0表示连接已被服务端接受
                    'session_present' => 0
                ]
            )
        );
    }


    public function onMqPingreq($server, int $fd, $fromId, $data): bool{
        return true;
    }


    public function onMqDisconnect($server, int $fd, $fromId, $data): bool{
        return true;
    }


    public function onMqPublish($server, int $fd, $fromId, $data){
        var_dump($data); 
    }


    public function onMqSubscribe($server, int $fd, $fromId, $data){}


    public function onMqUnsubscribe($server, int $fd, $fromId, $data){}


}
复制

开启[Swoole]服务

php bin/simps.php mqtt:start
复制

root@3064ee6c19e8:/var/www/simps# php bin/simps.php mqtt:start
  ____    _                           
  ___|  (_)  _ __ ___    _ __    ___ 
 \___ \  | | | '_ ` _ \  | '_ \   __|
  ___) | | | | | | | | | | |_) | \__ \
 |____/  |_| |_| |_| |_| | .__/  |___/
                         |_|           Version: 1.0.5, Swoole: 4.7.1


[2021-08-21 13:32:17] [INFO] Swoole MQTT Server running：mqtt://0.0.0.0:9503
复制

开启成功以后可以使用[MQTT]相关的工具进行连接测试，这里我用了[MQTT.FX]。网上有推荐[MQTTBox]的，但是我没有找到下载地址，然后去[GitHub]上下载了一份源码，编译了一下。发现是个[Web App]不支持[MQTT]。

MQTT over TCP and TLS are supported by MQTTBox apps for Linux, MAC and Windows. Download MQTTBox app from http://workswithweb.com/mqttbox.html
复制

[MQTT.FX]还是比较简单的，进行配置以后发送个简单的文本。

root@3064ee6c19e8:/var/www/simps# php bin/simps.php mqtt:start
  ____    _                           
  ___|  (_)  _ __ ___    _ __    ___ 
 \___ \  | | | '_ ` _ \  | '_ \  / __|
  ___) | | | | | | | | | | |_) | \__ \
 |____/  |_| |_| |_| |_| | .__/  |___/
                         |_|           Version: 1.0.5, Swoole: 4.7.1


[2021-08-21 13:39:48] [INFO] Swoole MQTT Server running：mqtt://0.0.0.0:9503
array(6) {
  ["cmd"]=>
  int(3)
  ["topic"]=>
  string(12) "上下博客"
  ["content"]=>
  string(0) ""
  ["dup"]=>
  int(0)
  ["qos"]=>
  int(0)
  ["retain"]=>
  int(0)
}
复制

此篇文章仅仅只是搭建，如果需要知道[MQTT]详细的内容，请关注后续。

... 未完待续 ...

物联网

文章转载自上下博客，如果涉嫌侵权，请发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。

Swoole MQTT (物联网) 服务器环境搭建（一）

评论