Workerman開發實戰：搭建高效的即時通訊系統-魔扣目錄

Workerman開發實戰：搭建高效的即時通訊系統

引言:
隨著互聯網的快速發展和用戶對實時通信需求的增加，即時通訊系統成為了當下熱門的開發領域。為了滿足各種實時通信需求，我們可以利用PHP開源框架Workerman來搭建高效穩定的即時通訊系統。本文將介紹如何使用Workerman框架來開發一個功能強大的即時通訊系統，并附上代碼示例。

安裝Workerman:
首先，我們需要安裝Workerman框架。在終端中執行以下命令來安裝Workerman:

composer require workerman/workerman

登錄后復制

安裝完成后，我們就可以開始構建即時通訊系統了。

創建服務端:
創建一個新的PHP文件，命名為server.php，用于搭建即時通訊系統的服務端。在server.php文件中，我們需要編寫以下代碼:

<?php
require_once __DIR__.'/vendor/autoload.php';

use WorkermanWorker;

// 創建一個Worker監聽2345端口，使用websocket協議通信
$ws_worker = new Worker("websocket://0.0.0.0:2345");

// 設置進程數
$ws_worker->count = 4;

// 當客戶端連接時
$ws_worker->onConnect = function($connection){
    echo "New connection
";
};

// 當客戶端發送消息時
$ws_worker->onMessage = function($connection, $data){
    foreach($connection->worker->connections as $clientConnection){
        $clientConnection->send($data);
    }
};

// 當客戶端斷開連接時
$ws_worker->onClose = function($connection){
    echo "Connection closed
";
};

// 運行worker
Worker::runAll();

登錄后復制

上述代碼創建了一個Worker對象，監聽2345端口，并使用WebSocket協議通信。當客戶端連接時，輸出”New connection”；當客戶端發送消息時，將消息發送給所有連接的客戶端；當客戶端斷開連接時，輸出”Connection closed”。最后，使用Worker::runAll()方法來運行Worker。

<?php
require_once __DIR__.'/vendor/autoload.php';

use WorkermanWorker;
use WorkermanAutoloader;
use WorkermanConnectionAsyncTcpConnection;

$connect_list = array();

// 當用戶輸入消息時
function onMessage($connect)
{
    // 從終端讀取用戶輸入的消息
    $message = trim(fgets(STDIN));
    
    // 發送消息到服務端
    $connect->send($message);
}

// 創建一個異步TCP連接到服務端
$connect = new AsyncTcpConnection('ws://127.0.0.1:2345');
$connect->onConnect = function($connection){
    echo "Connected to server
";
};
$connect->onMessage = function($connection, $data){
    echo "Received message: ".$data."
";
};
$connect->onClose = function($connection){
    echo "Disconnected from server
";
};

// 運行連接
$connect->connect();

// 將連接對象保存到連接列表中
$connect_list[] = $connect;

// 監聽用戶輸入消息
Worker::addWorker(function(){
    readline_callback_handler_install('', function(){});
    while (true) {
        if (count($GLOBALS['connect_list']) > 0) {
            $read = array_values($GLOBALS['connect_list']);
            $write = null;
            $except = null;
            if (false === ($num_changed_streams = stream_select($read, $write, $except, 1))) {
                continue;
            } elseif ($num_changed_streams > 0) {
                foreach($read as $connect) {
                    onMessage($connect);
                }
            }
        }
    }
});
Worker::runAll();

登錄后復制

上述代碼創建了一個AsyncTcpConnection對象，連接到服務端的2345端口。當連接成功時，輸出”Connected to server”；當接收到服務端發送的消息時，輸出”Received message: “以及具體的消息內容；當與服務端斷開連接時，輸出”Disconnected from server”。同時，監聽用戶輸入的消息，并通過連接對象發送到服務端。

運行即時通訊系統:
在終端中，分別執行以下命令來啟動服務端和客戶端: