如何扩展 laravel websockets server (by BeyondCode) 直接触发 laravel 事件？

Question

我研究了很长时间，据我了解，从我的 laravel 基本应用程序来看，BeyondCode 的 websockets 服务器触发的 websocket 事件只是 一种消息传递方式.

消息可以从 laravel 基本应用程序发送到客户端（对消息做出反应）。未实现将来自其他 websocket 客户端的事件发送到 websocket 服务器并且我的 laravel 基本应用程序对其作出反应（触发事件）。

要在我的 laravel 基本应用程序上触发事件，可以使用 webhooks。这是对通用生成路由的标准 http 请求。

我理解的对吗？

为什么我的 laravel 基本应用程序无法接收 messages/events 的 websocket 服务器？为什么在这种情况下我应该只使用一个方向的 websockets？

我还是laravel新手。我想 change/overwrite 一些 classes，看看 BeyondCode\LaravelWebSockets\WebSockets\Channels\Channel，如果正确的套接字发送正确的事件，使一些通道触发事件。

如何用我自己的 class 覆盖 BeyondCode\LaravelWebSockets\WebSockets\Channels\Channel class 而不会弄乱 BeyondCode 的 websocket 包？我不想碰供应商的东西。

websocket 服务器是完全独立的还是我可以从服务器 classes 中访问我的基本应用程序？这样做需要注意什么？

Answer 1

您不需要覆盖任何内容，您的 laravel 后端将向 websockets 服务器发送一个事件，websockets 服务器将在相应的通道中将事件发送回您的前端

Answer 2

您可以将库复制到您的项目目录中，并在您的 composer.json:

中设置路径

    "repositories": [
        {
            "type": "path",
            "url": "path-to-the-copy-of-the-library"
        }
    ],

或者您可以创建另一个存储库并分叉库并再次编辑 composer.json:

    "repositories": [
        {
            "type": "vcs",
            "url": "URL-to-your-repository"
        }
    ],

确保您有要求中的库：

    "require": {
        "beyondcode/laravel-websockets": "*",
    }

然后运行composer install

您可以在此处找到更多信息或不同的解决方案： https://getcomposer.org/doc/05-repositories.md

Answer 3

需要一些时间来解决这个问题，但现在我找到了对供应商代码覆盖最少的答案。

感兴趣的文件位于 Channels 文件夹下：

|-- laravel-websockets
|   |-- src
|   |   |-- WebSockets
|   |   |   |-- Channels
|   |   |   |   |-- ChannelManagers
|   |   |   |   |-- ArrayChannelManager.php
|   |   |   |-- Channel.php
|   |   |   |-- ChannelManager.php
|   |   |   |-- PresenceChannel.php
|   |   |   |-- PrivateChannel.php

在 Channel.php、PresenceChannel.php 和 PrivateChannel.php 中处理所有与推送服务器相关的事件。比如，订阅和发送消息。 class ArrayChannelManager 控制 class 用于 PrivateChannel、PresenceChannel 和 Channel。

Laravel-websockets 让您可以为您的项目使用自己的频道管理器，在 /config/websockets.php -> 'channel_manager'.

中指定

为了向推送服务器事件添加 Laravel 事件，我重载了 ArrayChannelManager 和 PrivateChannel（如果需要，您也可以重载其他通道）并添加了 Laravels queued事件。在 /config/websockets.php 中，我将重载的 class 用作 channel_manager。

/config/websockets.php:

'channel_manager' => \App\Lib\Overwrite\LaravelWebsockets\ArrayChannelManager::class,

我重载的 ArrayChannelManager：

<?php

namespace App\Lib\Overwrite\LaravelWebsockets;

use BeyondCode\LaravelWebSockets\WebSockets\Channels\Channel;
use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager;
use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManagers\ArrayChannelManager as ArrayChannelManagerBase;
use BeyondCode\LaravelWebSockets\WebSockets\Channels\PresenceChannel;
use App\Lib\Overwrite\LaravelWebsockets\PrivateChannel;
use Illuminate\Support\Arr;
use Illuminate\Support\Str;
use Ratchet\ConnectionInterface;

class ArrayChannelManager extends ArrayChannelManagerBase
{

    protected function determineChannelClass(string $channelName): string
    {
        if (Str::startsWith($channelName, 'private-')) {
            return PrivateChannel::class;
        }

        if (Str::startsWith($channelName, 'presence-')) {
            return PresenceChannel::class;
        }

        return Channel::class;
    }
    
    
};

在我超载的 PrivateChannel 文件中，我将 MyPusherLaravelEvent 挂接到推送器订阅事件：

<?php

namespace App\Lib\Overwrite\LaravelWebsockets;

use BeyondCode\LaravelWebSockets\WebSockets\Channels\PrivateChannel as PrivateChannelBase;
use Ratchet\ConnectionInterface;
use stdClass;

class PrivateChannel extends PrivateChannelBase
{
    public function subscribe(ConnectionInterface $connection, stdClass $payload)
    {
        parent::subscribe($connection, $payload);
        \App\Events\MyPusherLaravelEvent::dispatch($this->channelName);
    }
}

使用 Laravels 排队事件将事件处理与推送服务器分开很重要。 https://laravel.com/docs/8.x/events#queued-event-listeners

您还可以将事件挂接到 Channel::broadcast... 函数，然后解析内容以对服务器的某些客户端命令作出反应。

以通用方式重载函数，因此可以在不破坏重载的情况下更新供应商代码。

如何扩展 laravel websockets server (by BeyondCode) 直接触发 laravel 事件？

How to extend laravel websockets server (by BeyondCode) to directly trigger laravel events?

php

laravel

websocket

pusher