进程间通讯组件channel

简介

webman/channel 是一个进程间通讯组件，用于进程间通讯及服务器之间通讯。接口采用订阅模式。订阅者订阅某些事件，发布者发布对应事件，实现进程间及服务器间通讯。

安装

composer require webman/channel

使用

安装后会自动启动名为plugin.webman.channel.server的channel服务端，如果你是多服务器通讯，当前服务器不需要channel服务端时，更改 config/plugin/webman/channel/app.php 中的enable为false将其关闭。

注意
不管是进程间通讯还是服务器间通讯，plugin.webman.channel.server只能启动一个，所有需要通讯的channel客户端(包括订阅者和发布者)必须连接同一个channel server。

订阅方式一：独立启动一个进程作为订阅者

新建process/ChannelClient.php

<?php
namespace process;

use Workerman\Timer;
use Webman\Channel\Client;

class ChannelClient
{
    public function __construct()
    {
        Client::connect('127.0.0.1', 2206);
        // 要订阅的事件名称（名称可以为任意的数字和字符串组合）
        $event_name = 'event_xxxx';
        // 订阅某个自定义事件并注册回调，收到事件后会自动触发此回调
        Client::on($event_name, function($event_data) {
            var_dump($event_data);
        });
        // 每秒发布一次事件
        Timer::add(1, function () {
            // 要发布的事件名称
            $event_name = 'event_xxxx';
            // 事件数据（数据格式可以为数字、字符串、数组），会传递给客户端回调函数作为参数
            $event_data = array('some data.', 'some data..');
            // 发布某个自定义事件，订阅这个事件的客户端会收到事件数据，并触发客户端对应的事件回调
            Client::publish($event_name, $event_data);
        });
    }
}

修改 config/process.php

添加以下配置

return [
    // 这里省略了其它配置...

    'channe_client' => [
        'handler' => \process\ChannelClient::class
    ]
];

restart重启终端将会打印订阅到的数据

订阅方式一：在每个webman进程中订阅

创建 app/bootstrap/Channel.php

<?php

namespace app\bootstrap;

use Webman\Bootstrap;
use Webman\Channel\Client;
use Workerman\Timer;

class Channel implements Bootstrap
{
    public static function start($worker)
    {
        // 只给webman进程设置订阅
        if (!$worker || $worker->name !== 'webman') return;
        Client::connect('127.0.0.1', 2206);
        // 要订阅的事件名称（名称可以为任意的数字和字符串组合）
        $event_name = 'event_xxxx';
        // 订阅某个自定义事件并注册回调，收到事件后会自动触发此回调
        Client::on($event_name, function($event_data) {
            var_dump($event_data);
        });
    }
}

配置config/bootstrap.php

return [
    // 这里省略了其它配置...

    app\bootstrap\Channel::class,
];

restart 重启后，进程名为webman的进程将会执行订阅事件。

发布事件

app/controller/Index.php

<?php
namespace app\controller;

use support\Request;
use Webman\Channel\Client;

class Index
{
    public function index(Request $request)
    {
        Client::connect('127.0.0.1', 2206);
        $event_name = 'event_xxxx';
        // 事件数据（数据格式可以为数字、字符串、数组），会传递给客户端回调函数作为参数
        $event_data = array('some data from controller', 'some data..');
        // 发布某个自定义事件，订阅这个事件的客户端会收到事件数据，并触发客户端对应的事件回调
        Client::publish($event_name, $event_data);
        return 'ok';
    }
}

提示
Webman\Channel\Client 可以作为发布者在php-fpm环境中使用(php-fpm环境不支持订阅)，也就是说你可以在传统项目中(Laraval ThinkPHP等)使用Webman\Channel\Client给webman发布事件。