在laravel中集成swoole,使用hhxsv5/laravel-s扩展

准备工作

windows环境使用docker搭建
安装swoole扩展
在本地安装的话，以 Laradock 为例，需要在 laradock 目录下的 .env 中将下面两行配置值设置为 true

WORKSPACE_INSTALL_SWOOLE=true
PHP_FPM_INSTALL_SWOOLE=true

执行 docker-compose build php-fpm workspace 即可，执行完以后记得重启服务

项目根目录安装hhxsv5/laravel-s扩展

composer require hhxsv5/laravel-s

该扩展包具备自动发现功能（Laravel 5.5 以上版本可用），无需手动在 config/app.php 配置文件中注册，安装完成后，运行如下 Artisan 命令相应脚本和配置文件发布到根目录下：

php artisan laravels publish

可以查看https://github.com/hhxsv5/laravel-s/blob/master/README-CN.md文档

项目配置

修改config/laravels配置

‘websocket’ => [
‘enable’ => true, // 看清楚，这里是true
‘handler’ => \App\Services\WebSocketService::class,
],
‘swoole’ => [
// dispatch_mode只能设置为2、4、5，https://wiki.swoole.com/wiki/page/277.html
‘dispatch_mode’ => 2,
// …
],

env配置(本人使用的docker环境，其他环境请自行修改ip)

LARAVELS_LISTEN_IP=workspace
LARAVELS_DAEMONIZE=true

nginx反向代理配置

map $http_upgrade $connection_upgrade {default upgrade;''      close;
}
upstream swoole {# 通过 IP:Port 连接server workspace:5200 weight=5 max_fails=3 fail_timeout=30s;keepalive 16;
}
server {listen 80;# 别忘了绑Hostserver_name blogtest.localhost;root /var/www/laravel_demo/public;index index.php index.html index.htm;# Nginx处理静态资源(建议开启gzip)，LaravelS处理动态资源。location / {try_files $uri @laravels;}# 当请求PHP文件时直接响应404，防止暴露public/*.php#location ~* \.php$ {#    return 404;#}# Http和WebSocket共存，Nginx通过location区分# !!! WebSocket连接时路径为/ws# Javascript: var ws = new WebSocket("ws://blogtest.localhost/ws");location =/ws {# proxy_connect_timeout 60s;# proxy_send_timeout 60s;# proxy_read_timeout：如果60秒内被代理的服务器没有响应数据给Nginx，那么Nginx会关闭当前连接；同时，Swoole的心跳设置也会影响连接的关闭# proxy_read_timeout 60s;proxy_http_version 1.1;proxy_set_header X-Real-IP $remote_addr;proxy_set_header X-Real-PORT $remote_port;proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;proxy_set_header Host $http_host;proxy_set_header Scheme $scheme;proxy_set_header Server-Protocol $server_protocol;proxy_set_header Server-Name $server_name;proxy_set_header Server-Addr $server_addr;proxy_set_header Server-Port $server_port;proxy_set_header Upgrade $http_upgrade;proxy_set_header Connection $connection_upgrade;proxy_pass http://swoole;}location @laravels {# proxy_connect_timeout 60s;# proxy_send_timeout 60s;# proxy_read_timeout 60s;proxy_http_version 1.1;proxy_set_header Connection "";proxy_set_header X-Real-IP $remote_addr;proxy_set_header X-Real-PORT $remote_port;proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;proxy_set_header Host $http_host;proxy_set_header Scheme $scheme;proxy_set_header Server-Protocol $server_protocol;proxy_set_header Server-Name $server_name;proxy_set_header Server-Addr $server_addr;proxy_set_header Server-Port $server_port;proxy_pass http://swoole;}
}

nginx配置查看https://laravelacademy.org/post/19700

swoole简单demo

创建 App\Services\WebSocketService.php

<?php
namespace App\Services;use Hhxsv5\LaravelS\Swoole\WebSocketHandlerInterface;
use Swoole\Http\Request;
use Swoole\WebSocket\Frame;
use Swoole\WebSocket\Server;/*** @see https://wiki.swoole.com/wiki/page/400.html*/
class WebSocketService implements WebSocketHandlerInterface
{// 声明没有参数的构造函数public function __construct(){}public function onOpen(Server $server, Request $request){// 在触发onOpen事件之前Laravel的生命周期已经完结，所以Laravel的Request是可读的，Session是可读写的// \Log::info('New WebSocket connection', [$request->fd, request()->all(), session()->getId(), session('xxx'), session(['yyy' => time()])]);$server->push($request->fd, 'Welcome to LaravelS');// throw new \Exception('an exception');// 此时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理}public function onMessage(Server $server, Frame $frame){// \Log::info('Received message', [$frame->fd, $frame->data, $frame->opcode, $frame->finish]);$server->push($frame->fd, $frame->data);// throw new \Exception('an exception');// 此时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理}public function onClose(Server $server, $fd, $reactorId){// throw new \Exception('an exception');// 此时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理}
}

创建控制器 IndexController.php

<?php
namespace App\Http\Controllers;class IndexController extends Controller
{public function index(){return view('index');}
}

view试图：

<!DOCTYPE html>
<html>
<head><meta charset="UTF-8"><title>Chat Client</title>
</head>
<body>
<div style="width:600px;margin:0 auto;border:1px solid #ccc;"><div id="content" style="overflow-y:auto;height:300px;"></div><hr /><div style="height:40px;background:white;"><input type="text" class="form-control" id="message"  placeholder="请输入内容"><button type="button" class="btn btn-primary" onclick="sendMessage()">Primary</button></div>
</div><script type="text/javascript">if(window.WebSocket){// 端口和ip地址对应不要写错  写自己的配置 var webSocket = new WebSocket("ws://blogtest.localhost/ws");webSocket.onopen = function (event) {console.log('webSocket 连接成功');};// 连接关闭时触发webSocket.onclose = function (event) {console.log("WebSocket 关闭连接");}//收到服务端消息回调webSocket.onmessage = function (event) {var content = document.getElementById('content');content.innerHTML = content.innerHTML.concat('<p style="margin-left:20px;height:20px;line-height:20px;">'+event.data+'</p>');console.log(event.data)}var sendMessage = function(){var data = document.getElementById('message').value;webSocket.send(data);}}else{console.log("您的浏览器不支持WebSocket");}
</script></body>
</html>

启动laravels：

php bin/laravels start

具体可以查看https://github.com/hhxsv5/laravel-s文档

运行结果

注意：修改了代码以后执行

php bin/laravels reload
或者 php bin/laravels restart

相关文档：https://laravelacademy.org/post/9801
https://www.bookstack.cn/read/LaravelS/spilt.8.d7f5aa7b24640641.md
laradvels配置说明https://github.com/hhxsv5/laravel-s/blob/master/Settings-CN.md
laravels使用说明https://github.com/hhxsv5/laravel-s/blob/master/README-CN.md