json rpc 如何接管 register_shutdown_function

回复

提问langbin 发起了问题 • 1 人关注 • 0 个回复 • 60 次浏览 • 2019-09-07 11:28 • 来自相关话题

请问在同一个网站的多个页面上使用gatewayworker的onclose功能,需要安装多个gatewayworker吗?

提问bv 回复了问题 • 2 人关注 • 2 个回复 • 91 次浏览 • 2019-09-06 16:49 • 来自相关话题

thinkphp5+layui+GatewayWorker开源多客服系统, 支持多客服 权限管理

回复

案例zhbo1689 回复了问题 • 0 人关注 • 1 个回复 • 137 次浏览 • 2019-09-06 15:27 • 来自相关话题

使用gatewayworker 和redis消息订阅造成的多进程阻塞

提问six 回复了问题 • 3 人关注 • 3 个回复 • 105 次浏览 • 2019-09-06 11:54 • 来自相关话题

刚接触workerman不久,问一下,硬件通过tcp发送过来的16进制文件流如何打包

提问blogdaren 回复了问题 • 2 人关注 • 1 个回复 • 103 次浏览 • 2019-09-05 10:49 • 来自相关话题

请问一下,日志经常满了,问题我又不懂

提问blogdaren 回复了问题 • 2 人关注 • 1 个回复 • 92 次浏览 • 2019-09-04 17:45 • 来自相关话题

can not connect to tcp://127.0.0.1:4000 Connection refused

提问walkor 回复了问题 • 2 人关注 • 1 个回复 • 84 次浏览 • 2019-09-04 17:41 • 来自相关话题

businessworker突然全掉了,重启半小时后又全部掉了

提问dou号 回复了问题 • 2 人关注 • 3 个回复 • 143 次浏览 • 2019-09-04 10:12 • 来自相关话题

为什么蜗壳的下载数和收益不对称

建议cai584887013 回复了问题 • 3 人关注 • 3 个回复 • 85 次浏览 • 2019-09-04 10:05 • 来自相关话题

gateway在服务器使用nginx代理wss,连接返回502

回复

提问yunwalker 发起了问题 • 1 人关注 • 0 个回复 • 83 次浏览 • 2019-09-03 19:34 • 来自相关话题

3.5.21 Gateway多进程启动失败 bug

提问walkor 回复了问题 • 3 人关注 • 4 个回复 • 118 次浏览 • 2019-09-03 18:37 • 来自相关话题

怎么传输文件啊

提问walkor 回复了问题 • 3 人关注 • 2 个回复 • 93 次浏览 • 2019-09-03 11:49 • 来自相关话题

new ArrayObject() 无法使用

提问智佳思远 回复了问题 • 3 人关注 • 2 个回复 • 80 次浏览 • 2019-09-03 10:38 • 来自相关话题

stream_socket_client(): failed to bind to

提问智佳思远 回复了问题 • 2 人关注 • 1 个回复 • 59 次浏览 • 2019-09-02 19:49 • 来自相关话题

SSL handshake error: stream_socket_enable_crypto(): SSL operation failed with code 1.

回复

提问好获严选约书亚 发起了问题 • 1 人关注 • 0 个回复 • 88 次浏览 • 2019-09-02 14:24 • 来自相关话题

Can not connect to tcp://127.0.0.1:1236 Connection refused

提问chyd 回复了问题 • 2 人关注 • 5 个回复 • 125 次浏览 • 2019-09-02 10:55 • 来自相关话题

workerman创建服务类然后启动报错think/worker/Server类找不到是哪个什么情况,

提问six 回复了问题 • 2 人关注 • 1 个回复 • 63 次浏览 • 2019-09-02 10:27 • 来自相关话题

设备通过tcp协议发送16进制的文件流,服务器如何处理

提问six 回复了问题 • 2 人关注 • 1 个回复 • 70 次浏览 • 2019-09-02 10:27 • 来自相关话题

workman使用中,客户端在进程中打开的mysql链接是否会在进程结束后被释放?

提问blogdaren 回复了问题 • 2 人关注 • 1 个回复 • 84 次浏览 • 2019-09-01 17:06 • 来自相关话题

按照手册配置了ssl,还是不管用,连接不上

