Ⅰ php workman心跳客户端关闭,服务端心跳代码不执行
怎么会不执行呢?
心跳的机制就是检测链接状态的。客户端关闭链接之后,正常workman 是可以监听到 客户断开了 ,如果出现网络原因。监听不到,就需要心跳包进行校检。workman 官方的心跳实例就是 检测客户端每个链接最后收发的时间。用定时器定期执行。如果在链接最后的时间超过规定的时间,就在总链接里面关闭掉这个链接。这样也就是 需要客户端定期发送一个心跳包。
js 的话用setinterval 周期一定要小于 服务端的心跳检测的周期。至于发送的数据随你自己的喜好了
Ⅱ php workerman怎么用
使用Gearman、Swoole扩展Gearman是一个具有php扩展的分布式异步处理框架,能处理大批量异步任务;Swoole最近很火,有很多异步方法,使用简单。(尘缘注:号称重新定义PHP,把NodeJS喷得体无完肤。Swoole工具虽好,却感觉是扩展本身跟NodeJS没可比性)
Ⅲ php中的swoole和workman比较。哪个socket长连接性能高
一.服务器端:
1. 编辑server.php文件内容如下:
<?php
$reqs=array(); //保持客户端的长连接在这个数组里
$serv = new swoole_websocket_server("192.168.2.115", 9502);
//如下可以设置多端口监听
//$server = new swoole_websocket_server("0.0.0.0", 9501, SWOOLE_BASE);
//$server->addlistener('0.0.0.0', 9502, SWOOLE_SOCK_UDP);
//$server->set(['worker_num' => 4]);
$serv->on('Open', function($server, $req) {
global $reqs;
$reqs[]=$req->fd;
echo "connection open: ".$req->fd."\n";
var_mp(count($reqs));//输出长连接数
});
$serv->on('Message', function($server, $frame) {
global $reqs;
echo "message: ".$frame->data."\n";
foreach($reqs as $fd){
$server->push($fd, $frame->data);
}
});
$serv->on('Close', function($server, $fd) {
echo "connection close: ".$fd."\n";
});
$serv->start();
2. 启动上面实现的websocket服务代码
[songaimin@localhost Tests]$/usr/bin/php server.php1
客户端-同事打开两个浏览器模拟多client:
3. 在浏览器console里运行:
var wsl= 'ws://192.168.2.115:9502'
ws = new WebSocket(wsl);//新建立一个连接
//如下指定事件处理
ws.onopen = function(){ws.send('Test!'); };
ws.onmessage = function(evt){console.log(evt.data);/*ws.close();*/};
ws.onclose = function(evt){console.log('WebSocketClosed!');};
ws.onerror = function(evt){console.log('WebSocketError!');}; 1234567
4. 在任意浏览器console里手动执行:
ws.send(888);
//看每个浏览器的内容console输出应该是一样的就实验在成功了
ws.close();//关闭连接
Ⅳ 什么是workerman
workerman是一个高性能的PHP socket 服务器框架,workerman基于PHP多进程以及libevent事件轮询库,PHP开发者只要实现一两个接口,便可以开发出自己的网络应用,例如Rpc服务、聊天室服务器、手机游戏服务器等。
workerman的目标是让PHP开发者更容易的开发出基于socket的高性能的应用服务,而不用去了解PHP socket以及PHP多进程细节。 workerman本身是一个PHP多进程服务器框架,具有PHP进程管理以及socket通信的模块,所以不依赖php-fpm、nginx或者apache等这些容器便可以独立运行
Ⅳ workerman 能在thinkphp的框架上使用吗
workerman 能在thinkphp的框架上使用
$Gateway = new OrgUtilGateway('127.0.0.1:5136');
$Gateway->sendToUid(1021,json_encode(array()));
下载workerman, 放入thinkphp,注意与Home平级,就把workerman当做是一个模块。
进入Home/Controller目录,新建WorkermanController.class.php
workerman和thinkphp完美结合使用源码
直接上源码,这里我是以守护进程方式运行的,调试的话,可以去掉daemonize = true 这行.
<?php
namespace AdminController;
use WorkermanWorker;
/**
* 用户信息查询
*/
class WorkermanController{
/**
* 用户信息查询
*/
public function index(){
if(!IS_CLI){
die("access illegal");
}
require_once APP_PATH.'Workerman/Autoloader.php';
// 每个进程最多执行1000个请求
define('MAX_REQUEST', 1000);
Worker::$daemonize = true;//以守护进程运行
Worker::$pidFile = '/data/wwwlogs/CMSWorker/workerman.pid';//方便监控WorkerMan进程状态
Worker::$stdoutFile = '/data/wwwlogs/CMSWorker/stdout.log';//输出日志, 如echo,var_mp等
Worker::$logFile = '/data/wwwlogs/CMSWorker/workerman.log';//workerman自身相关的日志,包括启动、停止等,不包含任何业务日志
$worker = new Worker('text://172.16.0.10:10024');
$worker->name = 'CMSWorker';
$worker->count = 2;
//$worker->transport = 'udp';// 使用udp协议,默认TCP
$worker->onWorkerStart = function($worker){
echo "Worker starting... ";
};
$worker->onMessage = function($connection, $data){
static $request_count = 0;// 已经处理请求数
var_mp($data);
$connection->send("hello");
/*
* 退出当前进程,主进程会立刻重新启动一个全新进程补充上来,从而完成进程重启
*/
if(++$request_count >= MAX_REQUEST){// 如果请求数达到1000
Worker::stopAll();
}
};
$worker->onBufferFull = function($connection){
echo "bufferFull and do not send again ";
};
$worker->onBufferDrain = function($connection){
echo "buffer drain and continue send ";
};
$worker->onWorkerStop = function($worker){
echo "Worker stopping... ";
};
$worker->onError = function($connection, $code, $msg){
echo "error $code $msg ";
};
// 运行worker
Worker::runAll();
}
}
修改Workerman/Worker.php源码,找到parseCommand()方法,workerman版本3.3.2的话,在586行,修改命令行检测语法:
protected static function parseCommand()
{
global $argv;
// Check argv;
$start_file = $argv[0];
if (!isset($argv[2])) {
exit("Usage: php yourfile.php Controller/Action {start|stop|restart|reload|status|kill} ");
}
// Get command.
$command = trim($argv[2]);
$command2 = isset($argv[3]) ? $argv[3] : '';
.....
}
OK,此时大功告成。
Linux命令行下运行,注意,此处要切换到thinkphp根目录下面
/usr/local/php/bin/php index.php Workerman/index start
查看运行状态:
/usr/local/php/bin/php index.php Workerman/index status
此处命令行可以放入全局变量中,直接以php运行
Ⅵ thinkphp 怎么获取workerman进程连接数
可以,你把代表按tp格式放进去就可以了,不过workman主依赖socket服务器的,tp主依赖web服务器的,其实两者没必要合在一块,又不好维护 更多内容,可以去后盾人学习些相关的名师录制视频。
Ⅶ php(workerman)如何读取十六进制数据,所见即所得的
换不同版本的浏览器。。一边用 IE 一边用火狐之类的。。另外,如果你用 SESSION 制作的身份验证。IE 都可以双开。。不过要分别从桌面IE图标点进。不能用新建标签页。新建标签页算是同一浏览器会话。
Ⅷ php workerman 多少人在线
不低于5000人,但是准要还是取决于你的服务器。workerman采用socket框架,能有效解网络堵塞问题。
Ⅸ php workerman 不用提供客户端ip吗
Workerman提供了全局变量$_SERVER
其中$_SERVER['REMOTE_ADDR']可获得到客户端IP,$_SERVER['REMOTE_PORT']可获得到客户端端口。
建议还是先看完视频教程,现在Workerman的视频教程免费了。
如有疑问,欢迎追问。
Ⅹ workerman 平滑重启有什么用
workerman 能在thinkphp的框架上使用
$Gateway = new \Org\Util\Gateway('127.0.0.1:5136');
$Gateway->sendToUid(1021,json_encode(array()));
下载workerman, 放入thinkphp,注意与Home平级,就把workerman当做是一个模块。
进入Home/Controller目录,新建WorkermanController.class.php
workerman和thinkphp完美结合使用源码
直接上源码,这里我是以守护进程方式运行的,调试的话,可以去掉daemonize = true 这行.
<?php
namespace Admin\Controller;
use Workerman\Worker;
/**
* 用户信息查询
*/
class WorkermanController{
/**
* 用户信息查询
*/
public function index(){
if(!IS_CLI){
die("access illegal");
}
require_once APP_PATH.'Workerman/Autoloader.php';
// 每个进程最多执行1000个请求
define('MAX_REQUEST', 1000);
Worker::$daemonize = true;//以守护进程运行
Worker::$pidFile = '/data/wwwlogs/CMSWorker/workerman.pid';//方便监控WorkerMan进程状态
Worker::$stdoutFile = '/data/wwwlogs/CMSWorker/stdout.log';//输出日志, 如echo,var_mp等
Worker::$logFile = '/data/wwwlogs/CMSWorker/workerman.log';//workerman自身相关的日志,包括启动、停止等,不包含任何业务日志
$worker = new Worker('text://172.16.0.10:10024');
$worker->name = 'CMSWorker';
$worker->count = 2;
//$worker->transport = 'udp';// 使用udp协议,默认TCP
$worker->onWorkerStart = function($worker){
echo "Worker starting...\n";
};
$worker->onMessage = function($connection, $data){
static $request_count = 0;// 已经处理请求数
var_mp($data);
$connection->send("hello");
/*
* 退出当前进程,主进程会立刻重新启动一个全新进程补充上来,从而完成进程重启
*/
if(++$request_count >= MAX_REQUEST){// 如果请求数达到1000
Worker::stopAll();
}
};
$worker->onBufferFull = function($connection){
echo "bufferFull and do not send again\n";
};
$worker->onBufferDrain = function($connection){
echo "buffer drain and continue send\n";
};
$worker->onWorkerStop = function($worker){
echo "Worker stopping...\n";
};
$worker->onError = function($connection, $code, $msg){
echo "error $code $msg\n";
};
// 运行worker
Worker::runAll();
}
}
修改Workerman/Worker.php源码,找到parseCommand()方法,workerman版本3.3.2的话,在586行,修改命令行检测语法:
protected static function parseCommand()
{
global $argv;
// Check argv;
$start_file = $argv[0];
if (!isset($argv[2])) {
exit("Usage: php yourfile.php Controller/Action {start|stop|restart|reload|status|kill}\n");
}
// Get command.
$command = trim($argv[2]);
$command2 = isset($argv[3]) ? $argv[3] : '';
.....
}
OK,此时大功告成。
Linux命令行下运行,注意,此处要切换到thinkphp根目录下面
/usr/local/php/bin/php index.php Workerman/index start
查看运行状态:
/usr/local/php/bin/php index.php Workerman/index status
此处命令行可以放入全局变量中,直接以php运行