onConnect 里调用 onWebSocketConnect 的回调方法，如果不满足条件关闭了链接该如何终止 onConnect 后续事件呢？
代码如下： $worker->onConnect = function (\Workerman\Connection\TcpConnection $connection) { $connection->onWebSocketConnect = function ($connection, $http_header) { if (!isset($_GET['sid']) || !i...
请问 $worker->onConnect 和 $connection->onWebSocketConnect 是异步的吗？
我的代码大致如下： $worker->onConnect = function (\Workerman\Connection\TcpConnection $connection) { $connection_ip = $connection->getRemoteIp(); $connection->onWebSocketConnect = function ($connection...
webman mongo数据如何只获取一条记录
<?php namespace app\controller; use support\Request; use support\Db; class User { public function db(Request $request) { Db::connection('mongodb')->collection('test')->insert([1,2,3]); return json(Db::...
GatewayWorker 中onConnect怎么获取 query 参数
请问在GatewayWorker 中onConnect怎么获取 query 参数 像下面这样，怎么在onConnect中获取token参数 ws://192.168.10.31:2348/?token=123...
关于workerman的健壮性的一个问题，connect的时候故意传错一个参数，程序就崩溃了
我在websocket的链接里加了个参数类似下面： ws://127.0.0.1:8019/?sid=3670549-360dMrtp 然后服务端 onConnect 方法里做了如下验证： $worker->onConnect = function (\Workerman\Connection\TcpConnection $connection) { try { $connection-...
为何我的队列服务没啥请求但是那个total_request一直在涨？
我按照作者： http://doc.workerman.net/components/workerman-redis-queue.html 这篇文章实现的一个队列服务器，我通过 status 命令发现那个 total_request 一直在涨，但是我没有做什么请求啊，我才刚刚开发。 具体信息如下： root@c1cf8d8252d7:/var/www# php diary/server/WorkermanQueueS...
自定义协议的出入口进程是否独立
我是在项目中使用的自定义协议，我想问的是如果我现在有两个客户端，服务端同时分别向两个客户端发送一个命令，如果我在自定义的协议中的encode($buffer)方法中调用sleep(10)这个方法，那么到达两个客户端的命令会有这个10秒的间隔吗？ 也就是想问，多个客户端的命令出口和入口是独立的还是统一接收的？...
启动workerman报错
PHP Warning: stream_socket_server(): php_network_getaddresses: getaddrinfo failed: Name or service not known in /www/wwwroot/im.1234xiss.com/vendor/workerman/workerman/Worker.php on line 2255 Warning: stream_s...
win10 php start.php nproc 命令不存在？
D:\www\webman>php start.php 'nproc' is not recognized as an internal or external command, operable program or batch file. ...
请问下面这个定时器如何改成普通函数的形式？
代码如下，是workerStart下的定时器： // 进程启动后设置一个每30秒运行一次的定时器，定时关闭不发送心跳包的链接以及没有sid属性的链接 Timer::add(30, 'cleanWorkerInvalidConnection', [$worker]); function cleanWorkerInvalidConnection(&$worker) { $time_now = time()...
关于onConnect和onMessage的一些理解
刚刚学习workerman，看了文档，稍微有些混乱，不知道理解的是不是正确 worker和connection都有onConnect和onMessage的回调，这两个应该分别在什么时候使用？ worker的onConnect和onMessage是当workerman作为服务端被客户端连接的时候，如果被客户端连接成功会回调onConnect，如果客户端向服务端发送了消息，会回调onMessage。 connection...
现在是PHP cli模式一直while(true){} 来处理数据，想改用webman
我现在是PHP cli模式一直while(true){} 来处理数据，但是太占资源了。 如何通过webman来处理呢？ 有朋友说直接写业务逻辑就可以了，我不明白的是我写好业务逻辑之后怎么运行起来呢？和现在的PHP cli一样命令行输入启动命令来处理吗？ 之前没用过类似的框架，所以不是很明白。...
启动进程,使用定时器检测心跳
以下代码是心跳的demo 假如开了4个进程,岂不是每个进程都会每隔10秒轮询检测一次是否超时? 这样操作是不是太频繁了? 如果指定某个进程轮询,其他进程的连接又检测不到 ========== // 进程启动后设置一个每10秒运行一次的定时器 $worker->onWorkerStart = function($worker) { Timer::add(10, function()use($worker){ $t...
Workerman 工作原理，如何实现连接不在同一个进程传递消息。
Workerman 使用“Websocket”协议，开启两个子进程监听客户端连接。 描述：单机Workerman 开启4个worker子进程且开启端口复用，那么客户端连接的时候。每个客户端都有一个TcpConnection 对象实例，均保存在各自Worker 内存。 疑问一：如果来自多个websocket 客户端，但是他们的连接实例均不在同一进程。不在同一个Worker实例，那么是如何发送消息的嘛？ 疑问二：Work...
gateway收到离线后，什么方式广播给对应的客户端
环境是用的gateway和client，当客户端下线后，虽然gateway知道了，但是网站不知道，客户端也不知道，是不是应该在gateway上OnClose发送一个http请求到网站，然后网站再用client去推送离线通知？有没有更好的方法呢？...
