Libevent 是一個高性能的事件通知庫，用于編寫可擴展的網絡服務器和客戶端。它提供了一個事件驅動的編程模型，支持多種 I/O 多路復用技術，如 select、poll、epoll 等。在 PHP 中，可以使用 PHP-libevent 擴展來利用 Libevent 的功能。
PHP-libevent 的事件循環機制主要包括以下幾個部分：
創建事件基（Event Base）：
事件基是事件循環的核心，它負責管理所有的事件。你可以使用 event_base_new() 函數創建一個新的事件基。
添加事件：
向事件基中添加事件，可以使用 event_new() 函數創建一個新的事件。然后，使用 event_add() 函數將事件添加到事件基中。你需要指定事件的回調函數、超時時間等參數。
事件回調函數： 當事件被觸發時，事件循環會自動調用相應的回調函數。在回調函數中，你可以處理事件，例如讀取或寫入數據、關閉連接等。
啟動事件循環：
使用 event_base_dispatch() 函數啟動事件循環。這個函數會阻塞，直到所有的事件都被處理完畢。
下面是一個簡單的 PHP-libevent 示例，演示了如何使用事件循環處理 TCP 連接：
<?php
// 創建事件基
$base = event_base_new();
// 創建一個 TCP 服務器
$server = stream_socket_server("tcp://0.0.0.0:8080", $errno, $errstr);
if (!$server) {
echo "Error: $errstr ($errno)\n";
exit(1);
}
// 監聽連接事件
$listener = event_new();
event_set($listener, $server, EV_READ | EV_PERSIST, 'accept_conn', $base);
event_base_set($listener, $base);
event_add($listener);
// 事件回調函數
function accept_conn($socket, $events, $base) {
$conn = stream_socket_accept($socket);
if (!$conn) {
return;
}
// 創建一個新的事件
$event = event_new();
event_set($event, $conn, EV_READ | EV_PERSIST, 'handle_conn');
event_base_set($event, $base);
event_add($event);
}
// 處理連接事件
function handle_conn($socket, $events, $arg) {
$data = fread($socket, 1024);
if (!$data) {
fclose($socket);
return;
}
// 處理數據
$response = "Received: " . $data;
fwrite($socket, $response);
}
// 啟動事件循環
event_base_dispatch($base);
?>
這個示例中，我們創建了一個 TCP 服務器，監聽 8080 端口。當有新的連接請求時，accept_conn 函數會被調用。我們在這個函數中創建一個新的事件，用于處理客戶端發送的數據。當客戶端發送數據時，handle_conn 函數會被調用，我們在這個函數中處理數據并返回響應。最后，我們啟動事件循環，等待事件的觸發。
