发表新帖

会不会始终只有一个进程在处理消息？在addProcess里sendMessage，会把消息发到哪个进程？

{{{php
        $server = new Server('0.0.0.0', env('TASK_CLIENT_PORT'));
        $server->set([
            'worker_num' => 4,
        ]);
        $server->on('WorkerStart', [$this, 'onWorkerStart']);
        $server->on('Open', [$this, 'onOpen']);
        $server->on('Message', [$this, 'onMessage']);
        $server->on('PipeMessage', [$this, 'onPipeMessage']);
        /*
         * 增加一个子进程订阅redis消息
         */
        $server->addProcess(new Process(function () use ($server) {
            $this->subscribeProcess($server);
        }));
        $server->start();
}}}

{{{php
    protected function subscribeProcess(Server $server)
    {
        $redis = new Redis([
            'database' => config('database.redis.task.database'),
        ]);

/*
         * 转发redis订阅消息到主进程
         */
        $redis->on('Message', function ($redis, $message) use ($server) {
            $server->sendMessage(json_encode($message), $server->worker_id);
        });

$redis->connect(env('REDIS_HOST'), env('REDIS_PORT'), function ($redis, $connected) {
            if ($connected) {
                $redis->psubscribe('task-*');
            } else {
                throw new Exception($redis->errMsg);
            }
        });
    }
}}}

发布于7年前 · 1 次浏览 · 来自提问

Yandere.

{{{php
    protected function subscribeProcess(Server $server)
    {
        $redis = new Redis([
            'database' => config('database.redis.task.database'),
        ]);

登录后参与评论

2019-04-14

BING