workerman Rabbitmq 是否支持集群配置

wangyw 2023-11-01

問題描述

目前看配置文件無法設(shè)置像phpamqp一樣的集群配置

 998  1 1

1個(gè)回答

walkor 2023-11-01

打賞

phpamqp 是怎么設(shè)置集群的？

wangyw 2023-11-01

public static function create_connection($hosts, $options = array())
{
    if (!is_array($hosts) || count($hosts) < 1) {
        throw new \InvalidArgumentException(
            'An array of hosts are required when attempting to create a connection'
        );
    }

    foreach ($hosts as $hostdef) {
        self::validate_host($hostdef);
        $host = $hostdef['host'];
        $port = $hostdef['port'];
        $user = $hostdef['user'];
        $password = $hostdef['password'];
        $vhost = isset($hostdef['vhost']) ? $hostdef['vhost'] : '/';
        try {
            $conn = static::try_create_connection($host, $port, $user, $password, $vhost, $options);
            return $conn;
        } catch (\Exception $e) {
            $latest_exception = $e;
        }
    }
    throw $latest_exception;
}

wangyw 2023-11-01

創(chuàng)建連接的時(shí)候，傳一個(gè)集群的多維數(shù)組
walkor 2023-11-01

他也是連其中一個(gè)節(jié)點(diǎn)，你可以隨機(jī)連一個(gè)節(jié)點(diǎn)，也可以加一個(gè)負(fù)載均衡，比如nginx
wangyw 2023-11-01

大佬，那就是說workerman-rabbitmq 需要自己加一段隨機(jī)節(jié)點(diǎn)連接嘛？
walkor 2023-11-01

最簡(jiǎn)單的方案。
$hosts = ['ip1:port1', 'ip2:port2']; // 多維數(shù)組
$host = $hosts[array_rand($hosts)]; // 隨機(jī)選其中一個(gè)