Solr/Lucene分布式搜索,SolrIntegratekattastep4

2019独角兽企业重金招聘Python工程师标准>>>

做好了上面几个步骤.我们可以加入测试,测试代码:

package net.dkatta;import java.util.Iterator; import java.util.Map;import net.sf.katta.client.ClientResult; import net.sf.katta.util.KattaException; import net.sf.katta.util.ZkConfiguration;import org.apache.solr.client.solrj.SolrQuery; import org.apache.solr.client.solrj.SolrResponse; import org.apache.solr.client.solrj.response.QueryResponse; import org.apache.solr.common.SolrDocument; import org.apache.solr.common.SolrDocumentList; import org.apache.solr.common.params.CommonParams; import org.apache.solr.common.util.NamedList; import org.apache.solr.katta.KattaClient; import org.apache.solr.katta.KattaRequest; import org.apache.solr.katta.KattaResponse;/***

* Created by IntelliJ IDEA.* User: zhenqin* Date: 12-10-12* Time: 上午11:45* To change this template use File | Settings | File Templates.**

** &＃64;author zhenqin*/
public class ClientMain {public static void main(String[] args) throws KattaException {KattaClient kattaClient &＃61; new KattaClient(new ZkConfiguration());
//        Client client &＃61; new Client(SolrKattaServer.class);SolrQuery query &＃61; new SolrQuery();String word &＃61; "facet";query.setQuery("content:facet");query.setParam("fl", "title, content, score");//        query.addFilterQuery("content:(" &＃43; word &＃43; ")");query.setRows(10);//设置返回结果条数&＃xff0c;如果你时分组查询&＃xff0c;你就设置为0query.setSortField("score", SolrQuery.ORDER.desc);//分组排序字段query.add(CommonParams.QT, "standard");System.out.println(query.toString());QueryResponse queryResponse &＃61; null;SolrResponse solrResponse &＃61; null;KattaRequest request &＃61; new KattaRequest(query);try {ClientResult res &＃61; kattaClient.request(10 * 1000L, new String[]{"*"}, request);System.out.println(res);java.util.Collection ls &＃61; res.getResults();KattaResponse kr &＃61; ls.iterator().next();SolrResponse response &＃61; kr.getRsp();if(response instanceof QueryResponse) {queryResponse &＃61; (QueryResponse)response;System.out.println("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;true");} else {System.out.println("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;false" &＃43; response.getClass().getName());queryResponse &＃61; new QueryResponse();queryResponse.setResponse(response.getResponse());}System.out.println("共搜索到: " &＃43; queryResponse.getResults().size());SolrDocumentList docs &＃61; queryResponse.getResults();for (SolrDocument doc : docs) {for (Iterator> iter &＃61; doc.iterator(); iter.hasNext();) {Map.Entry entry &＃61; iter.next();System.out.print("Key: " &＃43; entry.getKey() &＃43; "  ");System.out.println("Value: " &＃43; entry.getValue());}System.out.println("----------------------------------------------");}} catch(Exception e) {e.printStackTrace();}}
}

执行后ClientMain输出:

10-18 14:44:21 [INFO 级别][ zookeeper.ZooKeeper ]类 (379 行) Initiating client connection, connectString&＃61;localhost:2181 sessionTimeout&＃61;5000 watcher&＃61;org.I0Itec.zkclient.ZkClient&＃64;5d40f8c3 10-18 14:44:21 [INFO 级别][ zookeeper.ClientCnxn ]类 (1058 行) Opening socket connection to server localhost/127.0.0.1:2181 10-18 14:44:21 [INFO 级别][ zookeeper.ClientCnxn ]类 (947 行) Socket connection established to localhost/127.0.0.1:2181, initiating session 10-18 14:44:21 [INFO 级别][ zookeeper.ClientCnxn ]类 (736 行) Session establishment complete on server localhost/127.0.0.1:2181, sessionid &＃61; 0x13a7236897c0009, negotiated timeout &＃61; 10000 10-18 14:44:21 [INFO 级别][ zkclient.ZkClient ]类 (449 行) zookeeper state changed (SyncConnected) 10-18 14:44:21 [INFO 级别][ client.Client ]类 (143 行) indices&＃61;[solrhome1] q&＃61;content%3Afacet&fl&＃61;title%2C&＃43;content%2C&＃43;score&rows&＃61;10&sort&＃61;score&＃43;desc&qt&＃61;standard ClientResult: 1 results, 0 errors, 1/1 shards (closed) (complete) &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;falseorg.apache.solr.client.solrj.response.SolrResponseBase 共搜索到: 2 Key: sid Value: 7039ce44-20bc-41d4-8278-2377654b3f35 Key: title Value: facet.field Key: content Value: This param allows you to specify a field which should be treated as a facet Key: score Value: 0.9991327 ---------------------------------------------- Key: sid Value: 832c11d4-e1c1-453d-8a56-a9726d8e3b44 Key: title Value: facet.field Key: content Value: This param allows you to specify a field which should be treated as a facet Key: score Value: 0.9991327 ---------------------------------------------- 同时,step3中启动的Node和Shard同时搜了2遍.日志:

10-18 14:44:22 [INFO 级别][ core.SolrCore ]类 (1386 行) [solrhome1#proxy] webapp&＃61;null path&＃61;/select params&＃61;{rows&＃61;10&sort&＃61;score&＃43;desc&fl&＃61;sid%2Cscore&q&＃61;content%3Afacet&start&＃61;0&fsv&＃61;true&isShard&＃61;true} hits&＃61;2 status&＃61;0 QTime&＃61;20 10-18 14:44:22 [INFO 级别][ core.SolrCore ]类 (1386 行) [solrhome1#proxy] webapp&＃61;null path&＃61;/select params&＃61;{rows&＃61;10&fl&＃61;title%2C&＃43;content%2C&＃43;score%2Csid&q&＃61;content%3Afacet&ids&＃61;7039ce44-20bc-41d4-8278-2377654b3f35%2C832c11d4-e1c1-453d-8a56-a9726d8e3b44&isShard&＃61;true} status&＃61;0 QTime&＃61;4 当然如果在step3中加入2个shard,它会搜索这2个shard的索引.当同时加入更多的Node,则使用*搜索所有的Node,solrhome1只搜索一个Node.