正在显示
1 个修改的文件
包含
1 行增加
和
2 行删除
@@ -51,12 +51,11 @@ $worker->onWorkerStart = function ($worker) { | @@ -51,12 +51,11 @@ $worker->onWorkerStart = function ($worker) { | ||
51 | // $data数组格式,里面有uid,表示向那个uid的页面推送数据 | 51 | // $data数组格式,里面有uid,表示向那个uid的页面推送数据 |
52 | $data = json_decode($buffer, true); | 52 | $data = json_decode($buffer, true); |
53 | $uid = $data['uid']; | 53 | $uid = $data['uid']; |
54 | - echo $uid; | 54 | + $connection->send($uid); |
55 | // 通过workerman,向uid的页面推送数据 | 55 | // 通过workerman,向uid的页面推送数据 |
56 | $ret = sendMessageByUid($uid, $data['percent']); | 56 | $ret = sendMessageByUid($uid, $data['percent']); |
57 | // 返回推送结果 | 57 | // 返回推送结果 |
58 | // $connection->send($ret ? 'ok' : 'fail'); | 58 | // $connection->send($ret ? 'ok' : 'fail'); |
59 | - echo $ret; | ||
60 | $connection->send($ret); | 59 | $connection->send($ret); |
61 | }; | 60 | }; |
62 | $inner_text_worker->listen(); | 61 | $inner_text_worker->listen(); |
-
请 注册 或 登录 后发表评论