提问朕震惊了 回复了问题 • 3 人关注 • 2 个回复 • 80 次浏览 • 2019-08-31 16:25 • 来自相关话题

PHP Fatal error: Uncaught Error: Class 'GatewayWorker\BusinessWorker' not found

提问cloudty 回复了问题 • 3 人关注 • 5 个回复 • 701 次浏览 • 2019-08-31 11:30 • 来自相关话题

我有两个项目部署在两台服务器上,在a服务器里发布一个事件,怎么在b服务器里订阅到

提问lianglong 发表了文章 • 4 个评论 • 142 次浏览 • 2019-08-30 21:59 • 来自相关话题

我在69服务器上发布了订单超时事件,在199服务器上订阅不到.请问怎么回事
我在69服务器上发布了订单超时事件,在199服务器上订阅不到.请问怎么回事

workerman和swoole优势和劣势分别是什么

提问天道酬勤 回复了问题 • 5 人关注 • 4 个回复 • 6004 次浏览 • 2019-08-30 16:28 • 来自相关话题

posix_kill($master_pid, 0) 返回false , 但其实是有这个进程的

提问hunterkou 回复了问题 • 2 人关注 • 2 个回复 • 83 次浏览 • 2019-08-30 12:37 • 来自相关话题

Gateway Worker进程内存不断上涨

提问damao 回复了问题 • 3 人关注 • 2 个回复 • 152 次浏览 • 2019-08-30 10:42 • 来自相关话题

AsyncTcpConnection 应该放在onWorkerStart,onConnect还是onMessage函数里面?

提问blogdaren 回复了问题 • 1 人关注 • 1 个回复 • 98 次浏览 • 2019-08-30 09:00 • 来自相关话题

AsyncTcpConnection的send函数怎么发送变量,提示错误,就是不知道怎么用

提问你别不信 回复了问题 • 3 人关注 • 2 个回复 • 588 次浏览 • 2019-08-29 23:32 • 来自相关话题

workerman怎么实现一个进程一个端口监听不同的https网站

提问bluestone 回复了问题 • 3 人关注 • 2 个回复 • 305 次浏览 • 2019-08-29 22:30 • 来自相关话题

@walkor 大大 workerman中的传输协议可以使用protobuffer吗

提问wsc218 回复了问题 • 6 人关注 • 8 个回复 • 1914 次浏览 • 2019-08-29 20:42 • 来自相关话题

怎样学习workerman

提问th 回复了问题 • 4 人关注 • 4 个回复 • 156 次浏览 • 2019-08-29 16:23 • 来自相关话题

请问 websocket如何向tcp端口发送信息?

提问blogdaren 回复了问题 • 2 人关注 • 1 个回复 • 112 次浏览 • 2019-08-29 16:22 • 来自相关话题

异步http组件react/http-client 怎么设置超时时间

提问blogdaren 回复了问题 • 2 人关注 • 1 个回复 • 76 次浏览 • 2019-08-29 00:45 • 来自相关话题

请大神指教phpsocketio开启ssl Exception: class \Protocols\Https not exist报错了?

提问blogdaren 回复了问题 • 3 人关注 • 2 个回复 • 96 次浏览 • 2019-08-28 22:04 • 来自相关话题

websocket 无法绑定

提问轩轩 回复了问题 • 2 人关注 • 4 个回复 • 146 次浏览 • 2019-08-28 18:02 • 来自相关话题

gatewayworker报错error3,error4,11,64000

提问walkor 回复了问题 • 2 人关注 • 1 个回复 • 81 次浏览 • 2019-08-28 10:42 • 来自相关话题

@官方,使用gatewayClient连接register,如果register设置开户多个进程,连接会时而报错。

提问walkor 回复了问题 • 2 人关注 • 1 个回复 • 75 次浏览 • 2019-08-27 22:13 • 来自相关话题

workerman的reload命令

提问walkor 回复了问题 • 2 人关注 • 1 个回复 • 108 次浏览 • 2019-08-27 22:11 • 来自相关话题

fromId和toId接收消息

提问six 回复了问题 • 2 人关注 • 1 个回复 • 68 次浏览 • 2019-08-27 19:06 • 来自相关话题

GatewayWorker连接多个数据库,会自动识别吗?

