话不多说直接上代码
private static CloudSolrServer cloudSolrServer;
private static synchronized CloudSolrServer getCloudSolrServer(final String zkHost) {
if(cloudSolrServer == null) {
try {
cloudSolrServer = new CloudSolrServer(zkHost);
cloudSolrServer.setZkConnectTimeout(30000);
cloudSolrServer.setZkClientTimeout(30000);
QueryResponse reponse = cloudSolrServer.query(sql);
cloudSolrServer.shutdown();
} catch(Exception e) {
e.printStackTrace();
}
}
return cloudSolrServer;
}