Workerman development practice: building an efficient instant messaging system

Workerman Development Practice: Building an Efficient Instant Messaging System

Introduction:
With the rapid development of the Internet and the increasing user demand for real-time communication, instant messaging systems have become a popular development field. In order to meet various real-time communication needs, we can use the PHP open source framework Workerman to build an efficient and stable instant messaging system. This article will introduce how to use the Workerman framework to develop a powerful instant messaging system, and attach code examples.

1. Install Workerman:
   First, we need to install the Workerman framework. Execute the following command in the terminal to install Workerman:

   composer require workerman/workerman

   After the installation is completed, we can start building the instant messaging system.

2. Create the server:
   Create a new PHP file named server.php to build the server of the instant messaging system. In the server.php file, we need to write the following code:

<?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();

The above code creates a Worker object, listens to port 2345, and communicates using the WebSocket protocol. When the client is connected, "New connection" is output; when the client sends a message, the message is sent to all connected clients; when the client is disconnected, "Connection closed" is output. Finally, use the Worker::runAll() method to run the Worker.

3. Create client:
   Create a new PHP file named client.php, which is used to build the client of the instant messaging system. In the client.php file, we need to write the following code:

<?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();

The above code creates an AsyncTcpConnection object and connects to the 2345 port of the server. When the connection is successful, "Connected to server" is output; when a message sent by the server is received, "Received message: " and the specific message content are output; when the connection is disconnected from the server, "Disconnected from server" is output. At the same time, the message input by the user is monitored and sent to the server through the connection object.

4. Run the instant messaging system:
   In the terminal, execute the following commands to start the server and client:

   php server.php
   php client.php

   The server and client are executing After that, they will enter the listening state and can send messages to each other. When the server receives a message sent by a client, it broadcasts the message to all connected clients.

Summary:
In this article, we introduced how to use Workerman to develop an efficient instant messaging system. By building the server and client and writing corresponding code, we can achieve real-time communication functions. Workerman provides a complete set of APIs and functions, allowing us to easily build a powerful instant messaging system. I hope this article is helpful to you, thank you for reading!

The above is the detailed content of Workerman development practice: building an efficient instant messaging system. For more information, please follow other related articles on the PHP Chinese website!