webman的redis-queue队列消费怎么算成功呢?
webman的Redis消息队列组件 redis-queue文档中没有提及，如何告知服务部分消费成功？例子中没有说明，试验代码，会按重试次数重试。 Stomp组件则有下面这种代码，告知服务端已经消费成功。 // 值为 client 时需要调用$ack_resolver->ack()告诉服务端已经成功消费 // 值为 auto 时无需调用$ack_resolver->ack() public $ack ...
想请问一下 关于定时器的问题 多个连接调用同一个定时器是会被挤掉麽
在接口中发起推送aa,aa中用了定时器,同一时间另外一个$to发起aa推送是不能执行这个定时器内的逻辑吗？ $sender_io->on('workerStart', function () { case 'aa': global $sender_io, $to; if ($to) { $aa_timerid = Timer::add(8, fun...
js close()无法关闭链接
var heartbeat, ws = new WebSocket(url); ws.onopen = function(e){ heartbeat = setInterval(function(){ ws.send({type:'heartbeat'}); },3e4); plugin.emit('live.onopen', e, heartbeat); }, ...
求解：webman cookie在函数中的设置和获取
如何在同一个函数内设置和获取到webman中的cookie. 因在think的业务中，在同一个函数中，先设置了cookie::set(),后再get获取。 在webman中如果使用这种方式能否在同一个函数中实现既设置又获取?...
请问一下webman数据模型可以自动创建吗？
请问一下webman数据模型可以自动创建吗？我看了一下文档php artisan命令执行不了，webman有没有自己的模型创建命令，或者要安装哪个库才能解决...
求解：路由可变参数定义和模板中获取文章分类问题
1.第一个问题： index应用，article类，cate方法 路径为/index/atricle/cate[/type][/page]， /type和/page是可变参数 如访问: /index/atricle/cate， /index/atricle/cate/type， /index/atricle/cate/page， /index/atricle/cate/type/page 这条路由规则应该怎么定义成由...
socket可写事件怎么触发
public function send($send_buffer, $raw = false) .... Worker::$globalEvent->add($this->_socket, EventInterface::EV_WRITE, array($this, 'baseWrite')); // Check if the send buffer...
关于gatewayworker的疑问
我现要用gatewayworker开发一个棋牌游戏的服务服务器 那现在有一个问题就是 如果 BusinessWorker 的进程设置大于1 那么连接上来的两个玩家怎么能保证进入到相同的房间 以我现在的理解 1 设置 BusinessWorker 进程数 为1 2 设置 设置Gateway到BusinessWorker路由规则 请问还有其它的方法吗 PS 强烈建议网站加一个找回密码功能，还有就是问题检索的功能...
GatewayWorker Register被不明来源访问，不知道secretKey是否配置正确
提示符： 源码： $registerIp = '127.0.0.1'; $registerPort = '6006'; $secretKey = '6006RegisterPass'; //注册Serve,只能一个 $r = new Register("text://0.0.0.0:$registerPort"); $r->name = '6006Register'; $r-&...
心跳断开问题
目前是设备id绑定$client_id 连接id 我的ateway配置是 60秒不回的话就判断断线 为啥绑定后的id会断线两次？？？ 我推测可能是，第一次登录$client_id1绑定id-123456,过两个心跳之后，没给服务器心跳， 然后设备重连 client_id2绑定id-123456，这时候服务器把第一次的踢出吗？...
咨询一下大佬: gatewayworker 源码阅读 _innerTcpWorker 为什么每个进程使用独立的端口？
咨询一下大佬，我在阅读 gatewayworker 源码的时候 有个疑问，在与BusinessWorker 通讯的时候为啥每个进程独立的端口? 这样做的好处是什么？ 感谢大佬解答疑惑 // 初始化 gateway 内部的监听，用于监听 worker 的连接已经连接上发来的数据 $this->_innerTcpWorker = new Worker("GatewayProtocol://...
GatewayWorker群发和Channel组件群发
GatewayWorker群发和Channel组件群发有性能差别吗？ 目前使用Channel组件的方式实现，在onWebSocketConnect里面将TcpConnection添加到数组中。每个进程连接Channel服务，监听事件。收到事件后遍历数组的连接发送到websocket客户端中。 这种方式在2核4g的云服务器中300个websocket连接，负载（宝塔中查看）和CPU都会跑到100%。不知道是不是正常（过...
