Ⅰ 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運行