Class PatchedLBHttpSolrClient
- All Implemented Interfaces:
Closeable,Serializable,AutoCloseable
Hybris note: This is a patched version of LBHttpSolrClient which we had to create due to
https://issues.apache.org/jira/browse/SOLR-12415.
LBHttpSolrClient or "LoadBalanced HttpSolrClient" is a load balancing wrapper around
HttpSolrClient. This is useful when you
have multiple Solr servers and the requests need to be Load Balanced among them.
Do NOT use this class for indexing in master/slave scenarios since documents must be sent to the
correct master; no inter-node routing is done.
In SolrCloud (leader/replica) scenarios, it is usually better to use
CloudSolrClient, but this class may be used
for updates because the server will forward them to the appropriate leader.
It offers automatic failover when a server goes down and it detects when the server comes back up.
Load balancing is done using a simple round-robin on the list of servers.
If a request to a server fails by an IOException due to a connection timeout or read timeout then the host is taken off the list of live servers and moved to a 'dead server list' and the request is resent to the next live server. This process is continued till it tries all the live servers. If at least one server is alive, the request succeeds, and if not it fails.
SolrClient lbHttpSolrClient = new LBHttpSolrClient("http://host1:8080/solr/", "http://host2:8080/solr", "http://host2:8080/solr");
//or if you wish to pass the HttpClient do as follows
httpClient httpClient = new HttpClient();
SolrClient lbHttpSolrClient = new LBHttpSolrClient(httpClient, "http://host1:8080/solr/", "http://host2:8080/solr", "http://host2:8080/solr");
This detects if a dead server comes alive automatically. The check is done in fixed intervals in a dedicated thread.
This interval can be set using PatchedLBSolrClient.setAliveCheckInterval(int) , the default is set to one minute.
When to use this?
This can be used as a software load balancer when you do not wish to setup an external
load balancer. Alternatives to this code are to use
a dedicated hardware load balancer or using Apache httpd with mod_proxy_balancer as a load balancer. See Load balancing on Wikipedia
- Since:
- solr 1.4
- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classConstructsPatchedLBHttpSolrClientinstances from provided configuration.static classDeprecated.static classDeprecated.usePatchedLBSolrClient.RspinsteadNested classes/interfaces inherited from class de.hybris.platform.solrfacetsearch.solr.impl.PatchedLBSolrClient
PatchedLBSolrClient.ServerWrapper -
Field Summary
Fields inherited from class de.hybris.platform.solrfacetsearch.solr.impl.PatchedLBSolrClient
parser, queryParams, requestWriter -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedprotectedPatchedLBHttpSolrClient(org.apache.http.client.HttpClient httpClient, org.apache.solr.client.solrj.ResponseParser parser, String... solrServerUrl) Deprecated.usePatchedLBHttpSolrClient(Builder)instead, as it is a more extension/subclassing-friendly alternativeprotectedPatchedLBHttpSolrClient(org.apache.solr.client.solrj.impl.HttpSolrClient.Builder httpSolrClientBuilder, org.apache.http.client.HttpClient httpClient, String... solrServerUrl) Deprecated.usePatchedLBHttpSolrClient(Builder)instead, as it is a more extension/subclassing-friendly alternative -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()protected org.apache.solr.client.solrj.SolrClientorg.apache.http.client.HttpClientReturn the HttpClient this instance uses.protected org.apache.solr.client.solrj.impl.HttpSolrClientmakeSolrClient(String server) removeSolrServer(String server) Deprecated.voidsetConnectionTimeout(int timeout) Deprecated.since 7.0 UsePatchedLBHttpSolrClient.Buildermethods instead.voidsetSoTimeout(int timeout) Deprecated.since 7.0 UsePatchedLBHttpSolrClient.Buildermethods instead.Methods inherited from class de.hybris.platform.solrfacetsearch.solr.impl.PatchedLBSolrClient
addQueryParams, addSolrServer, createServerWrapper, doRequest, getParser, getQueryParams, getRequestWriter, normalize, pickServer, request, request, request, setAliveCheckInterval, setParser, setQueryParams, setRequestWriter, updateAliveListMethods inherited from class org.apache.solr.client.solrj.SolrClient
add, add, add, add, add, add, add, add, add, add, addBean, addBean, addBean, addBean, addBeans, addBeans, addBeans, addBeans, addBeans, addBeans, commit, commit, commit, commit, commit, commit, deleteById, deleteById, deleteById, deleteById, deleteById, deleteById, deleteById, deleteById, deleteByQuery, deleteByQuery, deleteByQuery, deleteByQuery, getBinder, getById, getById, getById, getById, getById, getById, getById, getById, optimize, optimize, optimize, optimize, optimize, optimize, ping, ping, query, query, query, query, queryAndStreamResponse, queryAndStreamResponse, queryAndStreamResponse, request, rollback, rollback
-
Constructor Details
-
PatchedLBHttpSolrClient
@Deprecated protected PatchedLBHttpSolrClient(org.apache.solr.client.solrj.impl.HttpSolrClient.Builder httpSolrClientBuilder, org.apache.http.client.HttpClient httpClient, String... solrServerUrl) Deprecated.usePatchedLBHttpSolrClient(Builder)instead, as it is a more extension/subclassing-friendly alternativeThe provided httpClient should use a multi-threaded connection manager -
PatchedLBHttpSolrClient
@Deprecated protected PatchedLBHttpSolrClient(org.apache.http.client.HttpClient httpClient, org.apache.solr.client.solrj.ResponseParser parser, String... solrServerUrl) Deprecated.usePatchedLBHttpSolrClient(Builder)instead, as it is a more extension/subclassing-friendly alternativeThe provided httpClient should use a multi-threaded connection manager -
PatchedLBHttpSolrClient
-
-
Method Details
-
makeSolrClient
-
setConnectionTimeout
Deprecated.since 7.0 UsePatchedLBHttpSolrClient.Buildermethods instead. -
setSoTimeout
Deprecated.since 7.0 UsePatchedLBHttpSolrClient.Buildermethods instead.set soTimeout (read timeout) on the underlying HttpConnectionManager. This is desirable for queries, but probably not for indexing. -
request
@Deprecated public PatchedLBHttpSolrClient.Rsp request(PatchedLBHttpSolrClient.Req req) throws org.apache.solr.client.solrj.SolrServerException, IOException Deprecated.- Throws:
org.apache.solr.client.solrj.SolrServerExceptionIOException
-
getClient
- Specified by:
getClientin classPatchedLBSolrClient
-
removeSolrServer
- Overrides:
removeSolrServerin classPatchedLBSolrClient
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Overrides:
closein classPatchedLBSolrClient
-
getHttpClient
public org.apache.http.client.HttpClient getHttpClient()Return the HttpClient this instance uses.
-
PatchedLBSolrClient.Reqinstead