棘轮 PHP WAMP - React / ZeroMQ - 特定用户广播

注意：我在这里的回答不包括对 ZeroMQ 的引用，因为我不再使用它了。但是，我相信如果需要，您将能够弄清楚如何使用具有此答案的ZeroMQ。

使用数据硬件

首先，Websocket RFC 和 WAMP 规范声明要订阅的主题必须是字符串。我在这里作弊了一点，但我仍然遵守规范：我正在传递 JSON。

{
    "topic": "subject here",
    "userId": "1",
    "token": "dsah9273bui3f92h3r83f82h3"
}

JSON 仍然是一个字符串，但它允许我传递更多数据来代替"主题"，PHP 在另一端做一个json_decode()很简单。当然，您应该验证是否确实收到了 JSON，但这取决于您的实现。

那么我在这里经过什么，为什么？

• 主题

主题是用户订阅的主题。您可以使用它来决定将哪些数据传递回用户。

• 用户标识

显然是用户的ID。您必须使用下一部分验证此用户是否存在并被允许订阅：

• 令 牌

这应该是一个随机生成的一次性令牌，在您的 PHP 中生成，并传递给 JavaScript 变量。当我说"一次使用"时，我的意思是每次你重新加载页面(并且，通过扩展，在每个HTTP请求上(，你的JavaScript变量应该有一个新令牌。此令牌应根据用户的 ID 存储在数据库中。

然后，一旦发出 websocket 请求，您将令牌和用户 ID 与数据库中的令牌和用户 ID 匹配，以确保用户确实是他们所说的用户，并且他们没有弄乱 JS 变量。

注意：在事件处理程序中，您可以使用$conn->remoteAddress来获取连接的IP，因此如果有人尝试恶意连接，您可以阻止他们(记录他们或其他内容(。

为什么会这样？

它之所以有效，是因为每次有新连接通过时，唯一令牌可确保任何用户都无法访问其他任何人的订阅数据。

服务器

这是我用于运行循环和事件处理程序的方法。我正在创建循环，执行所有装饰器样式的对象创建，并传入我的事件处理程序(我很快就会介绍(以及其中的循环。

$loop = Factory::create();
new IoServer(
    new WsServer(
        new WampServer(
            new EventHandler($loop) // This is my class. Pass in the loop!
        )
    ),
    $webSock
);
$loop->run();

事件处理程序

class EventHandler implements WampServerInterface, MessageComponentInterface
{
    /**
     * @var 'React'EventLoop'LoopInterface
     */
    private $loop;
    /**
     * @var array List of connected clients
     */
    private $clients;
    /**
     * Pass in the react event loop here
     */
    public function __construct(LoopInterface $loop)
    {
        $this->loop = $loop;
    }
    /**
     * A user connects, we store the connection by the unique resource id
     */
    public function onOpen(ConnectionInterface $conn)
    {
        $this->clients[$conn->resourceId]['conn'] = $conn;
    }
    /**
     * A user subscribes. The JSON is in $subscription->getId()
     */
    public function onSubscribe(ConnectionInterface $conn, $subscription)
    {
        // This is the JSON passed in from your JavaScript
        // Obviously you need to validate it's JSON and expected data etc...
        $data = json_decode(subscription->getId());
        
        // Validate the users id and token together against the db values
        
        // Now, let's subscribe this user only
        // 5 = the interval, in seconds
        $timer = $this->loop->addPeriodicTimer(5, function() use ($subscription) {
            $data = "whatever data you want to broadcast";
            return $subscription->broadcast(json_encode($data));
        });
        // Store the timer against that user's connection resource Id
        $this->clients[$conn->resourceId]['timer'] = $timer;
    }
    public function onClose(ConnectionInterface $conn)
    {
        // There might be a connection without a timer
        // So make sure there is one before trying to cancel it!
        if (isset($this->clients[$conn->resourceId]['timer']))
        {
            if ($this->clients[$conn->resourceId]['timer'] instanceof TimerInterface)
            {
                $this->loop->cancelTimer($this->clients[$conn->resourceId]['timer']);
            }
        }
    
        unset($this->clients[$conn->resourceId]);
    }
    /** Implement all the extra methods the interfaces say that you must use **/
}

基本上就是这样。这里的要点是：

• 唯一令牌、用户 ID 和连接 ID 提供确保一个用户看不到其他用户数据所需的唯一组合。
• 唯一令牌意味着，如果同一用户打开另一个页面并请求订阅，他们将拥有自己的连接 ID + 令牌组合，因此同一用户不会在同一页面上拥有双倍的订阅(基本上，每个连接都有自己的个人数据(。

外延

在对数据执行任何操作之前，您应该确保所有数据都经过验证，而不是黑客攻击。使用 Monolog 之类的东西记录所有连接尝试，并在发生任何关键事件时设置电子邮件转发(例如服务器停止工作，因为有人是混蛋并试图入侵您的服务器(。

结语

• 验证一切。这一点我怎么强调都不为过。每个请求都会更改的唯一令牌非常重要。
• 请记住，如果您在每个 HTTP 请求上重新生成令牌，并且在尝试通过 websockets 连接之前发出 POST 请求，则必须在尝试连接之前将重新生成的令牌传回您的 JavaScript(否则您的令牌将无效(。
• 记录所有内容。记录每个连接、询问主题和断开连接的人。独白非常适合此。

要发送给特定用户，您需要路由器-经销商模式而不是 PUB-SUB。《指南》第3章对此作了解释。如果您使用的是 ZMQ v4.0，则安全性在线路级别处理，因此您在应用程序中看不到它。它仍然需要一些工作，除非使用 CZMQ 绑定，该绑定提供身份验证框架 (zauth(。

基本上，要进行身份验证，您需要在 inproc://zeromq.zap.01 上安装一个处理程序，并通过该套接字响应请求。Google ZeroMQ ZAP for the RFC;在核心libzmq/tests/test_security_curve.cpp程序中还有一个测试用例。