提问six 回复了问题 • 2 人关注 • 1 个回复 • 91 次浏览 • 2019-08-27 19:05 • 来自相关话题

workerman实现微信公众号带参数二维码扫码识别用户

案例efnic 发表了文章 • 2 个评论 • 157 次浏览 • 2019-08-27 10:47 • 来自相关话题

完整功能体验 查看源代码,有完整的通讯流程实现。 ## https://iyuu.cn/ 发表在自己的博客 https://www.iyuu.cn/archives/202/  #说明 ...查看全部
完整功能体验
查看源代码,有完整的通讯流程实现。
## https://iyuu.cn/
发表在自己的博客
https://www.iyuu.cn/archives/202/

 #说明
此功能是利用微信公众号带参数二维码,实现扫码识别用户,并且实时通知前端扫码状态,并非ajax轮询!从而进行后续的其他业务逻辑。
 
#工作流程详解
 1. 用workerman框架,编写websocket服务后端监听`2129端口`,进程启动同时再监听一个内部通讯`5678端口`,`2129端口`等待前端页面发起连接:`https://www.iyuu.cn/usr/index.html`;
 2. 用户进入前端页面,自动连接`wss://www.iyuu.cn:2129`;
 3. 用户点击`获取二维码`,请求二维码生成接口:`https://www.iyuu.cn/qrcode`,返回二维码参数:
  ```json
{"ticket":"gQH47zwAAAAAAAAAAS5odHRwOi8vd2VpeGluLnFxLmNvbS9xLzAycTMtdzlMVEhlYzIxcF9jQU50MWsAAgQHjGRdAwR4AAAA","expire_seconds":120,"uid":1735536450}
  ```
  注:uid通过函数`rand(1,4294967200)`生成并查询缓存,确保唯一后放入Redis缓存。
 4. 把`二维码参数`,转发到websocket服务`wss://www.iyuu.cn:2129`,websocket服务保存转发来的信息建立映射关系;
 5. 显示二维码:https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket={data.ticket},用户扫码;
 6. 微信开发者接口会收到扫码结果,获取到场景值ID;
 7. 根据场景值ID从Redis缓存取出ticket校验通过,执行业务逻辑(登录、绑定、解绑、积分等等),并通过`5678端口`实时通知用户扫码后的处理结果。
 
#完整Websocket服务代码
<?php
use Workerman\Worker;
use Workerman\Lib\Timer;
define("APP_PATH", dirname(__FILE__));
// 心跳间隔40秒
define('HEARTBEAT_TIME', 40);
require_once __DIR__ . '/../../vendor/autoload.php';
require_once APP_PATH . '/Library/Function.php';
$context = array(
'ssl' => array(
// 请使用绝对路径
'local_cert' => __DIR__ . '/../../Cert/www.iyuu.cn.crt',
'local_pk' => __DIR__ . '/../../Cert/www.iyuu.cn.key',
'verify_peer' => false,
//'allow_self_signed' => true, //如果是自签名证书需要开启此选项
)
);
$worker = new Worker('websocket://0.0.0.0:2129', $context);
$worker->transport = 'ssl';
$worker->name = 'WebSocket';
/*
* 注意这里进程数必须设置为1,否则会报端口占用错误
* (php 7可以设置进程数大于1,前提是$inner_text_worker->reusePort=true)
*/
$worker->count = 1;
// 新增加一个属性,用来保存uid到connection的映射(uid是用户id或者客户端唯一标识)
$worker->uidConnections = array();
// 当有客户端连接时
$worker->onConnect = function($connection)
{
/*
//定时10秒关闭这个链接,需要10秒内发认证并删除定时器阻止关闭连接的执行
$connection->auth_timer_id = Timer::add(10, function(){
$connection->close();
});

Timer::del($connection->auth_timer_id);
*/
};

