导航:首页 > 编程语言 > phpworkman

phpworkman

发布时间:2022-05-17 05:59:32

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

直接上源码,这里我是以守护进程方式运行的,调试的话,可以去掉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运行

阅读全文

与phpworkman相关的资料

热点内容
java聊天窗口 浏览:976
单片机控制阵列led灯 浏览:577
白鹿用的什么APP修图 浏览:499
阿里云轻量应用服务器ssh无法连接 浏览:794
员工福利系统源码 浏览:982
数据加密如何设置 浏览:570
php取余运算 浏览:153
php如何压缩图片大小 浏览:137
编程三阶教程 浏览:983
pdf颜色查看 浏览:469
怎么用指令停用命令方块java 浏览:406
鼠标命令行 浏览:567
如何朗读pdf 浏览:746
压缩机启动后继电器发烫 浏览:405
小学编程项目学习 浏览:557
net编译运行原理 浏览:786
加密电脑的文件拷出来打不开 浏览:366
可达性算法根 浏览:208
ibm的服务器怎么安装系统 浏览:492
pdftomobi在线 浏览:797