|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.solr.client.solrj.SolrServer org.apache.solr.client.solrj.impl.LBHttpSolrServer
public class LBHttpSolrServer
LBHttpSolrServer or "LoadBalanced HttpSolrServer" is a load balancing wrapper around
HttpSolrServer
. This is useful when you
have multiple SolrServers and the requests need to be Load Balanced among them. This should NOT be used for
indexing. Also see the wiki page.
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 usingSolrServer lbHttpSolrServer = new LBHttpSolrServer("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(); SolrServer lbHttpSolrServer = new LBHttpSolrServer(httpClient,"http://host1:8080/solr/","http://host2:8080/solr","http://host2:8080/solr");
setAliveCheckInterval(int)
, the default is set to one minute.
When to use this?
Nested Class Summary | |
---|---|
static class |
LBHttpSolrServer.Req
|
static class |
LBHttpSolrServer.Rsp
|
Constructor Summary | |
---|---|
LBHttpSolrServer(org.apache.http.client.HttpClient httpClient,
ResponseParser parser,
String... solrServerUrl)
The provided httpClient should use a multi-threaded connection manager |
|
LBHttpSolrServer(org.apache.http.client.HttpClient httpClient,
String... solrServerUrl)
The provided httpClient should use a multi-threaded connection manager |
|
LBHttpSolrServer(String... solrServerUrls)
|
Method Summary | |
---|---|
void |
addSolrServer(String server)
|
protected void |
finalize()
|
org.apache.http.client.HttpClient |
getHttpClient()
|
protected HttpSolrServer |
makeServer(String server)
|
static String |
normalize(String server)
|
String |
removeSolrServer(String server)
|
LBHttpSolrServer.Rsp |
request(LBHttpSolrServer.Req req)
Tries to query a live server from the list provided in Req. |
NamedList<Object> |
request(SolrRequest request)
Tries to query a live server. |
void |
setAliveCheckInterval(int interval)
LBHttpSolrServer keeps pinging the dead servers at fixed interval to find if it is alive. |
void |
setConnectionTimeout(int timeout)
|
void |
setSoTimeout(int timeout)
set soTimeout (read timeout) on the underlying HttpConnectionManager. |
void |
shutdown()
Release allocated resources. |
Methods inherited from class org.apache.solr.client.solrj.SolrServer |
---|
add, add, add, add, addBean, addBean, addBeans, addBeans, commit, commit, commit, deleteById, deleteById, deleteById, deleteById, deleteByQuery, deleteByQuery, getBinder, optimize, optimize, optimize, ping, query, query, queryAndStreamResponse, rollback |
Methods inherited from class java.lang.Object |
---|
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public LBHttpSolrServer(String... solrServerUrls) throws MalformedURLException
MalformedURLException
public LBHttpSolrServer(org.apache.http.client.HttpClient httpClient, String... solrServerUrl) throws MalformedURLException
MalformedURLException
public LBHttpSolrServer(org.apache.http.client.HttpClient httpClient, ResponseParser parser, String... solrServerUrl) throws MalformedURLException
MalformedURLException
Method Detail |
---|
public static String normalize(String server)
protected HttpSolrServer makeServer(String server) throws MalformedURLException
MalformedURLException
public LBHttpSolrServer.Rsp request(LBHttpSolrServer.Req req) throws SolrServerException, IOException
req
- contains both the request as well as the list of servers to query
SolrServerException
IOException
public void addSolrServer(String server) throws MalformedURLException
MalformedURLException
public String removeSolrServer(String server)
public void setConnectionTimeout(int timeout)
public void setSoTimeout(int timeout)
public void shutdown()
SolrServer
shutdown
in class SolrServer
public NamedList<Object> request(SolrRequest request) throws SolrServerException, IOException
request
in class SolrServer
request
- the SolrRequest.
SolrServerException
IOException
public void setAliveCheckInterval(int interval)
interval
- time in millisecondspublic org.apache.http.client.HttpClient getHttpClient()
protected void finalize() throws Throwable
finalize
in class Object
Throwable
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |