добавить несколько конечных точек solr unsing solarium

когда я добавляю несколько серверов solr в качестве конечной точки и использую один клиент солярия для запуска запроса на любом сервере solr; Я добавляю master/slave репликации в solr. на данный момент я пробую, когда сервер для onecore (ведущий или подчиненный) выходит из строя, клиент / солярий должен использовать доступную конечную точку.

Я получаю эту ОШИБКУ:

Message: Solr HTTP error: HTTP request failed, Failed connect to 127.0.0.1:8983; No error

потому что я останавливаю solr на порту 8983, а solr работает на ведомом ядре на порту 9000, в этом случае я ищу подключение к localhost2, если localhost не работает. Это мой код:

$config = array(
         "endpoint" => array("localhost" => array("host"=>"127.0.0.1",
         "port"=>"8983", "path"=>"/solr", "core"=>"master",),
         "localhost2" => array("host"=>"127.0.0.1",
         "port"=>"9000", "path"=>"/solr", "core"=>"slave",)

        ) );

    $client = new Solarium\Client($config);
            $ping = $client->createPing();
            $client->ping($ping,"localhost2");
            $client->getEndpoints();

когда ключ localhost не работает, а ключ localhost2 работает в порту 9000, я получаю эту ошибку Message Solr HTTP: HTTP-запрос не выполнен, не удалось подключиться к 127.0.0.1:8983; Нет ошибок

И вывод $client->getEndpoints();

object(Solarium\Client) {
    [protected] options => array(
        'adapter' => 'Solarium\Core\Client\Adapter\Curl',
        'endpoint' => array(
            'localhost' => array(
                'host' => '*****',
                'port' => '*****',
                'path' => '/solr',
                'core' => 'master'
            ),
            'localhost2' => array(
                'host' => '*****',
                'port' => '*****',
                'path' => '/solr',
                'core' => 'slave'
            )
        )
    )
    [protected] queryTypes => array(
        'select' => 'Solarium\QueryType\Select\Query\Query',
        'update' => 'Solarium\QueryType\Update\Query\Query',
        'ping' => 'Solarium\QueryType\Ping\Query',
        'mlt' => 'Solarium\QueryType\MoreLikeThis\Query',
        'analysis-document' => 'Solarium\QueryType\Analysis\Query\Document',
        'analysis-field' => 'Solarium\QueryType\Analysis\Query\Field',
        'terms' => 'Solarium\QueryType\Terms\Query',
        'suggester' => 'Solarium\QueryType\Suggester\Query',
        'extract' => 'Solarium\QueryType\Extract\Query',
        'get' => 'Solarium\QueryType\RealtimeGet\Query'
    )
    [protected] pluginTypes => array(
        'loadbalancer' => 'Solarium\Plugin\Loadbalancer\Loadbalancer',
        'postbigrequest' => 'Solarium\Plugin\PostBigRequest',
        'customizerequest' => 'Solarium\Plugin\CustomizeRequest\CustomizeRequest',
        'parallelexecution' => 'Solarium\Plugin\ParallelExecution\ParallelExecution',
        'bufferedadd' => 'Solarium\Plugin\BufferedAdd\BufferedAdd',
        'prefetchiterator' => 'Solarium\Plugin\PrefetchIterator',
        'minimumscorefilter' => 'Solarium\Plugin\MinimumScoreFilter\MinimumScoreFilter'
    )
    [protected] eventDispatcher => object(Symfony\Component\EventDispatcher\EventDispatcher) {
        [private] listeners => array()
        [private] sorted => array()
    }
    [protected] pluginInstances => array()
    [protected] endpoints => array(
        'localhost' => object(Solarium\Core\Client\Endpoint) {
            [protected] options => array(
                'host' => '*****',
                'port' => '*****',
                'scheme' => 'http',
                'path' => '/solr',
                'core' => 'master',
                'timeout' => (int) 5,
                'key' => 'localhost'
            )
        },
        'localhost2' => object(Solarium\Core\Client\Endpoint) {
            [protected] options => array(
                'host' => '*****',
                'port' => '*****',
                'scheme' => 'http',
                'path' => '/solr',
                'core' => 'slave',
                'timeout' => (int) 5,
                'key' => 'localhost2'
            )
        }
    )
    [protected] defaultEndpoint => 'localhost'
    [protected] adapter => null
}

php solr solarium cakephp-2.6
person MedKostali    schedule 11.04.2016    source источник

Ответы (2)


arrow_upward
1
arrow_downward

Вот как мне удается переключаться между «конечными точками»:

$endpoints=[
    'endpoint' => [
            'foo' => [
                'host' => '127.0.0.1',
                'port' => '9000',
                'path' => 'foo',
                'core' => 'foo',
                'timeout' => 15
            ],
            'baz' => [
                'host' => '127.0.0.1',
                'port' => '7464',
                'path' => 'baz',
                'core' => 'baz',
                'timeout' => 15
            ],
    ]
];
$solrClient = new Solarium\Client($config);
$solrClient->setDefaultEndPoint('baz');

И функция setDefaultEndPoint сделает магию

setDefaultEndPoint

`

person Carlos Zerga    schedule 07.09.2016

arrow_upward
0
arrow_downward

Это используется для создания нескольких solr-соединений в PHP-фреймворках.

Чтобы добавить приведенный ниже код в папку конфигурации

<?php
    $config['endpoint1'] = array( // endpoint1 is a FIRST connection.
        'endpoint' => array(
            'localhost' => array(
              'host' => 'host_name', // localhost or www.host.com
              'port' => 'port_value', //Default 8983 or 8080 etc,
              'path' => '/solr/',
              'core' => 'solr_core_name' // core1 or movie1 or etc,
            )
        )
    );
    $config['endpoint2'] = array( // endpoint2 is a secound connection.
        'endpoint' => array(
          'localhost' => array(
              'host' => 'host_name', // localhost or www.host.com
              'port' => 'port_value', //Default 8983 or 8080 etc,
              'path' => '/solr/',
              'core' => 'solr_core_name' // core1 or movie1 or etc,
          )
        )
    );
?>

И добавьте ссылку на подключение в методе __construct()

public function __construct() {
   parent::__construct();
   $this->config->load('solarium');
   $this->endpoint1 = new Solarium\Client($this->config->item('endpoint1')); 
   $this->endpoint2 = new Solarium\Client($this->config->item('endpoint2')); 
}

Если есть сомнения в настройке solr и его подключения, обратитесь к в этот репозиторий Github.

person CreativeMinds    schedule 08.06.2019