SWOOLE开发实时聊天系统（五）Swoole核心文件配置

我们首先看一下swoole官网
上的文档。
将上面的websocket面向对象示例拷贝一下。

class WebsocketTest
{
    public $server;

    public function __construct()
    {
        $this->server = new Swoole\WebSocket\Server("0.0.0.0", 9501);
        $this->server->on('open', function (Swoole\WebSocket\Server $server, $request) {
            echo "server: handshake success with fd{$request->fd}\n";
        });
        $this->server->on('message', function (Swoole\WebSocket\Server $server, $frame) {
            echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
            $server->push($frame->fd, "this is server");
        });
        $this->server->on('close', function ($ser, $fd) {
            echo "client {$fd} closed\n";
        });
        $this->server->on('request', function ($request, $response) {
            // 接收http请求从get获取message参数的值，给用户推送
            // $this->server->connections 遍历所有websocket连接用户的fd，给所有用户推送
            foreach ($this->server->connections as $fd) {
                // 需要先判断是否是正确的websocket连接，否则有可能会push失败
                if ($this->server->isEstablished($fd)) {
                    $this->server->push($fd, $request->get['message']);
                }
            }
        });
        $this->server->start();
    }
}

new WebsocketTest();

可以看到在其生命周期中，执行了三个方法，分别是open、message和close.
在swoole开启之后，会监听服务器的9501端口
当一个请求进来时，会先执行onOpen方法，握手成功之后开始通过onMessage传输数据，当连接断开的时候再调用close方法去关闭连接。
因此我们要将ws类作为核心类，当有数据传输的时候，去调用app下的方法来完成操作，而不是在当前类中写出所有的逻辑代码。
所以，我们首先在app目录下新建一个MessageController的控制器，然后在其中设定两个方法，第一个是获取信息，第二个是关闭连接的操作。

<?php

namespace app\controllers;


class MessageController extends CommonController
{
    protected  $server;
    public function __construct(\swoole_websocket_server $server)
    {
        $this->server=$server;
    }

    /**
     * 获取消息，并按照实际情况去分发
     * @param $frame \swoole_websocket_frame
     */
    public function getMessage(\swoole_websocket_frame $frame)
    {
        var_dump(json_decode($frame->data,true));

    }
    //关闭连接
    public function closeFd($fd)
    {

    }

}

然后在web目录下新建一个websocket类，将onMessage和onClose的数据转发到MessageController中。

<?php
namespace websocket;
use Swoole;
use app\controllers\MessageController;
use swoole_websocket_server;

class websocket{

    private $server;
    private $MessageController;

    public function __construct() {
    }
    public function run(){
        //开启swoole
        $this->server = new Swoole\WebSocket\Server("0.0.0.0", 9501);

        $this->MessageController = new MessageController($this->server);

        $this->server->on('open', function (swoole_websocket_server $server, $request) {
            echo "server: handshake success with fd{$request->fd}\n";
        });


        $this->server->on('message', function (Swoole\WebSocket\Server $server, $frame) {
            $this->MessageController->getMessage($frame);
        });


        $this->server->on('close', function ($ser, $fd) {
            echo "server: close a fd  : fd{$fd}\n";
            $this->MessageController->closeFd($fd);
        });

        $this->server->start();
    }
}

现在我们就可以将数据发送到MessageController中了。
测试一下，首先启动swoole,

$ php web/index.php

通过netstat命令，我们可以看到当前的任务已经在运行了

$ netstat -dlnp|grep 9501
(Not all processes could be identified, non-owned process info
 will not be shown, you would have to be root to see it all.)
tcp        0      0 0.0.0.0:9501            0.0.0.0:*               LISTEN      13145/php           

在这里推荐一个很好用的websocket测试小工具：wstool
我们首先连接服务器127.0.0.1:9501，可以看到，连接成功的状态。
同时查看服务器，命令行输出内容如下：

server: handshake success with fd1

然后我们通过以下的json来进行测试：

{
"type":"login",
"user_id":"10086",
"first_topic":"1",
"second_topic":"1"
}

发现我们已经可以在服务器端的MessageController中打印出信息了。

string(76) "{
"type":"login",
"user_id":"10086",
"first_topic":"1",
"second_topic":"1"
}"