发表新帖

会不会始终只有一个进程在处理消息？在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);
            }
        });
    }
}}}

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

Yandere.

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

2019-04-14

BING

微信公众号

热门内容

暂无回复的问答

- CodeGalaxy K3s 轻量集群节点之间如何实现负载均衡

- 关于openssl CURL WARNING swSSL_connect: SSL_connect(fd=69) failed. Error: error:141A318A:SSL routines:tls_process_ske_dhe:dh key too small[1|394]

- 多个模型如何进行事务异常回退？

- websocket开启wss报错

- 协程tcp服务器如何使用多进程？recv()方法接收信息，打印出来的pid一直是同一个。没用使用到多进程啊。