在 Laravel 中使用 Workerman 进行 socket 通讯
19027 / 80 / 创建于 5年前 /
小陈叔叔 的个人博客
1.安装 Workerman
由于要使用客户端点对点通讯，选择了 workerman/gateway-worker 的扩展包，它已经引入了 workerman/workerman 。
$ composer require workerman/gateway-worker2.创建 Workerman 启动文件
创建一个 artisan 命令行工具来启动 Socket 服务端，在 app/Console/Commands 目录下建立命令行文件。
<?php
namespace App\Console\Commands;
use GatewayWorker\BusinessWorker;
use GatewayWorker\Gateway;
use GatewayWorker\Register;
use Illuminate\Console\Command;
use Workerman\Worker;
class WorkermanCommand extends Command
{
protected $signature = 'workman {action} {--d}';
protected $description = 'Start a Workerman server.';
public function handle()
{
global $argv;
$action = $this->argument('action');
$argv[0] = 'wk';
$argv[1] = $action;
$argv[2] = $this->option('d') ? '-d' : '';
$this->start();
}
private function start()
{
$this->startGateWay();
$this->startBusinessWorker();
$this->startRegister();
Worker::runAll();
}
private function startBusinessWorker()
{
$worker = new BusinessWorker();
$worker->name = 'BusinessWorker';
$worker->count = 1;
$worker->registerAddress = '127.0.0.1:1236';
$worker->eventHandler = \App\Workerman\Events::class;
}
private function startGateWay()
{
$gateway = new Gateway("websocket://0.0.0.0:2346");
$gateway->name = 'Gateway';
$gateway->count = 1;
$gateway->lanIp = '127.0.0.1';
$gateway->startPort = 2300;
$gateway->pingInterval = 30;
$gateway->pingNotResponseLimit = 0;
$gateway->pingData = '{"type":"@heart@"}';
$gateway->registerAddress = '127.0.0.1:1236';
}
private function startRegister()
{
new Register('text://0.0.0.0:1236');
}
}3.创建事件监听文件
创建一个 app/Workerman/Events.php 文件来监听处理 workman 的各种事件。
<?php
namespace App\Workerman;
class Events
{
public static function onWorkerStart($businessWorker)
{
}
public static function onConnect($client_id)
{
}
public static function onWebSocketConnect($client_id, $data)
{
}
public static function onMessage($client_id, $message)
{
}
public static function onClose($client_id)
{
}
}4.启动 Workerman 服务端
在命令行里面执行，支持的命令大概有 start|stop|restart，其中 -d 的意思是 daemon 模式。
$ php artisan workman start -d当你看到如下结果的时候，workman已经启动成功了。
Workerman[wk] start in DEBUG mode
----------------------- WORKERMAN -----------------------------
Workerman version:3.5.11 PHP version:7.1.11
------------------------ WORKERS -------------------------------
user worker listen processes status
root Gateway websocket://0.0.0.0:2346 1 [OK]
root BusinessWorker none 1 [OK]
root Register text://0.0.0.0:1236 1 [OK]
----------------------------------------------------------------
Press Ctrl+C to stop. Start success.
onWorkerStart表述能力不是很好，按照这个流程，可以很快的搭建起基于 workerman 的 socket 服务端，其中的运行配置参数等，大家自行百度吧。
本作品采用《CC 协议》，转载必须注明作者和本文链接
本帖由系统于 5年前 自动加精
我执行这个命令报错
关于 LearnKu
粤公网安备 44030502004330号
推荐文章：