WebSocket协议 与 IO多路复用

最近在把 Facebook Message 接入客服系统，因为与 Facebook Message 对接的收发消息都是经过调用 http 接口来实现的，若是想实现即时通信，还须要在中间加一个 WebSocket 来转发消息。以下图：

其中用到了 WebSocket 协议和 IO多路复用相关的知识。在这里作一个学习记录。

为何须要 WebSocket 协议

• 由于 HTTP 协议有一个缺陷：通讯只能先由客户端发起，而后服务器再做出响应，并不能由服务器主动向客户端推送消息。
• WebSocket 协议最大的特色是，服务器能够主动向客户端推送信息，客户端也能够主动向服务器发送信息。

WebSocket 与 socket 的之间关系

• WebSocket 是一个网络通讯协议，是属于网络七层模型中的应用层的协议，一样属于应用层的协议还有 HTTP 协议、FTP协议、SMTP协议等等。
• 而 socket 是操做系统提供的一套接口，利用这一套接口就能够编写程序实现进程之间的通讯、网络通讯等功能。

一个 WebSocket 链接是如何创建起来的

WebSocket 链接的初期是基于 HTTP 协议的，假如 WebSocket 的地址是这个：wss://www.xxx.com/websocket ，在链接 WebSocket 的初期浏览器首先会向这个地址发出一个 HTTP GET 请求，请求头信息截图以下：

红色框标出的是比较重要的请求头：

• Connection: Upgrade 告诉服务端这个链接须要升级。
• Upgrade: websocket 告诉服务端须要升级到 WebSocket 协议。
• Sec-WebSocket-Key: d97OXZzuRlSJV/6SrX+uUA== 是浏览器随机生成的一个字符串。

服务端接收到这个 HTTP 请求，会做出响应，响应头的截图以下：

红色框标出的是比较重要的响应头：

• HTTP/1.1 101 Switching Protocols 告诉浏览器，服务端已经成功切换了协议。
• Sec-WebSocket-Accept: axMY+KY1i8F9y9zyUMPhrfuYtPw= 这个是服务端拿到请求头中的 Sec-WebSocket-Key: d97OXZzuRlSJV/6SrX+uUA==，在 d97OXZzuRlSJV/6SrX+uUA== 后面拼接一个固定的字符串 258EAFA5-E914-47DA-95CA-C5AB0DC85B11 ，对拼接后的字符串作SHA1，获得16进制表示的字符串，将每两位看成一个字节进行分隔，获得字节数组，再对这个字节数组作Base64，获得最后的结果，把最后的结果放到 Sec-WebSocket-Accept 响应头里返回。

浏览器也会使用一样的算法把请求头中的 Sec-WebSocket-Key 算出一个结果，将这个结果与服务端返回的 Sec-WebSocket-Accept 作对比。就像对暗号同样，两边的暗号相同，WebSocket 链接就会被创建起来。这个过程也叫作握手，握手成功后，就能够愉快的使用这个 WebSocket 链接来收发消息了。

操做系统提供的 socket 接口

WebSocket 的通讯，实际上是利用了操做系统给咱们提供的一套 socket 编程接口。接下来，我把 Linux 系统中给咱们提供的 socket 头文件找出来，看看里面有哪些接口提供给咱们使用，以及每一个接口的做用是什么。找到 socket.h 头文件在以下位置：

打开 socket.h 文件：

打开另外一个目录下的 socket.h 文件：

socket 编程的流程以下：

在 socket 服务端除了用到上面流程图列出来的函数，还用到了 setsockopt() 函数，这个函数能够用来设置一些 socket 选项。好比：我在开发调试的过程当中，改完代码后须要杀掉运行中的 socket 进程，从新运行新编译出来的 socket。这时候常常会运行失败，缘由是进程是立马被杀掉了，可是原来被进程监听的那个端口会进入 TIME_WAIT 状态，而不会当即被释放出来。解决方法有两个：一、杀掉进程后等一下子，端口被释放了就能被再次使用了。二、在绑定端口以前，利用 setsockopt() 函数，给端口设置一个 SO_REUSEPORT 选项，这样杀掉这个进程后立马从新运行这个进程，也不会运行失败。

IO 多路复用(IO Multiplexing)

在项目中还用到了IO 多路复用：

• 什么是 IO ？答：计算机的输入和输出(Input、Output)
• 什么是 IO 多路复用？答：网上看到一个例子比较有意思。假如一个班有 50 名学生，老师在黑板上布置了一道题目让学生作，
  若是老师按照学号先看 1 号学生作出来没有，作出来了就检查他，还没作出来就在原地等他作出来，而后检查他，检查完 1 号学生才轮到 2 号学生......这个就是单进程/单线程。
  若是老师能分身，一共分出 50 个分身，每一个学生旁边站一个老师......这就是多进程/多线程。
  若是老师站在讲台上，有哪位学生作完了就举手，老师下去检查他，检查完老师又回到讲台上，看有哪位同窗举手，而后去检查他......这就是 IO 多路复用。

IO 多路复用有3 种：select、poll、epoll。在项目中用到的是 epoll。接下来，我把 Linux 系统中给咱们提供的 epoll 头文件找出来，看看里面有哪些接口提供给咱们使用，以及每一个接口的做用是什么。找到 epoll.h 头文件在以下位置：

打开 epoll.h 文件：

epoll 的使用流程以下：

看到网上有文章说 redis 和 nginx 也有使用 epoll，为了验证他讲的是否是真的。咱们找 redis 和 nginx 的源码看一看：

果真 redis 和 nginx 的源码里面都有使用 epoll。

WebSocket 编程，还有其余方案

Swoole 扩展：

• 须要 php-7.1 或更高版本
• 用法以下：

//建立WebSocket Server对象，监听0.0.0.0:9502端口
$ws = new Swoole\WebSocket\Server('0.0.0.0', 9502);

//监听WebSocket链接打开事件
$ws->on('open', function ($ws, $request) {
    var_dump($request->fd, $request->server);
    $ws->push($request->fd, "hello, welcome\n");
});

//监听WebSocket消息事件
$ws->on('message', function ($ws, $frame) {
    echo "Message: {$frame->data}\n";
    $ws->push($frame->fd, "server: {$frame->data}");
});

//监听WebSocket链接关闭事件
$ws->on('close', function ($ws, $fd) {
    echo "client-{$fd} is closed\n";
});

$ws->start();

想了解更多，请参考 Swoole 官方文档：https://wiki.swoole.com/#/

Workerman：

在学习 WebSocket 的过程当中，还发现了一个纯 PHP 实现的框架：Workerman

• 须要 PHP 5.3.3 或更高版本
• 用法以下：

<?php
use Workerman\Worker;
require_once __DIR__ . '/Workerman/Autoloader.php';

// 注意：这里与上个例子不一样，使用的是websocket协议
$ws_worker = new Worker("websocket://0.0.0.0:2000");

// 启动4个进程对外提供服务
$ws_worker->count = 4;

// 当收到客户端发来的数据后返回hello $data给客户端
$ws_worker->onMessage = function($connection, $data)
{
    // 向客户端发送hello $data
    $connection->send('hello ' . $data);
};

// 运行worker
Worker::runAll();

想了解更多，请参考 Workerman 官方文档：http://doc.workerman.net/