PHP Socket框架如何實現雙向通信

在PHP中，實現Socket雙向通信通常涉及到創建一個TCP服務器和客戶端。以下是一個簡單的示例，展示了如何使用PHP的socket函數來創建一個基本的TCP服務器和客戶端，從而實現雙向通信。

服務器端代碼

<?php
// 創建socket
$server_socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if (!$server_socket) {
    echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
    exit();
}

// 綁定地址和端口
$address = '127.0.0.1';
$port = 8080;
socket_bind($server_socket, $address, $port);

// 監聽連接
socket_listen($server_socket);
echo "Server listening on $address:$port...\n";

while (true) {
    // 接受客戶端連接
    $client_socket = socket_accept($server_socket);
    if (!$client_socket) {
        echo "socket_accept() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
        continue;
    }

    // 讀取客戶端發送的數據
    $data = socket_read($client_socket, 1024, PHP_BINARY_READ);
    echo "Received message: $data\n";

    // 向客戶端發送響應
    $response = "Hello from server!";
    socket_write($client_socket, $response, strlen($response));

    // 關閉連接
    socket_close($client_socket);
}

// 關閉服務器套接字
socket_close($server_socket);
?>

客戶端代碼

<?php
// 創建socket
$client_socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if (!$client_socket) {
    echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
    exit();
}

// 連接到服務器
$address = '127.0.0.1';
$port = 8080;
socket_connect($client_socket, $address, $port);

// 向服務器發送數據
$message = "Hello from client!";
socket_write($client_socket, $message, strlen($message));

// 讀取服務器發送的響應
$response = socket_read($client_socket, 1024, PHP_BINARY_READ);
echo "Received response: $response\n";

// 關閉連接
socket_close($client_socket);
?>

運行步驟

1. 啟動服務器：首先運行服務器端代碼，確保服務器正在監聽指定的地址和端口。
2. 啟動客戶端：然后運行客戶端代碼，連接到服務器并發送消息。
3. 觀察通信：服務器接收到客戶端的消息后，會向客戶端發送響應，客戶端會顯示接收到的響應。

注意事項

• 確保服務器端和客戶端在同一臺機器上運行，或者確保服務器的IP地址正確。
• 根據需要調整端口號。
• 處理錯誤情況，例如連接失敗、讀取/寫入失敗等。

這個示例展示了如何使用PHP的socket函數實現基本的雙向通信。對于更復雜的應用，可能需要考慮使用更高級的庫，如ReactPHP或Amphp，這些庫提供了更強大的功能和更好的錯誤處理。