hrjy 29dfd4aa99 commit | před 2 roky | |
---|---|---|
.. | ||
src | před 2 roky | |
test | před 2 roky | |
README.md | před 2 roky | |
composer.json | před 2 roky |
基于订阅的多进程通讯组件,用于workerman进程间通讯或者服务器集群通讯,类似redis订阅发布机制。基于workerman开发。
use Workerman\Worker;
$channel_server = new Channel\Server('0.0.0.0', 2206);
if(!defined('GLOBAL_START'))
{
Worker::runAll();
}
```php use Workerman\Worker;
$worker = new Worker(....); $worker->onWorkerStart = function() {
// Channel客户端连接到Channel服务端
Channel\Client::connect('<Channel服务端ip>', 2206);
// 要订阅的事件名称(名称可以为任意的数字和字符串组合)
$event_name = 'event_xxxx';
// 订阅某个自定义事件并注册回调,收到事件后会自动触发此回调
Channel\Client::on($event_name, function($event_data){
var_dump($event_data);
});
}; $worker->onMessage = function($connection, $data) {
// 要发布的事件名称
$event_name = 'event_xxxx';
// 事件数据(数据格式可以为数字、字符串、数组),会传递给客户端回调函数作为参数
$event_data = array('some data.', 'some data..');
// 发布某个自定义事件,订阅这个事件的客户端会收到事件数据,并触发客户端对应的事件回调
Channel\Client::publish($event_name, $event_data);
};
if(!defined('GLOBAL_START')) {
Worker::runAll();
} ````