|
導讀網頁的本質就是超級文本標記語言，通過結合使用其他的Web技術（如：腳本語言、公共網關接口、組件等），可以創造出功能強大的網頁。因而，超級文本標記語言是萬維網（Web）編程的基礎，也就是說萬維網是建立... 網頁的本質就是超級文本標記語言，通過結合使用其他的Web技術（如：腳本語言、公共網關接口、組件等），可以創造出功能強大的網頁。因而，超級文本標記語言是萬維網（Web）編程的基礎，也就是說萬維網是建立在超文本基礎之上的。超級文本標記語言之所以稱為超文本標記語言，是因為文本中包含了所謂“超級鏈接”點。 本篇文章給大家帶來的內容是關于php如何使用SwooleTaskWorker實現異步操作Mysql（代碼），有一定的參考價值，有需要的朋友可以參考一下，希望對你有所幫助。在一般的 Server 程序中都會有一些耗時的任務，比如：發送郵件、聊天服務器發送廣播等。如果我們采用同步阻塞的防水去執行這些任務，那么這肯定會非常的慢。 Swoole 的 TaskWorker 進程池可以用來執行一些異步的任務，而且不會影響接下來的任務，很適合處理以上場景。 那么什么是異步任務呢？ 可以從下面的圖示中來簡單了解一下。（來源于網絡，侵刪）
我們上一個 Swoole 的文章介紹了如何創建一個簡單的服務器，并且知道了幾個核心的回調函數的使用方法。 要實現上述的異步處理，只需要增加兩個事件回調即可：onTask 和 onFinish, 這兩個回調函數分別用于執行 Task 任務和處理 Task 任務的返回結果。另外還需要在 set 方法中設置 task 進程數量。 使用示例： class Server
{
private $serv;
public function __construct() {
$this->serv = new swoole_server("0.0.0.0", 9501);
$this->serv->set(array(
'worker_num' => 4,
'daemonize' => false,
'task_worker_num' => 8
));
$this->serv->on('Start', array($this, 'onStart'));
$this->serv->on('Connect', array($this, 'onConnect'));
$this->serv->on('Receive', array($this, 'onReceive'));
$this->serv->on('Close', array($this, 'onClose'));
$this->serv->on('Task', array($this, 'onTask'));
$this->serv->on('Finish', array($this, 'onFinish'));
$this->serv->start();
}
public function onReceive( swoole_server $serv, $fd, $from_id, $data ) {
echo "Get Message From Client {$fd}:{$data}\n";
// 發送任務到Task進程
$param = array(
'fd' => $fd
);
$serv->task( json_encode( $param ) );
echo "繼續處理之后的邏輯\n";
}
public function onTask($serv, $task_id, $from_id, $data) {
echo "This Task {$task_id} from Worker {$from_id}\n";
echo "Data: {$data}\n";
for($i = 0 ; $i < 5 ; $i ++ ) {
sleep(1);
echo "Task {$task_id} Handle {$i} times...\n";
}
$fd = json_decode( $data , true )['fd'];
$serv->send( $fd , "Data in Task {$task_id}");
return "Task {$task_id}'s result";
}
public function onFinish($serv,$task_id, $data) {
echo "Task {$task_id} finish\n";
echo "Result: {$data}\n";
}
public function onStart( $serv ) {
echo "Server Start\n";
}
public function onConnect( $serv, $fd, $from_id ) {
echo "Client {$fd} connect\n";
}
public function onClose( $serv, $fd, $from_id ) {
echo "Client {$fd} close connection\n";
}
}
$server = new Server();通過上述示例可以看到，發起一個異步任務只需要調用 swoole_server 的 task 方法就可以。發送之后會觸發 onTask 回調，可以通過 $task_id 和 $from_id 處理不同進程的不同任務。最后可以通過 return 一個字符串來將執行結果返回給 Worker 進程，Worker 進程通過 onFinish 回調來處理結果。 那么基于上述代碼就可以實現異步操作 mysql。異步操作 mysql 較適合以下場景：
好處：
數據庫的壓力主要在于 mysql 維持的連接數，如果存在 1000 個并發，那么 mysql 就需要建立對應數量的連接。而采用長連接的方式，mysql 的連接一直維持在進程中，減少了創建連接的損耗。可以通過 swoole 開啟多個 task 進程，每一個進程內維持一個mysql 長連接，那么這樣子也可以引申出來 mysql 連接池技術。還需要注意的是，mysql 服務器如果檢測到長時間沒有沒有查詢，則會斷開連接回收資源,所以要有斷線重連的機制。 以下是一個簡單的異步操作 mysql 的示例： 還是以上的代碼，我們只需要修改 onReceive、onTask、onFinish 三個函數。 class Server
{
private $serv;
public function __construct() {
$this->serv = new swoole_server("0.0.0.0", 9501);
$this->serv->set(array(
'worker_num' => 4,
'daemonize' => false,
'task_worker_num' => 8 // task進程數量 即為維持的MySQL連接的數量
));
$this->serv->on('Start', array($this, 'onStart'));
$this->serv->on('Connect', array($this, 'onConnect'));
$this->serv->on('Receive', array($this, 'onReceive'));
$this->serv->on('Close', array($this, 'onClose'));
$this->serv->on('Task', array($this, 'onTask'));
$this->serv->on('Finish', array($this, 'onFinish'));
$this->serv->start();
}
public function onReceive( swoole_server $serv, $fd, $from_id, $data ) {
echo "收到數據". $data . PHP_EOL;
// 發送任務到Task進程
$param = array(
'sql' => $data, // 接收客戶端發送的 sql
'fd' => $fd
);
$serv->task( json_encode( $param ) ); // 向 task 投遞任務
echo "繼續處理之后的邏輯\n";
}
public function onTask($serv, $task_id, $from_id, $data) {
echo "This Task {$task_id} from Worker {$from_id}\n";
echo "recv SQL: {$data['sql']}\n";
static $link = null;
$sql = $data['sql'];
$fd = $data['fd'];
HELL:
if ($link == null) {
$link = @mysqli_connect("127.0.0.1", "root", "root", "test");
}
$result = $link->query($sql);
if (!$result) { //如果查詢失敗
if(in_array(mysqli_errno($link), [2013, 2006])){
//錯誤碼為2013，或者2006，則重連數據庫，重新執行sql
$link = null;
goto HELL;
}
}
if(preg_match("/^select/i", $sql)){//如果是select操作，就返回關聯數組
$data = array();
while ($fetchResult = mysqli_fetch_assoc($result) ){
$data['data'][] = $fetchResult;
}
}else{//否則直接返回結果
$data['data'] = $result;
}
$data['status'] = "OK";
$data['fd'] = $fd;
$serv->finish(json_encode($data));
}
public function onFinish($serv, $task_id, $data) {
echo "Task {$task_id} finish\n";
$result = json_decode($result, true);
if ($result['status'] == 'OK') {
$this->serv->send($result['fd'], json_encode($result['data']) . "\n");
} else {
$this->serv->send($result['fd'], $result);
}
}
public function onStart( $serv ) {
echo "Server Start\n";
}
public function onConnect( $serv, $fd, $from_id ) {
echo "Client {$fd} connect\n";
}
public function onClose( $serv, $fd, $from_id ) {
echo "Client {$fd} close connection\n";
}
}
$server = new Server();以上代碼在 onReceive 時直接接收一條 sql，之后直接發送到 Task 任務中。這個時候下一步的流程緊接著輸出，這里也就體現出了異步。然后 onTask 和 onFinish 分別用來向數據庫發送 sql，處理 task 執行結果。 以上就是php如何使用SwooleTaskWorker實現異步操作Mysql（代碼）的詳細內容，更多請關注php中文網其它相關文章！ 網站建設是一個廣義的術語，涵蓋了許多不同的技能和學科中所使用的生產和維護的網站。 |
溫馨提示：喜歡本站的話，請收藏一下本站！
本站發布的Win7純凈版系統、Win10純凈版和XP純凈版系統僅為個人學習測試使用，請在下載后24小時內刪除，不得用于任何商業用途，否則后果自負，請支持購買微軟正版軟件！
本站所有資源全部來自于網絡資源,如侵犯到您的權益,請及時通知我們(peng896066052@126.com),我們會及時處理.
Copyright © 2018-2020 雨林木風下載站
