event-stream在PHP中的最佳实践案例

EventStream 是一个 PHP 库，用于创建实时数据流。它允许您在客户端和服务器之间传输数据，而不需要显式地刷新页面。以下是一个使用 EventStream 的最佳实践案例：

场景：我们将创建一个简单的聊天应用，用户可以在客户端输入消息，服务器将这些消息广播给所有连接的客户端。

1. 首先，安装 EventStream 库：

composer require frozengenesis/eventstream

2. 创建一个名为 server.php 的 PHP 文件，用于设置 EventStream 服务器：

<?php
require 'vendor/autoload.php';

use Frozengenesis\EventStream\EventStream;
use Frozengenesis\EventStream\Message;

$server = new EventStream('tcp://0.0.0.0:8000');

$server->on('connection', function (EventStream $stream) {
    echo "新客户端已连接\n";

    $stream->on('message', function (Message $message) {
        echo "收到消息: {$message->data}\n";
    });

    $stream->on('close', function () {
        echo "客户端已断开连接\n";
    });
});

echo "服务器启动，监听 8000 端口...\n";
$server->run();

3. 创建一个名为 client.php 的 PHP 文件，用于创建 EventStream 客户端并发送和接收消息：

<?php
require 'vendor/autoload.php';

use Frozengenesis\EventStream\EventStream;

$client = new EventStream('tcp://127.0.0.1:8000');

echo "连接到服务器...\n";

$client->on('message', function (Message $message) {
    echo "收到消息: {$message->data}\n";
});

$client->on('open', function () {
    echo "已连接到服务器\n";
    echo "发送消息: Hello, World!\n";
});

$client->on('close', function () {
    echo "已断开与服务器的连接\n";
});

4. 分别运行 php server.php 和 php client.php。现在，您可以在客户端输入消息并查看服务器接收到的消息。其他客户端也可以连接到服务器并接收实时消息。

这个例子展示了如何使用 EventStream 在 PHP 中创建一个简单的实时聊天应用。您可以根据自己的需求扩展此示例，例如添加用户身份验证、私人消息等功能。