您当前的位置： 首页 > 慢生活 > 程序人生 网站首页程序人生

workerman常用组件-channel分佈式通訊組件-channelClient-publish-實現7端通信

发布时间：2021-12-17 22:57:08编辑：雪饮阅读（）

 publish

(要求Workerman版本>=3.3.0)
void \Channel\Client::publish(string $event_name, mixed $event_data)
发布某个事件，所有这个事件的订阅者会收到这个事件并触发on($event_name, $callback)注册的回调$callback
参数
$event_name
发布的事件名称，可以是任意的字符串。如果事件没有任何订阅者，事件将被忽略。
$event_data
事件相关的数据，可以是数字、字符串或者数组
返回值
void
一個具體的實例場景：
這裏需要一個用戶登錄后就能通知到所有websocket客戶端。
其中用戶登錄用的是http服務。
那麽總結下來我們需要一個http服務端用來實現用戶登錄。
我們需要一個websocket服務端用來提供給所有websocket客戶端都能聯係在一起。
然後我們需要一個channel用來接收事件發佈。
我們每個channel客戶端都訂閲這個channel服務端的某個事件（用戶登錄事件），那麽登錄的http服務在用戶登錄時就發佈用戶登錄事件。
則首先是channelServer.php：

<?php
use Workerman\Worker;
require_once __DIR__ . '/vendor/autoload.php';

// 不传参数默认是监听0.0.0.0:2206
$channel_server = new Channel\Server();

if(!defined('GLOBAL_START'))
{
    Worker::runAll();
}

?>

[root@localhost www.fpm.com]# /usr/local/php734/bin/php -c /usr/local/php734/lib/php/php.ini channelServer.php start

Workerman[channelServer.php] start in DEBUG mode
------------------------------------------ WORKERMAN ------------------------------------------
Workerman version:4.0.22          PHP version:7.3.4
------------------------------------------- WORKERS -------------------------------------------
proto   user            worker           listen                  processes    status
tcp     root            ChannelServer    frame://0.0.0.0:2206    1             [OK]
-----------------------------------------------------------------------------------------------
Press Ctrl+C to stop. Start success.
接下來是wsServer.php：
<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';
// websocket服务端
$worker = new Worker('websocket://0.0.0.0:4236');
$worker->name = 'websocket';
$worker->count = 6;
// 每个worker进程启动时
$worker->onWorkerStart = function($worker)
{
    // Channel客户端连接到Channel服务端
    Channel\Client::connect('127.0.0.1', 2206);
    // 订阅用戶登錄事件，并注册事件回调
    Channel\Client::on('user_login', function($event_data)use($worker){
        // 向当前所有websocket客戶端通知有用戶登錄了系統
        foreach($worker->connections as $connection)
        {
            $connection->send(json_encode($event_data));
        }
    });
};

Worker::runAll();
?>

[root@localhost www.fpm.com]# /usr/local/php734/bin/php -c /usr/local/php734/lib/php/php.ini wsServer.php start

Workerman[wsServer.php] start in DEBUG mode
------------------------------------------- WORKERMAN --------------------------------------------
Workerman version:4.0.22          PHP version:7.3.4
-------------------------------------------- WORKERS ---------------------------------------------
proto   user            worker          listen                      processes    status
tcp     root            websocket       websocket://0.0.0.0:4236    6             [OK]
--------------------------------------------------------------------------------------------------
Press Ctrl+C to stop. Start success.
然後是我們的登陸服務：
login.php：
<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$http_worker = new Worker('http://0.0.0.0:4237');
$http_worker->onWorkerStart = function($http_worker)
{
    //連接到channelServer 2206
    Channel\Client::connect('127.0.0.1', 2206);
};
$http_worker->onMessage = function(TcpConnection $connection, $data)
{
    $event_name = 'user_login';
    $event_data = array('uid'=>123, 'uname'=>'tom');
    //用戶登錄事件發佈
    Channel\Client::publish($event_name, $event_data );
    //返回給http請求端
    $connection->send("login success");
};

Worker::runAll();

[root@localhost www.fpm.com]# /usr/local/php734/bin/php -c /usr/local/php734/lib/php/php.ini login.php start

Workerman[login.php] start in DEBUG mode
----------------------------------------- WORKERMAN -----------------------------------------
Workerman version:4.0.22          PHP version:7.3.4
------------------------------------------ WORKERS ------------------------------------------
proto   user            worker          listen                 processes    status
tcp     root            none            http://0.0.0.0:4237    1             [OK]
---------------------------------------------------------------------------------------------
Press Ctrl+C to stop. Start success.
接下來是我們的websocket客戶端：
<!doctype html>
<html>
<head>
    <script>
        ws = new WebSocket("ws://192.168.43.170:4236");
        ws.onmessage = function(e) {
            console.log("收到服务端的消息：" + e.data);
        };
        ws.onopen=function(){

        };
    </script>
</head>
<body>
    <div class="container">
        <h1>恭喜, 站点创建成功！</h1>
        <h3>这是默认index.html，本页面由系统自动生成</h3>
        <ul>
            <li>本页面在FTP根目录下的index.html</li>
            <li>您可以修改、删除或覆盖本页面</li>
            <li>FTP相关信息，请到“面板系统后台 > FTP” 查看</li>
        </ul>
    </div>
</body>
</html>

我們將這套代碼運行在兩個瀏覽器（或者同瀏覽器標簽頁應該也是可以的哈）。

最後就是我們http客戶端通過登錄接口進行用戶登錄。
[root@localhost www.fpm.com]# elinks http://127.0.0.1:4237 --dump
   login success
然後就可以看到上面這兩個websocket客戶端就都收到了登錄通知！