一、PHP7源碼安裝和Swoole源碼編譯安裝
1.1 PHP7源碼安裝
1.1.1 獲取源碼與安裝
獲取PHP7源碼：www.php.net
tar -xzvf ... # 解壓命令
./configure --prefix=/home/study/php # 安裝至某個(gè)路徑，提前安裝gcc等
make # 編譯
make install # 安裝
如有報(bào)錯(cuò)：
ext/iconv/.libs/iconv.o: In function `php_iconv_stream_filter_ctor':
/home/king/php-5.2.13/ext/iconv/iconv.c:2491: undefined reference to `libiconv_open'
collect2: ld returned 1 exit status
make: *** [sapi/cli/php] Error 1
[root@test php-5.2.13]# vi Makefile
在安裝 PHP 到系統(tǒng)中時(shí)要是發(fā)生「undefined reference to libiconv_open'」之類的錯(cuò)誤信息，那表示在「./configure 」沒(méi)抓好一些環(huán)境變數(shù)值。錯(cuò)誤發(fā)生點(diǎn)在建立「-o sapi/cli/php」是出錯(cuò)，沒(méi)給到要 link 的 iconv 函式庫(kù)參數(shù)。 解決方法：編輯Makefile 大約77 行左右的地方: EXTRA_LIBS = ..... -lcrypt 在最后加上 -liconv，例如: EXTRA_LIBS = ..... -lcrypt -liconv 然后重新再次 make 即可。
或者用另一種辦法
make ZEND_EXTRA_LIBS='-liconv'
ln -s /usr/local/lib/libiconv.so.2 /usr/lib64/
作者用的第一種辦法解決的,編譯好Makefile后，記得先make clean一下，再make，不然會(huì)報(bào)錯(cuò)
源碼執(zhí)行文件放在：bin目錄下
php -m # 查看 PHP 安裝的擴(kuò)展
1.1.2 簡(jiǎn)化PHP執(zhí)行命令
`alias` 命令=命令的絕對(duì)路徑
linux: ~/.bash_profile
MAC: ./zsh
vim /.bash_profile
alias php=/home/work/soft/php/bin/php # 添加
source /.bash_profile # 注意
**source FileName**
**作用:**在當(dāng)前`bash`環(huán)境下讀取并執(zhí)行`FileName`中的命令。 用于重新執(zhí)行剛修改的初始化文檔，如 `.bash_profile` 和 `.profile` 等等
**注：**該命令通常用命令“`.`”來(lái)替代
**如：**`source /etc/profile` 與 `. /etc/profile`是等效的
拷貝php.ini制作ini文件,修改為php.ini
php -i | grep php.ini # 查找PHP的配置文件
把ini放到該路徑
1.2 Swoole源碼編譯安裝
獲取swoole源碼：https://gitee.com/swoole/swoole.git
phpize是用來(lái)擴(kuò)展php模塊的，通過(guò)phpize可以建立php的外掛模塊,解決沒(méi)有configure問(wèn)題
/usr/local/php/bin/phpize # 在需要執(zhí)行的目錄執(zhí)行這行代碼即可
./configure --with-php-config=/usr/local/php/bin/php-config
make
make install
最后可以在`PHP`的擴(kuò)展目錄中看見(jiàn)`swoole.so` 擴(kuò)展文件
1.3 雙劍合璧，PHP7支持swoole
在`php.ini`文件中添加：`extension=swoole.so`
查看是否添加成功：`php -m`
在`swoole/examples/server`下執(zhí)行`php echo.php`
查看是否執(zhí)行端口：`9501`
mac下可以把-p去掉看結(jié)果
netstat -anp|grep 9501
查看端口號(hào)是否狀態(tài)：
lsof -i :9501
二、玩轉(zhuǎn)網(wǎng)絡(luò)通信引擎(非常重要)
2.1 TCP服務(wù)&TCP客戶端
2.1.1 TCP服務(wù)
Swoole官網(wǎng)文檔：創(chuàng)建TCP服務(wù)器 | 創(chuàng)建UDP服務(wù)器
//創(chuàng)建Server對(duì)象，監(jiān)聽(tīng) 127.0.0.1:9501端口
$serv = new swoole_server("127.0.0.1", 9501);
//swoole_server->set函數(shù)用于設(shè)置swoole_server運(yùn)行時(shí)的各項(xiàng)參數(shù)
$serv->set([
'worker_num' => 6 , // worker進(jìn)程數(shù)，cpu 1-4倍
'max_request' => 10000,
]);
/**
* 監(jiān)聽(tīng)連接進(jìn)入事件
* $fd 客戶端連接的唯一標(biāo)示
* $reactor_id 線程id
*/
$serv->on('connect', function ($serv, $fd, $reactor_id) {
echo "Client: {$reactor_id} - {$fd}-Connect.\n";
});
/**
* 監(jiān)聽(tīng)數(shù)據(jù)接收事件
* $reactor_id = $from_id
*/
$serv->on('receive', function ($serv, $fd, $reactor_id, $data) {
$serv->send($fd, "Server: {$reactor_id} - {$fd}".$data);
});
//監(jiān)聽(tīng)連接關(guān)閉事件
$serv->on('close', function ($serv, $fd) {
echo "Client: Close.\n";
});
//啟動(dòng)服務(wù)器
$serv->start();
**測(cè)試`tcp`服務(wù)器方法：**
netstat -anp | grep 9501通過(guò)
telnet方式登錄遠(yuǎn)程主機(jī):telnet 127.0.0.1 9501-
tcp客戶端腳本查看當(dāng)前
worker進(jìn)程數(shù)：ps -aft | grep tcp_server.php
Tips：為了保證程序執(zhí)行的完整性，當(dāng)修改tcp服務(wù)器腳本后最好設(shè)置平滑重啟worker進(jìn)程
平滑重啟worker進(jìn)程
2.1.2 TCP客戶端
阿里云服務(wù)器巨坑----端口未對(duì)外打開(kāi)?。?！websocket連接不上服務(wù)器，提示Provisional headers are shown
<?php
// 連接 swoole tcp 服務(wù)
$client = new swoole_client(SWOOLE_SOCK_TCP);
if(!$client->connect("127.0.0.1", 9501)) {
echo "連接失敗";
exit;
}
// php cli常量
fwrite(STDOUT, "請(qǐng)輸入消息:");
$msg = trim(fgets(STDIN));
// 發(fā)送消息給 tcp server服務(wù)器
$client->send($msg);
// 接受來(lái)自server 的數(shù)據(jù)
$result = $client->recv();
echo $result;
2.2 HTTP服務(wù)（常用）
$http = new swoole_http_server("0.0.0.0", 8811);
//添加測(cè)試一：獲取參數(shù)并打印出來(lái)
//$http->on('request', function ($request, $response) {
// $response->cookie("singwa",'xsssss', time() + 1800);
// $response->end('sss'.json_encode($request->get));
//});
/**
* https://wiki.swoole.com/wiki/page/783.html
* 配置靜態(tài)文件根目錄，與enable_static_handler配合使用。
* 設(shè)置document_root并設(shè)置enable_static_handler為true后，
* 底層收到Http請(qǐng)求會(huì)先判斷document_root路徑下是否存在此文件，
* 如果存在會(huì)直接發(fā)送文件內(nèi)容給客戶端，不再觸發(fā)onRequest回調(diào)。
*/
$http->set(
[
'enable_static_handler' => true,
'document_root' => "/home/work/hdtocs/swoole_mooc/data",
]
);
$http->on('request', function($request, $response) {
//print_r($request->get);
$content = [
'date:' => date("Ymd H:i:s"),
'get:' => $request->get,
'post:' => $request->post,
'header:' => $request->header,
];
swoole_async_writefile(__DIR__."/access.log", json_encode($content).PHP_EOL, function($filename){
// todo
}, FILE_APPEND);
$response->cookie("singwa", "xsssss", time() + 1800);
$response->end("sss". json_encode($request->get));
});
$http->start();
2.3 WebSocket服務(wù)（重點(diǎn)）
2.3.1 基本概述
`WebSocket`協(xié)議是基于`TCP`的一種新的網(wǎng)絡(luò)協(xié)議。它實(shí)現(xiàn)了瀏覽器與服務(wù)器全雙工（`full-duplex`）通信--`允許服務(wù)器主動(dòng)發(fā)送信息給客戶端`
**為什么需要WebSocket**
-
缺陷：
HTTP的通信只能由客戶端發(fā)起WebSocket特點(diǎn)
- 建立在
TCP協(xié)議之上 - 性能開(kāi)銷小通信高效
- 客戶端可以與任意服務(wù)器通信
- 協(xié)議標(biāo)識(shí)符
wswss - 持久化網(wǎng)絡(luò)通信協(xié)議
2.3.2 案例實(shí)現(xiàn)
2.3.2.1 服務(wù)端實(shí)現(xiàn)
1. 面向過(guò)程：procedure_ws_server.php
$server = new swoole_websocket_server("0.0.0.0", 9912);
//配置靜態(tài)文件根目錄，可選
$server->set(
[
'enable_static_handler' => true,
'document_root' => "/home/wwwroot/www.lingyuan88.com/public/swoole/data",
]
);
//監(jiān)聽(tīng)websocket連接打開(kāi)事件
$server->on('open', 'onOpen');
function onOpen($server, $request) {
print_r($request->fd);
}
// 監(jiān)聽(tīng)ws消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) {
echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
$server->push($frame->fd, "singwa-push-secesss");
});
$server->on('close', function ($ser, $fd) {
echo "client {$fd} closed\n";
});
$server->start();
2. WebSocket服務(wù)優(yōu)化，基礎(chǔ)類庫(kù)面向?qū)ο螅?/code>object_ws_server.php
class Ws {
CONST HOST = "0.0.0.0";
CONST PORT = 9912;
public $ws = null;
public function __construct() {
$this->ws = new swoole_websocket_server(self::HOST, self::PORT);
//配置靜態(tài)文件根目錄，可選
$this->ws->set(
[
'enable_static_handler' => true,
'document_root' => "/home/wwwroot/www.lingyuan88.com/public/swoole/data",
]
);
$this->ws->on("open", [$this, 'onOpen']);
$this->ws->on("message", [$this, 'onMessage']);
$this->ws->on("close", [$this, 'onClose']);
$this->ws->start();
}
/**
* 監(jiān)聽(tīng)ws連接事件
* @param $ws
* @param $request
*/
public function onOpen($ws, $request) {
print_r($request->fd);
}
/**
* 監(jiān)聽(tīng)ws消息事件
* @param $ws
* @param $frame
*/
public function onMessage($ws, $frame) {
echo "ser-push-message:{$frame->data}\n";
$ws->push($frame->fd, "server-push:".date("Y-m-d H:i:s"));
}
/**
* close
* @param $ws
* @param $fd
*/
public function onClose($ws, $fd) {
echo "clientid:{$fd}\n";
}
}
$obj = new Ws();
2.3.2.2 客戶端實(shí)現(xiàn)
ws_client.html
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title></title>
</head>
<body>
<h1>singwa-swoole-ws測(cè)試</h1>
<script>
var wsUrl = "ws://120.77.206.215:9912";
var websocket = new WebSocket(wsUrl);
//實(shí)例對(duì)象的onopen屬性
websocket.onopen = function(evt) {
websocket.send("hello-sinwa");
console.log("conected-swoole-success");
}
// 實(shí)例化 onmessage
websocket.onmessage = function(evt) {
console.log("ws-server-return-data:" + evt.data);
}
//onclose
websocket.onclose = function(evt) {
console.log("close");
}
//onerror
websocket.onerror = function(evt, e) {
console.log("error:" + evt.data);
}
</script>
</body>
</html>
2.3.2.3 測(cè)試
1. 通過(guò)WebSocket靜態(tài)文件目錄測(cè)試
2. 通過(guò)HTTP服務(wù)測(cè)試
2.4 異步Task任務(wù)使用（重點(diǎn)）
使用場(chǎng)景
-
執(zhí)行耗時(shí)的操作（發(fā)送郵件 廣播等）
注意：
投遞異步任務(wù)之后程序會(huì)
繼續(xù)往下執(zhí)行，不會(huì)等待任務(wù)執(zhí)行完后再繼續(xù)向下執(zhí)行
class Ws {
CONST HOST = "0.0.0.0";
CONST PORT = 9912;
public $ws = null;
public function __construct() {
$this->ws = new swoole_websocket_server(self::HOST, self::PORT);
$this->ws->set(
[
'worker_num' => 2,
'task_worker_num' => 2,
]
);
//注冊(cè)Server的事件回調(diào)函數(shù)
$this->ws->on("open", [$this, 'onOpen']);
$this->ws->on("message", [$this, 'onMessage']);
$this->ws->on("task", [$this, 'onTask']);
$this->ws->on("finish", [$this, 'onFinish']);
$this->ws->on("close", [$this, 'onClose']);
$this->ws->start();
}
/**
* 監(jiān)聽(tīng)ws連接事件
* @param $ws
* @param $request
*/
public function onOpen($ws, $request) {
var_dump($request->fd);
}
/**
* 監(jiān)聽(tīng)ws消息事件
* @param $ws
* @param $frame
*/
public function onMessage($ws, $frame) {
echo "ser-push-message:{$frame->data}\n";
// todo 10s
$data = [
'task' => 1,
'fd' => $frame->fd,
];
//投遞異步任務(wù)
//注意：程序會(huì)繼續(xù)往下執(zhí)行，不會(huì)等待任務(wù)執(zhí)行完后再繼續(xù)向下執(zhí)行
$ws->task($data);
//客戶端會(huì)馬上收到以下信息
$ws->push($frame->fd, "server-push:".date("Y-m-d H:i:s"));
}
/**
* @param $serv
* @param $taskId
* @param $workerId
* @param $data
* @return string
*/
public function onTask($serv, $taskId, $workerId, $data) {
print_r($data);
// 耗時(shí)場(chǎng)景 10s
sleep(10);
return "on task finish"; // 告訴worker，并返回給onFinish的$data
}
/**
* @param $serv
* @param $taskId
* @param $data
*/
public function onFinish($serv, $taskId, $data) {
echo "taskId:{$taskId}\n";
echo "finish-data-sucess:{$data}\n";
}
/**
* close
* @param $ws
* @param $fd
*/
public function onClose($ws, $fd) {
echo "clientid:{$fd}\n";
}
}
$obj = new Ws();
三、異步非堵塞IO場(chǎng)景
3.1 異步、阻塞和IO模型（務(wù)必理解）
3.1.1 同步和異步
關(guān)注的是消息通知機(jī)制；
同步：調(diào)用發(fā)出之后
不會(huì)立即返回*，但一旦返回，則返回最終結(jié)果；異步：調(diào)用發(fā)出之后，被調(diào)用方
立即返回消息，但返回的并非最終結(jié)果。被調(diào)用者通過(guò)狀態(tài)、通知機(jī)制等來(lái)通知調(diào)用者，或通過(guò)回調(diào)函數(shù)來(lái)處理結(jié)果；
3.1.2 阻塞(block)和非阻塞(nonblock)
關(guān)注的是調(diào)用者等待被調(diào)用者返回調(diào)用結(jié)果時(shí)的狀態(tài)。
阻塞：
調(diào)用結(jié)果返回之前，調(diào)用者會(huì)被掛起*，調(diào)用者只有在得到返回結(jié)果之后才能繼續(xù)。非阻塞：調(diào)用者在結(jié)果返回之前，不會(huì)被掛起；
3.1.3 IO模型
blocking IO：阻塞式IO
nonblocking IO：非阻塞IO
multiplexing IO：多路復(fù)用IO
signal driven IO：事件驅(qū)動(dòng)式IO
asynchronous IO：異步IO
真正執(zhí)行`IO`過(guò)程的階段是**`內(nèi)核內(nèi)存數(shù)據(jù)`拷貝到`進(jìn)程內(nèi)存`**中
3.2 Swoole異步毫秒定時(shí)器
**`異步`**高精度定時(shí)器，粒度為**毫秒級(jí)**
//每隔2000ms觸發(fā)一次
swoole_timer_tick(2000, function ($timer_id) {
echo "tick-2000ms\n";
});
//3000ms后執(zhí)行此函數(shù)
swoole_timer_after(3000, function () {
echo "after 3000ms.\n";
});
3.3 異步文件系統(tǒng)IO
[Swoole官網(wǎng)文檔：異步文件系統(tǒng)IO](https://wiki.swoole.com/wiki/page/183.html)
3.3.1 異步讀
/**
* 讀取文件
* __DIR__
* 文件不存在會(huì)返回false
* 成功打開(kāi)文件立即返回true
* 數(shù)據(jù)讀取完畢后會(huì)回調(diào)指定的callback函數(shù)。
*/
//函數(shù)風(fēng)格
$result = swoole_async_readfile(__DIR__."/1.txt", function($filename, $fileContent) {
echo "filename:".$filename.PHP_EOL; // \n \r\n
echo "content:".$fileContent.PHP_EOL;
});
//命名空間風(fēng)格
$result = Swoole\Async::readfile(__DIR__."/1.txt", function($filename, $fileContent) {
echo "filename:".$filename.PHP_EOL; // \n \r\n
echo "content:".$fileContent.PHP_EOL;
});
var_dump($result);
echo "start".PHP_EOL;
3.3.2 異步寫(xiě)（如日志）
$http->on('request', function($request, $response) {
$content = [
'date:' => date("Ymd H:i:s"),
'get:' => $request->get,
'post:' => $request->post,
'header:' => $request->header,
];
swoole_async_writefile(__DIR__."/access.log", json_encode($content).PHP_EOL, function($filename){
// todo
}, FILE_APPEND);
$response->end("response：". json_encode($request->get));
});
3.4 異步MySQL詳解
class AsyncMySql {
/**
* @var string
*/
public $dbSource = "";
/**
* mysql的配置
* @var array
*/
public $dbConfig = [];
public function __construct() {
//new swoole_mysql;
$this->dbSource = new Swoole\Mysql;
$this->dbConfig = [
'host' => '127.0.0.1',
'port' => 3306,
'user' => 'root',
'password' => 'test',
'database' => 'test',
'charset' => 'utf8',
];
}
public function update() {}
public function add() {}
/**
* mysql 執(zhí)行邏輯
* @param $id
* @param $username
* @return bool
*/
public function execute($id, $username) {
$this->dbSource->connect($this->dbConfig, function($db, $result) use($id, $username) {
echo "mysql-connect".PHP_EOL;
if($result === false) {
var_dump($db->connect_error);
// todo
}
$sql = "select * from cmf_user where id=1";
//$sql = "update test set `username` = '".$username."' where id=".$id;
// insert into
// query (add select update delete)
$db->query($sql, function($db, $result){
// select => result返回的是 查詢的結(jié)果內(nèi)容
if($result === false) {
// todo
var_dump($db->error);
}elseif($result === true) {// add update delete
// todo
var_dump($db->affected_rows);
}else {
print_r($result);
}
$db->close();
});
});
return true;
}
}
$obj = new AsyncMySql();
$flag = $obj->execute(1, 'singwa-111112');
var_dump($flag).PHP_EOL;
echo "start".PHP_EOL;
3.5 異步Redis
3.5.1 環(huán)境準(zhǔn)備
安裝redis：
下載tar包：
tar -zxvf redis-4.0.14.tar.gz
cd redis-4.0.14
make
之后進(jìn)入./src目錄即可測(cè)試
打開(kāi)redis服務(wù)端./redis-server
打開(kāi)客戶端./redis-cli
swoole使用redis的前置條件
redis服務(wù)hiredis庫(kù)-
編譯
swoole需要加入-enable-async-redis編譯安裝hiredis
使用
Redis客戶端，需要安裝hiredis庫(kù),下載hiredis源碼后，執(zhí)行
make -j
sudo make install
sudo ldconfig//新版本MAC 不需要進(jìn)行此指令
啟用異步Redis客戶端
編譯
swoole時(shí)，在configure指令中加入--enable-async-redis
[root@izwz93ee3z8wdxsujiec2oz swoole]# ./configure --with-php-config=/usr/local/php/bin/php-config --enable-async-redis
make clean
make -j
sudo make install
查看`PHP`的`swoole`擴(kuò)展：`php -m`
查看`hiredis`是否編譯安裝成功：`php --ri swoole`
3.5.2 代碼測(cè)試
$redisClient = new swoole_redis;// Swoole\Redis
$redisClient->connect('127.0.0.1', 6379, function(swoole_redis $redisClient, $result) {
echo "connect".PHP_EOL;
var_dump($result);
// 同步 redis (new Redis())->set('key',2);
/*$redisClient->set('singwa_1', time(), function(swoole_redis $redisClient, $result) {
var_dump($result);
});*/
/*$redisClient->get('singwa_1', function(swoole_redis $redisClient, $result) {
var_dump($result);
$redisClient->close();
});*/
$redisClient->keys('*gw*', function(swoole_redis $redisClient, $result) {
var_dump($result);
$redisClient->close();
});
});
echo "start".PHP_EOL;
