solrj中LBHttpSolrServer的使用说明_JAVA_编程开发_程序员俱乐部

工作中用到solr做搜索，由于没有Lucene基础，有些理论性的知识完全不能理解，不过大概还是把搜索的任务做好了，没有用到分词等功能。在使用LBHttpSolrServer的时候遇到了一个问题，就是写入的数据比预期的少一半，Solr的Wiki上这样解释LBHttpSolrServer的用法：

What is LBHttpSolrServer?

LBHttpSolrServer or "Load Balanced?HttpSolrServer" is just a wrapper to?CommonsHttpSolrServer. This is useful when you have multiple SolrServers and query requests need to be Load Balanced among them. It offers automatic failover when a server goes down and it detects when the server comes back up.

?

This should NOT be used for indexing in traditional master/slave architectures since updates have to be routed to the correct master. In?SolrCloud?architectures, use?CloudSolrServer?which will take advantage of this class automatically.

?

其实已经有点明白了，上面说在更新索引的时候不要使用LBHttpSolrServer了，而恰好我在更新的时候用了这个API，通过阅读源码，弄明白了LBHttpSolrServer的原理，与我预期想的不一致造成了问题的产生。我以为LBHttpSolrServer首先拿第一个可获得的节点去操作，如果当前节点挂了自动去获取下一个节点，其实LBHttpSolrServer是轮流的拿节点来操作。

?

?

public class LBHttpSolrServer extends SolrServer {
  private final CopyOnWriteArrayList<ServerWrapper> aliveServers = new CopyOnWriteArrayList<ServerWrapper>();
  private final CopyOnWriteArrayList<ServerWrapper> zombieServers = new CopyOnWriteArrayList<ServerWrapper>();
  private ScheduledExecutorService aliveCheckExecutor;

  private HttpClient httpClient;
  private final AtomicInteger counter = new AtomicInteger(-1);

  private ReentrantLock checkLock = new ReentrantLock();
  private static final SolrQuery solrQuery = new SolrQuery("*:*");
  .....

?上面摘选了LBHttpSolrServer的相关属性部门，其中值得注意的是 counter 这个属性，LBHttpSolrServer通过这个属性来记录使用LBHttpSolrServer中的哪个地址来做相关操作。通过 counter 与 存活的 server 总数取余，代码如下：

?

 public NamedList<Object> request(final SolrRequest request)
          throws SolrServerException, IOException {
    int count = counter.incrementAndGet();
    int attempts = 0;
    Exception ex;
    int startSize = aliveServers.size();
    while (true) {
      int size = aliveServers.size();
      if (size < 1) throw new SolrServerException("No live SolrServers available to handle this request");
      ServerWrapper solrServer;
      try {
        solrServer = aliveServers.get(count % size); //这里是关键
      } catch (IndexOutOfBoundsException e) {
        //this list changes dynamically. so it is expected to get IndexOutOfBoundsException
        continue;
      }
      try {
        return solrServer.solrServer.request(request);
      } catch (SolrException e) {
        // Server is alive but the request was malformed or invalid
        throw e;
      } catch (SolrServerException e) {
        if (e.getRootCause() instanceof IOException) {
          ex = e;
          moveAliveToDead(solrServer);
        } else {
          throw e;
        }
      } catch (Exception e) {
        throw new SolrServerException(e);
      }
      attempts++;
      if (attempts >= startSize)
        throw new SolrServerException("No live SolrServers available to handle this request", ex);
    }
  }

?其实代码中都已经详细说明了LBHttpSolrServer的相关特性，希望在用LBHttpSolrServer操作solr的时候注意好本身项目的特性，采用合适的做法。我的项目做法，不适合使用LBHttpSolrServer，原因如下：

?

我的项目没有采用SolrCloud做备份等操作，而是自己定义一个节点做所谓的master，这个负责读写索引，而在其他机器上装一个类似的环境slave，这个负责做备份，而master完全不知道有哪些节点在做它的备份，只需要在slave上执行如下命令即可同步slave与master一致：

http://slave:8984/solr/core1/replication?command=fetchindex&masterUrl=http://master:7674/solr/core1/replication

?

至于为什么采用这种方式备份，是因为SolrCloud不适合我的应用，我的应用会频繁的做大量数据的写入索引，每一次在提交时都会触发备份，导致服务器负载非常高，这里采用这种办法缓解服务器压力，只需要在slave机器上通过curl或者其他命令执行以上命令就可以完成备份操作。

?

?