hyperf/doc/zh-cn/websocket-server.md

92 lines
2.4 KiB
Markdown
Raw Normal View History

2019-07-02 02:14:33 +08:00
# WebSocket 服务
2019-06-29 16:50:15 +08:00
Hyperf 提供了对 WebSocket Server 的封装,可基于 [hyperf/websocket-server](https://github.com/hyperf/websocket-server) 组件快速搭建一个 WebSocket 应用。
2019-06-29 16:50:15 +08:00
2019-07-02 01:58:34 +08:00
## 安装
```bash
2019-06-29 16:50:15 +08:00
composer require hyperf/websocket-server
```
2019-07-02 01:58:34 +08:00
## 配置 Server
2019-06-29 16:50:15 +08:00
修改 `config/autoload/server.php`,增加以下配置。
2019-07-02 01:58:34 +08:00
```php
<?php
2019-06-29 16:50:15 +08:00
'servers' => [
[
'name' => 'ws',
'type' => Server::SERVER_WEBSOCKET,
'host' => '0.0.0.0',
'port' => 9502,
'sock_type' => SWOOLE_SOCK_TCP,
'callbacks' => [
SwooleEvent::ON_HAND_SHAKE => [Hyperf\WebSocketServer\Server::class, 'onHandShake'],
SwooleEvent::ON_MESSAGE => [Hyperf\WebSocketServer\Server::class, 'onMessage'],
SwooleEvent::ON_CLOSE => [Hyperf\WebSocketServer\Server::class, 'onClose'],
],
],
],
```
2019-07-02 01:58:34 +08:00
## 配置路由
2019-06-29 16:50:15 +08:00
2019-07-02 01:58:34 +08:00
> 目前暂时只支持配置文件的模式配置路由,后续会提供注解模式。
`config/routes.php` 文件内增加对应 `ws` 的 Server 的路由配置,这里的 `ws` 值取决于您在 `config/autoload/server.php` 内配置的 WebSocket Server 的 `name` 值。
```php
<?php
2019-06-29 16:50:15 +08:00
Router::addServer('ws', function () {
Router::get('/', 'App\Controller\WebSocketController');
});
```
2019-07-02 01:58:34 +08:00
## 创建对应控制器
2019-06-29 16:50:15 +08:00
```php
<?php
declare(strict_types=1);
namespace App\Controller;
use Hyperf\Contract\OnCloseInterface;
use Hyperf\Contract\OnMessageInterface;
use Hyperf\Contract\OnOpenInterface;
use Swoole\Http\Request;
use Swoole\Server;
use Swoole\Websocket\Frame;
2019-10-08 12:43:48 +08:00
use Swoole\WebSocket\Server as WebSocketServer;
2019-06-29 16:50:15 +08:00
class WebSocketController implements OnMessageInterface, OnOpenInterface, OnCloseInterface
{
2019-10-08 12:43:48 +08:00
public function onMessage(WebSocketServer $server, Frame $frame): void
2019-06-29 16:50:15 +08:00
{
2019-07-02 01:58:34 +08:00
$server->push($frame->fd, 'Recv: ' . $frame->data);
2019-06-29 16:50:15 +08:00
}
public function onClose(Server $server, int $fd, int $reactorId): void
{
var_dump('closed');
}
2019-10-08 12:43:48 +08:00
public function onOpen(WebSocketServer $server, Request $request): void
2019-06-29 16:50:15 +08:00
{
2019-07-02 01:58:34 +08:00
$server->push($request->fd, 'Opened');
2019-06-29 16:50:15 +08:00
}
}
```
2019-07-02 01:58:34 +08:00
接下来启动 Server便能看到对应启动了一个 WebSocket Server 并监听于 9502 端口,此时您便可以通过各种 WebSocket Client 来进行连接和进行数据传输了。
2019-06-29 16:50:15 +08:00
```
$ php bin/hyperf.php start
[INFO] Worker#0 started.
[INFO] WebSocket Server listening at 0.0.0.0:9502
[INFO] HTTP Server listening at 0.0.0.0:9501
2019-07-02 01:58:34 +08:00
```