workerman中后端消息如何实时推送至前端

发布时间：2023-05-18 08:17:31

Workerman是一个高性能的PHP socket框架，可以实现实时推送消息至前端。前端可以通过Websocket或者Http长连接来实现实时推送，而后端可以使用Workerman的各种类库来推送消息。本文将介绍如何使用workerman实现后端实时推送消息至前端。

在使用workerman进行实时消息推送之前，需要先安装workerman。可以通过composer来安装workerman，在composer.json文件中加入如下代码：

"require": {
    "workerman/workerman": "~3.4"
}

然后执行命令composer install来安装workerman。

接下来，我们需要在后端代码中实现实时消息推送。

首先，我们需要启动workerman服务。新建一个php文件websocket_server.php，内容如下：

use Workerman\Worker;
use Workerman\WebServer;
use Workerman\Protocols\Websocket;
use Workerman\Connection\TcpConnection;

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

$ws_worker = new Worker('websocket://0.0.0.0:8000');

$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
";
};

$ws_worker->count = 1;

Worker::runAll();

在上述代码中，我们使用workerman的Worker类来创建websocket服务。其中，websocket://0.0.0.0:8000表示监听8000端口的Websocket服务。$ws_worker->onConnect表示当一个客户端连接时会触发这个回调函数，$ws_worker->onMessage表示当客户端向服务端发送消息时会触发这个回调函数，$ws_worker->onClose表示当客户端断开连接时会触发这个回调函数。

在$ws_worker->onMessage回调函数中，我们通过循环遍历所有连接并发送消息到每个连接中。

接下来，我们需要写一个前端页面来接收实时消息。在前端页面中，我们可以使用Websocket来接收服务端推送的消息。新建一个html文件websocket_client.html，内容如下：

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>Websocket Client</title>
</head>
<body>
    <div>
        <textarea id="message-list" style="width: 100%; height: 200px;"></textarea>
        <input type="text" id="message" style="width: 100%;"">
        <button onclick="send()">Send</button>
    </div>

    <script>
        var socket = new WebSocket("ws://localhost:8000");

        socket.onopen = function(event) {
            console.log("Websocket connection opened.");
        };

        socket.onmessage = function(event) {
            var data = JSON.parse(event.data);
            console.log("Websocket message received: " + JSON.stringify(data));
            var messageList = document.getElementById("message-list");
            messageList.value += data.message + "
";
        };

        socket.onclose = function(event) {
            console.log("Websocket connection closed.");
        };

        function send() {
            var input = document.getElementById("message");
            var message = input.value;
            var data = { message: message };
            console.log("Sending message: " + JSON.stringify(data));
            socket.send(JSON.stringify(data));
            input.value = "";
        }
    </script>
</body>
</html>

在上述代码中，我们通过WebSocket连接到服务端的websocket服务，并通过socket.onmessage事件来接收服务端发送的消息。当接收到消息时，将消息显示在页面上。

当页面准备好后，我们可以通过命令行启动websocket服务，进入终端，输入如下命令启动服务：

$ php websocket_server.php start

然后在浏览器中打开websocket_client.html文件，在输入框中输入消息并点击发送按钮，即可在文本框中看到服务端发送的实时消息。

总结：

在使用workerman实现后端实时推送消息至前端时，我们可以通过workerman的websocket服务实现，需要在后端代码中启动websocket服务并接收客户端发送的消息，在前端页面中使用Websocket来接收服务端推送的消息。通过这种方式，我们可以实现实时的消息推送，极大地提高了应用的实时性能。