Elasticsearch-PHP 中文文档 选择器

ulysses · 2021-05-20 12:50:02 · 热度: 20

选择器

连接池维护连接链表,并决定连接节点何时从活跃状态转换为消亡状态(反之亦然)。可是,选择哪个连接是没有逻辑性的。这个工作属于选择器类。

选择器的任务是从提供的连接列表中返回单个连接。和连接池一样,这里有几个实现好的选择器可供选择。

RoundRobinSelector (默认)

这个选择器通过轮询调度的方式来返回链接。例如在第一次请求中选择节点 1,第二次请求中选择节点 2,等等。这确保集群中的节点平均负担流量。轮询调度是基于每一个请求来执行的(例如,一个 PHP 脚本的所有请求轮流发送到不同的节点中)。

RoundRobinSelector 是默认选择器, 如果你想明确地配置该选择器,可以这么做:

$client = ClientBuilder::create()
            ->setSelector('\Elasticsearch\ConnectionPool\Selectors\RoundRobinSelector')
            ->build();

注意:要通过命名空间加类型的方式来指定选择器。

StickyRoundRobinSelector

这个选择器比较『任性』,它更喜欢重用同一个连接。例如,在第一个请求中选择节点 1,选择器会重用节点 1 来发送随后的请求,直到节点请求失败。在节点 1 请求失败后,选择器会轮询至下一个可用节点,然后一直重用这个节点。

对许多 PHP 脚本来说,这是一个理想的策略。由于 PHP 脚本是无共享架构且会快速退出,为每个请求创建新连接通常是一种次优策略且会引起大量的开销。相反,在脚本运行期间『钟情于』单个节点会更好。

这个选择器会默认会在初始化时把 hosts 随机打乱,但仍然保证集群中的节点平均负担流量。它动态地更改轮询方式,把轮询每个请求变成轮询每个脚本。

如果你使用 [未来模式] ,这种选择器的『任性』行为就不理想了,因为所有并行的请求会发送到集群中的同一个节点而非多个节点。当使用 Future 模式时,默认的 RoundRobinSelector 选择器会更好。

如果你要使用该选择器,你要这样做:

$client = ClientBuilder::create()
            ->setSelector('\Elasticsearch\ConnectionPool\Selectors\StickyRoundRobinSelector')
            ->build();

注意:要通过命名空间加类名的方法来指定选择器。

随机选择器

无论什么状态下,该选择器只返回一个随机的节点。常被用于测试。

你可以这样来使用随机选择器:

$client = ClientBuilder::create()
            ->setSelector('\Elasticsearch\ConnectionPool\Selectors\RandomSelector')
            ->build();

请注意,使用时需要指定类的完整命名空间。

自定义选择器

你可以自定义选择器。但是必须实现 SelectorInterface 类的方法

namespace MyProject\Selectors;

use Elasticsearch\Connections\ConnectionInterface;
use Elasticsearch\ConnectionPool\Selectors\SelectorInterface

class MyCustomSelector implements SelectorInterface
{

    /**
     * 选择一个连接
     *
     * @param array $connections Array of Connection objects
     *
     * @return ConnectionInterface
     */
    public function select($connections)
    {
        // 详细代码
    }

}

你可以通过对象注入或者实例化来使用自定义选择器:

$mySelector = new MyCustomSelector();

$client = ClientBuilder::create()
            ->setSelector($mySelector)                             // object injection
            ->setSelector('\MyProject\Selectors\FirstSelector')    // or namespace
            ->build();

猜你喜欢:
暂无回复。
需要 登录 后方可回复, 如果你还没有账号请点击这里 注册