// worker进程启动后创建一个text Worker以便打开一个内部通讯端口
$worker->onWorkerStart = function($worker)
{
sc('WebSocket服务进程启动成功!');
// 开启一个内部端口,方便内部系统推送数据,Text协议格式 文本+换行符
$inner_text_worker = new Worker('text://0.0.0.0:5678');
$inner_text_worker->onMessage = function($connection, $buffer)
{
global $worker;
if (empty($buffer)) return;
// $data数组格式,里面有uid,表示向那个uid的页面推送数据
$data = json_decode($buffer, true);
if (isset($data['uid'])) {
$uid = $data['uid'];
//uid + ticket双重安全验证(防止前端冒用随机uid)
$data['ticket'] = isset($data['ticket'])&&$data['ticket'] ? $data['ticket'] : '';
$conn = $worker->uidConnections[$uid];
$ticket = isset($conn->ticket)&&$conn->ticket ? $conn->ticket : '';
if($data['ticket'] != $ticket){
return;
}
// 通过workerman,向uid的页面推送数据
$ret = sendMessageByUid($uid, $buffer);
// 返回推送结果
$connection->send($ret ? 'ok' : 'fail');
}
return;
};
// ## 执行监听 ##
$inner_text_worker->listen();
// 进程启动后设置一个每秒运行一次的定时器
Timer::add(1, function()use($worker){
$time_now = time();
foreach($worker->uidConnections as $connection) {
// 有可能该connection还没收到过消息,则lastMessageTime设置为当前时间
if (empty($connection->lastMessageTime)) {
$connection->lastMessageTime = $time_now;
continue;
}
// 上次通讯时间间隔大于心跳间隔,则认为客户端已经下线,关闭连接
if ($time_now - $connection->lastMessageTime > HEARTBEAT_TIME) {
if(isset($connection->uid))
{
// 连接断开时删除映射
unset($worker->uidConnections[$connection->uid]);
}
$connection->close();
}
}
});
//每天重启进程
Timer::add(86400, function()use($worker)
{
sc('WebSocket服务进程定时重启任务,执行成功!');
Worker::stopAll();
});
};

// 当有客户端发来消息时执行的回调函数
$worker->onMessage = function($connection, $data)
{
global $worker;
// 给connection临时设置一个lastMessageTime属性,用来记录上次收到消息的时间
$connection->lastMessageTime = time();
// 客户端传递的是json数据
if (empty($data)) return;
$message = json_decode($data, true);
if(empty($message)) return;
if(isset($message['cmd'])) {
// 根据类型执行不同的业务
switch($message['cmd'])
{
case 'ping':
return;
case 'login':
return;
case 'sms':
return;
case 'mail':
return;
default:
return;
}
}else{
// 判断当前客户端是否已经验证,即是否设置了uid
if(isset($connection->uid))
{
//上次uid和ticket过期
if (isset($message['uid']) && ($message['uid']!=$connection->uid)) {
unset($worker->uidConnections[$connection->uid]);
}
}
if (isset($message['uid']) && $message['uid']) {
// 没验证的话把第一个包当做uid
$connection->uid = $message['uid'];
if (isset($message['ticket'])) {
//带参数二维码的ticket
$connection->ticket = $message['ticket'];
}
/* 保存uid到connection的映射,这样可以方便的通过uid查找connection,
* 实现针对特定uid推送数据
*/
$worker->uidConnections[$connection->uid] = $connection;
$connection->send($data);
return;
} else {
//不带uid的消息
# code...
}
}
};

// 当有客户端连接断开时
$worker->onClose = function($connection)
{
global $worker;
if(isset($connection->uid))
{
// 连接断开时删除映射
unset($worker->uidConnections[$connection->uid]);
}
};
// 进程关闭时
$worker->onWorkerStop = function($worker)
{
//通知运维人员
//sc('WebSocket服务进程退出,如非定时重启,请检查!');
};
// 针对uid推送数据
function sendMessageByUid($uid, $message)
{
global $worker;
if(isset($worker->uidConnections[$uid]))
{
$connection = $worker->uidConnections[$uid];
$connection->send($message);
return true;
}
return false;
}

// 如果不是在根目录启动,则运行runAll方法
if(!defined('GLOBAL_START'))
{
Worker::runAll();
}

