我们首先看一下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"
}"
