Hi walkor, 我现在服务器框架只是用的Workerman,如果要用Channel作分布式通讯的话,必须要知道连接所在的worker, 那么当设备连接上来的时候,我要如何获取到当连接所在的进程(worker id)? 例如在$tcp_worker->onConnect = function ($connection) {}这个函数里面....
Hi, walkor, 关于粘包问题,我想问一下。第1种:服务器有1台设备连接,这个连接每秒发送100条数据(即服务器1秒内接收了100条数据),这样100%会有粘包问题(这个问题我已经处理),但是如果服务器有100台设备连接,100台设备在1秒内同时发送1条数据(即服务器1秒内也是接收了100条数据),那这种情况会不会出现粘包的情况呢?...
Hi,walkor, 目前该问题已是在生产项目上,我在PHP脚本里面直接引用RPCclient.php,然后远程调用RPC服务器往数据库里写数据,脚本执行完一段时间后发现脚本的进程退出了,看了一下日志是RPC抛异常了:Uncaught exception 'Exception' with message 'recvData empty',导致脚本进程退出 我有几点想请问一下: 1,Uncaught excepti...
Hi,walkor, 最近我在项目使用GatewayWorker时也碰到了粘包问题,然后查阅了相关文档,发现text协议 能够很好解决粘包问题,但是客户端连上服务器发数据时,Events.php的onMessage方法中接收不到数据,这是 怎么回事呢?我在start_gateway.php里是这样写的$gateway = new Gateway("text://0.0.0.0:8585"...
Hi walkor, GatewayWorker框架的业务代码部分都是写在Events.php里面,随便着业务不断增加,我现在是统一调用外部的封装方法,请问这些方法我全部定义成static的会有问题吗?...
hi,walkor,在用GateWayWorker应用到实际项目中时,服务器端设置的1分钟心跳间隔,如果设备在断电或断网 的时候服务器不能立马感知到设备已经下线,此时设备断电或断网后立马重新连接,那么GateWay提示“拒绝重 连”,等服务端通过心跳感知到设备已经下线后,设备才能重新连接。这是不是服务器还认为此设备在线,不能重 复连接?那么有办法怎么能让设备断电后立马重连吗?因为我是跟硬件的同事联调的。他说重连的时候...
Hi Walkor, $result = $ret->query("select * from protype_brand inner join protype on protype_brand.protype_id=protype.protype_id where protype_brand.product_code='{$product_code}'"); 直接用这个query方法可以查到对应的值 ,但为...
Walkor,远程请求一次JsonRPC的时候 ,比如用户登陆 登陆成功正确返回是 { "code": 0, "msg": "ok", "data": "" } 那么,如果密码输入不正确登陆失败呢?如何返回{ "code": 1, "msg": "error"...
@walkor, 业务逻辑是这样的: 设备A通过mqtt协议 向 Mosquitto服务器上的某个Topic发布消息,php的mqtt客户端通过轮询订阅这个Topic来实时获取设备A上报的数据,然后存入数据库。 php端的mqtt client 这边我已经有实现的类,此类提供订阅和发布接口.. 目前我这边实现部分代码: $topics = array("qos"=>0, "function"=>"get...