##前端页面关键代码
<!DOCTYPE html> 
<html>
<head>
<meta charset="UTF-8" />
<title>微信公众号模板消息通知Token申请页 - 大卫科技blog www.iyuu.cn</title>
<meta name="keywords" content="大卫科技blog,www.iyuu.cn" />
<meta name="description" content="微信公众号模板消息通知Token申请页" />
<meta name="copyright" content="海南大卫电子科技有限公司" />
<meta name="author" content="大卫" />
<script src="https://cdn.bootcss.com/jquery/1.12.4/jquery.min.js"></script>
</head>
<body>
<div id="panel">
<div id="header">
<h1>微信公众号模板消息通知<span>Token申请页</span></h1>
<noscript><h1>你的浏览器不支持 JavaScript,请启用 JavaScript 后访问。</h1></noscript>
<address>制作 by <a href="http://www.iyuu.cn/">大卫科技blog</a></address>
</div>
<div id="token" style="display: none;"></div>
<div id="qrcode">点击下面的按钮,获取微信二维码!</div>
<div id="expire" style="display: none;">请尽快使用手机微信扫码,二维码<span id="dd">120</span>秒后过期。</div>
<a class="J_scanWeixin">获取微信二维码</a>
</div>
<script type="text/javascript">
var ws,ping_t,qrcode_t,expire_t;
var WEB_URL = {
QRCODE_IMG_URL : 'https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=',
wshost : 'wss://www.iyuu.cn:2129', //websocket服务器地址
};
// 连接服务器
function connect() {
ws = new WebSocket(WEB_URL.wshost);
ws.onopen = function(e) {
console.log(ws);
console.log("Server onOpen",e);
ping_t = setInterval(function(){
ws.send('{"cmd":"ping"}');
console.log("ping Server");
}, 30000);
};
ws.onmessage = onmessage;
ws.onclose = function(e) {
console.log("Server onClose",e.data);
//关闭定时器
if (typeof ping_t !="undefined")
{
clearInterval(ping_t);
console.log("clearInterval ping_t");
}
if (typeof qrcode_t !="undefined")
{
clearInterval(qrcode_t);
console.log("clearInterval qrcode_t");
}
};
ws.onerror = function(e) {
connect();
console.log("Server onError",e.data);
};
}

function onmessage(e)
{
var timestamp = new Date().getTime();
var data = JSON.parse(e.data); //JSON.parse() 将 JSON字符串转换为对象。
if (typeof data.cmd != 'undefined')
{
switch(data.cmd){
case 'login':
window.location='/admin/login.php?token='+data.token;
break;
case 'scan':
console.log('Server Cmd scan',e.data);
break;
case 'bind':
console.log('Server Cmd bind',e.data);
break;
default: //服务器下发其他指令
console.log('Server Cmd?',e.data);
break;
}
}else{
if (typeof data.token != 'undefined')
{
clearInterval(expire_t);
clearInterval(qrcode_t);
$("#token").html("<h3>您的Token是:"+ data.token +"</h3><br /><h3>请求URL是:https://www.iyuu.cn/"+ data.token +".send</h3>");
$("#token").show();
$("#qrcode").hide();
$("#expire").hide();
$(".J_scanWeixin").hide();
}
}
console.log('收到Server消息',e.data);
}
connect();
//dom载入完毕执行
$(function(){
//点击按钮,显示二维码
$('.J_scanWeixin').click(function(){
if (ws.readyState == 1)
{
$.get("/qrcode",function(ret){
ws.send(ret); //发送uid
var data = JSON.parse(ret);
$("#qrcode").html("<img class='' src='"+ WEB_URL.QRCODE_IMG_URL + escape(data.ticket) +"' width='375' height='375' />");
$(".J_scanWeixin").hide(); //隐藏获取二维码按钮
$("#qrcode").show();
$("#expire").show(); //显示倒计时
//扫码提示
qrcode_t = setTimeout(function(){
$("#qrcode").hide();
$("#expire").hide();
$(".J_scanWeixin").show();
}, data.expire_seconds*1000);

var dd = data.expire_seconds;
expire_t = setInterval(function(){
if(dd <=1){
clearInterval(expire_t);
}
dd--;
$("#dd").html("<b>"+ dd +"</b>");
}, 1000);
});
}else{
$("#qrcode").html("<b>Websocker链接失败,请刷新页面重试!</b>");
$(".J_scanWeixin").hide(); //隐藏获取二维码按钮
}
});
});
</script>
</body>
</html>

#执行方法:
 
    /磁盘/路径/php /路径/start_wss.php start -d