thinkphp5.0安装workman
composer安装
composer require topthink/think-worker=1.0.*
workman服务需要PHP开启某些函数
//使用workerman需要解除以下函数的禁用
stream_socket_server
stream_socket_client
pcntl_signal_dispatch
pcntl_signal
pcntl_alarm
pcntl_fork
posix_getuid
posix_getpwuid
posix_kill
posix_setsid
posix_getpid
posix_getpwnam
posix_getgrnam
posix_getgid
posix_setgid
posix_initgroups
posix_setuid
posix_isatty
在项目根目录创建
server.php
代码如下
<?php
define('APP_PATH', __DIR__ . '/application/');
define('BIND_MODULE','push/Worker');
require __DIR__ . '/thinkphp/start.php';
*创建模块应答
application|push|controller|Worker.php
代码如下
<?php
namespace app\push\controller;
use think\worker\Server;
use think\Log;
use think\Controller;
class Worker extends Server
{
protected $socket = 'websocket://0.0.0.0:2346';
/**
* 收到信息
* @param $connection
* @param $data
*/
public function onMessage($connection, $data)
{
$params =$data;
$data = json_decode($data,true);
if ($data['sign']){
$connection->send($data['sign']);
}else{
$return_data ="我于".date("Y-m-d H:i:s")."收到您的信息:".$params;
$connection->send($return_data);
}
}
/**
* 当连接建立时触发的回调函数
* @param $connection
*/
public function onConnect($connection)
{
}
/**
* 当连接断开时触发的回调函数
* @param $connection
*/
public function onClose($connection)
{
}
/**
* 当客户端的连接上发生错误时触发
* @param $connection
* @param $code
* @param $msg
*/
public function onError($connection, $code, $msg)
{
echo "error $code $msg\n";
}
/**
* 每个进程启动
* @param $worker
*/
public function onWorkerStart($worker)
{
Log::write('进程启动了:'.date('Y-m-d H:i:s'),'info');
}
public function index(){
parent::start();
}
}
启动php服务进程
php server.php start #启动 |stop 停止|restart重启
Nginx配置反向代理
在server内添加
location /wss {
proxy_pass http://127.0.0.1:2346/;
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "upgrade";
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header REMOTE-HOST $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
client_max_body_size 5000M;
}
客户端访问代码
我本地创建了一个8.html文件访问
<!doctype html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>测试接收数据</title>
<script src="https://code.jquery.com/jquery-3.6.0.min.js"></script>
</head>
<body>
<button type="button" class="signScore">点击一下</button>
<script type="application/javascript">
function StartWebSocket(){
websocket = new WebSocket("ws://app.dev.ejiegd.com/wss");
websocket.onopen = function (data) {
// 发送信息
var content =Math.random().toString(36).slice(2,10);
websocket.send(content);
};
websocket.onmessage = function (data) {
console.log("接收内容");
alert(data.data);
console.log(data.data); // 接收信息
};
websocket.onclose = function (data) {
console.log("关闭", data); //关闭
};
}
$(".signScore").click(function () {
StartWebSocket();
})
</script>
</body>
</html>
最终效果
workerman可以一直运行，以daemon（守护进程）方式启动workerman即可后台一直运行。
启动停止workerman：
启动
以debug（调试）方式启动
php server.php start
以daemon（守护进程）方式启动
php server.php start -d
停止
php server.php stop
重启
php server.php restart
平滑重启
php server.php reload
查看状态
php server.php status
debug和daemon方式区别：
1、以debug方式启动，代码中echo、var_dump、print等打印函数会直接输出在终端。
2、以daemon方式启动，代码中echo、var_dump、print等打印会默认重定向到/dev/null文件，可以通过设置Worker::$stdoutFile = '/your/path/file';来设置这个文件路径。
3、以debug方式启动，终端关闭后workerman会随之关闭并退出。
4、以daemon方式启动，终端关闭后workerman继续后台正常运行。
