thinkphp6.0swoole扩展websocket使⽤教程
前⾔
ThinkPHP即将迎来最新版本6.0，针对⽬前越来越流⾏Swoole，thinkphp也推出了最新的扩展think-swoole 3.0。
介绍
即将推出的tp6.0，已经适配swoole.并推出think-swoole 3.0，并且默认适配了socketio。和2.0版本在使⽤⽅法上⾯有些许不同。Websocket 继承与Http，进⾏websocket连接之前需要⼀次HTTP请求，如果当期地址⽀持websocket则返回101，然后进⾏连接。也就是说并不是我的服务⽀持websocket后，请求每个连接地址都可以进⾏websocket连接，⽽是需要预先适配才可以连接。
参数配置
1 2 3 4 5 6 7 8 9 10 11 12 13 14'server'=> [ 'host'=> '0.0.0.0', // 监听地址
reactor debug mode is enabled'port'=> 808, // 监听端⼝
'mode'=> SWOOLE_PROCESS, // 运⾏模式默认为SWOOLE_PROCESS
'sock_type'=> SWOOLE_SOCK_TCP, // sock type 默认为SWOOLE_SOCK_TCP
'options'=> [ 'pid_file'=> runtime_path() . 'swoole.pid', 'log_file'=> runtime_path() . 'swoole.log', 'daemonize'
=> false, // Normally this value should be 1~4 times larger according to your cpu cores.
'reactor_num'=> swoole_cpu_num(), 'worker_num'=> swoole_cpu_num(), 'task_worker_num'=> 4,//swoole_cpu_num(),
'enable_static_handler'=> true, 'document_root'=> root_path('public'), 'package_max_length'=> 20 * 1024 * 1024,
'buffer_output_size'=> 10 * 1024 * 1024, 'socket_buffer_size'=> 128 * 1024 * 1024, 'max_request'=> 3000, 'send_yield'=> true,
],
], 'websocket'=> [ 'enabled'=> true,// 开启websocket
'handler'=> Handler::class, //⾃定义wbesocket绑定类
'parser'=> Parser::class, //⾃定义解析类
'route_file'=> base_path() . 'websocket.php', 'ping_interval'=> 25000, 'ping_timeout'=> 60000, 'room'=> [ 'type'=> TableRoom::class, 'room_rows'=> 4096, 'room_size'=> 2048, 'client_rows'=> 8192, 'client_size'=> 2048,
],
], 'auto_reload'=> true, 'enable_coroutine'=> true, 'resetters'=> [], 'tables'
=> [],
链接： 提取码：x2p5
免费分享，但是X 度限制严重，如若链接失效点击链接或搜索加 号。
handler 和parser ⼤⼤⽅便了⾃定义websocket 服务，默认系统集成socketio 。
本⽂主要介绍如何使⽤socketio ，这⾥假设⼤家有socketio 有⼀定了解和使⽤基础。
socketIo
默认会在请求地址后加相应的参数
同时，socketio 默认情况下，会认为 url/socket.io/ 是⽀持websocket
服务的地址。
⽽在tp-swoole3.0内部已经对该地址请求进⾏了处理
12
3
4
5<?phpnamespace think\swoole\websocket\socketio;use think\Config;use think\Cookie;use think\Request;class Controller{ protected $transports = ['polling','websocket']; public function upgrade(Request $request, Config $config, Cookie $cookie) { if (!in_array($request->param('transport'), $this->transports)) { return json( [ 'code' => 0, 'message' => 'Transport unknown', ], 400
);
6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 } if($request->has('sid')) {
$response= response('1:6');
} else{
$sid= base64_encode(uniqid());
$payload= json_encode(
[ 'sid'=> $sid, 'upgrades'=> ['websocket'], 'pingInterval'=> $config->get('swoole.websocket.ping_interval'), 'pingTimeout'=> $config->get('swoole.websocket.ping_timeout'),
]
);
$cookie->set('io', $sid);
$response= response('97:0'. $payload. '2:40');
} return$response->contentType('text/plain');
} public function reject(Request $request)
{ return json(
[ 'code'=> 3, 'message'=> 'Bad request',
], 400
);
}
}
TP6.0，插件注册采⽤了service⽅式进⾏了注册，可在tp-swoole 服务注册⽂件中查看路由注册信息，如果想⾃定义链接规则，则可以覆盖该路由。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18<?php// +----------------------------------------------------------------------// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]// +----------------------------------------------------------------------// | Copyright (c) 2006-2018 thinkphp All rights reserved.// +----------------------------------------------------------------------// | Licensed (
/licenses/LICENSE-2.0 )// +----------------------------------------------------------------------// | Author: yunwuxin <448901948@qq>// +----------------------------------------------------------------------namespace think\swoole;use Swoole\Http\Server as HttpServer;use Swoole\Websocket\Server as WebsocketServer;use think\App;use think\Route;use think\swoole\command\Server as ServerCommand;use think\swoole\facade\Server;use think\swoole\websocket\socketio\Controller;use
think\swoole\websocket\socketio\Middleware;class Service extends \think\Service{ protected $isWebsocket = false; /**
* @var HttpServer | WebsocketServer
*/
protected static$server; public function register()
{ $this->isWebsocket = $this->app->config->get('abled', false); $this->app->bind(Server::class, function() { if
(is_null(static::$server)) { $this->createSwooleServer();
} return static::$server;
}); $this->app->bind('swoole.server', Server::class); $this->app->bind(Swoole::class, function(App $app) { return new Swoole($app);
}); $this->app->bind('swoole', Swoole::class);
} public function boot(Route $route)
{ $this->commands(ServerCommand::class); if($this->isWebsocket) {
$route->group(function() use($route) {
$route->get('socket.io/', '@upgrade');
$route->post('socket.io/', '@reject');
})->prefix(Controller::class)->middleware(Middleware::class);
}
} /**
* Create swoole server.
19 20 21 22 23 24 25 26 27 28 29 */
protected function createSwooleServer()
{
$server= $this->isWebsocket ? WebsocketServer::class: HttpServer::class;
$config= $this->app->config;
$host= $config->get('swoole.server.host');
$port= $config->get('swoole.server.port');
$socketType= $config->get('swoole.server.socket_type', SWOOLE_SOCK_TCP);
$mode= $config->get('de', SWOOLE_PROCESS); static::$server= new$server($host, $port, $mode, $socketType); $options= $config->get('swoole.server.options'); static::$server->set($options);
}
}
Socketio默认使⽤demo
1 2 3 4 5 6 7<!DOCTYPE html><html lang="en"><head>
<meta charset="UTF-8">
<title>Title</title>
<script src="./static/js/socket.io.js"></script></head><body><script> const socket = io('localhost:808');
<("test",function(res){console.log(res)});</script></body></html>
Websocket路由配置⽅法
在app⽬录下新建websocket.php⽂件，其中需要注意，由于使⽤了反射，闭包参数名称不能随意定义，不然⽆法注⼊。第⼀个参数是websocket，是当前websocket的Server对象，第⼆个参数data是客户端发送的数据。其中socketio emit的第⼀个参数和Websocket::on的第⼀个参数⼀致，作为事件名称。
1
2 3 4 5 6 7 8 9 10 11 12 13 14<?php/**
* Author:Xavier Yang
* Date:2019/6/5
* Email:499873958@qq
*/use\think\swoole\facade\Websocket;
Websocket::on("test", function(\think\swoole\Websocket $websocket, $data) { //var_dump($class); $websocket->emit("test", "asd");
});
Websocket::on("test1", function($websocket, $data) {
$websocket->emit("test", "asd");
});
Websocket::on("join", function(\think\swoole\Websocket $websocket, $data) {
$websocket->join("1");
});
参考如上⽅法即可使⽤全新的websocket服务。当然tp-swoole3.0同样还有许多其他的新功能，这些功能需要⼤家去摸索尝试。我也会在接下来的⽂章中，⼀起与⼤家分享我的使⽤过程。
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论