環(huán)境說明: 系統(tǒng):Ubuntu14.04 (安裝教程包括CentOS6.5)
PHP版本:PHP-5.5.10
swoole版本:1.7.7-stable
在實際運用場景中,服務(wù)器可能需要監(jiān)聽不同host下的不同端口。比如,一個應(yīng)用服務(wù)器,可能需要監(jiān)聽外網(wǎng)的服務(wù)端口,同時也需要監(jiān)聽內(nèi)網(wǎng)的管理端口。在Swoole中,可以輕松的實現(xiàn)這樣的功能。 Swoole提供了addlistener函數(shù)用于給服務(wù)器添加一個需要監(jiān)聽的host及port,并指定對應(yīng)的Socket類型(TCP,UDP,Unix Socket以及對應(yīng)的IPv4和IPv6版本)。 代碼如下:
$serv = new swoole_server("192.168.1.1", 9501); // 監(jiān)聽外網(wǎng)的9501端口
$serv->addlistener("127.0.0.1", 9502 , SWOOLE_TCP); // 監(jiān)聽本地的9502端口
$serv->start(); // addlistener必須在start前調(diào)用
此時,swoole_server就會同時監(jiān)聽兩個host下的兩個端口。這里要注意的是,來自兩個端口的數(shù)據(jù)會在同一個onReceive中獲取到,這時就要用到swoole的另一個成員函數(shù)connection_info,通過這個函數(shù)獲取到fd的from_port,就可以判定消息的類型。
$info = $serv->connection_info($fd, $from_id);
//來自9502的內(nèi)網(wǎng)管理端口
if($info['from_port'] == 9502) {
$serv->send($fd, "welcome admin\n");
}
//來自外網(wǎng)
else {
$serv->send($fd, 'Swoole: '.$data);
}
所謂熱重啟,就是當服務(wù)器相關(guān)代碼有所變動之后,無需停止服務(wù),而是在服務(wù)器仍然運行的狀態(tài)下更新文件。Swoole通過內(nèi)置的reload函數(shù)以及兩個自定義信號量實現(xiàn)了這一功能。 首先我講解一下Swoole可用的三個信號:SIGTERM,SIGUSR1,SIGUSR2。SIGTERM用于停止服務(wù)器,SIGUSR1用于重啟全部的Worker進程,SIGUSR2用于重啟全部的Task Worker進程。 那要如何實現(xiàn)熱更新代碼文件呢?Swoole的回調(diào)函數(shù)中有這個一個回調(diào)onWorkerStart;該回調(diào)會在Worker進程啟動時被調(diào)用。因此,當swoole_server收到SIGUSR1信號并重啟全部Worker進程后,onWorkerStart就會被調(diào)用。如果在onWorkerStart中require全部的代碼文件,每次onWorkerStart后都會重新require一次php文件,這樣就能實現(xiàn)代碼文件的熱更新。 來看下代碼實現(xiàn):
public function onStart( $serv ) {
cli_set_process_title("reload_master");
}
public function onWorkerStart( $serv , $worker_id) {
require_once "reload_page.php";
Test(); // reload_page.php中定義的一個函數(shù)
}
首先,在onStart回調(diào)函數(shù)中通過php的cli_set_process_title函數(shù)設(shè)置進程名。 在onWorkerStart中,require相關(guān)的php文件。 然后,新建一個reload.sh文件,輸入如下內(nèi)容:
echo "Reloading..."
cmd=$(pidof reload_master)
kill -USR1 "$cmd"
echo "Reloaded"
這樣,就可以通過執(zhí)行這個腳本重啟服務(wù)器了。?點此查看完整源碼
在swoole-1.7.7stable版本中,Timer新增了一個函數(shù)after。該函數(shù)的作用是在指定的時間間隔后執(zhí)行回調(diào)函數(shù),并且只執(zhí)行一次。 這個函數(shù)可以彌補Timer本身做不到或者做起來很難的一些定時工作。 代碼如下:
$serv->after( 1000 , array($this, 'onAfter') , $str );
這里指定在1000ms后,執(zhí)行onAfter回調(diào)函數(shù),函數(shù)參數(shù)為$str。 舉個例子,比如服務(wù)器要求在收到某個請求后,在30S后向所有用戶發(fā)起推送。這樣的需求就可以直接用after函數(shù)來實現(xiàn)。?點此查看完整源碼
未完成
更多建議: