Solr Server对外提供Web Service的沟通方式 使用SolrJ跟Solr Server通信

使用SolrJ跟Solr Server通信

郝国梁 (2009年8月 3日 23:09) | 暂无评论 | 暂无引用通告

我们都知道Solr Server对外提供Web Service的沟通方式，接受Xml格式的Post数据。这种方式本身没有问题，可当我们要把Solr跟我们的业务逻辑整合时，我们希望更加友好的接口和工具。SolrJ等Solr Client应运而生了，并且被官方包含在Solr1.3.0的发布包中。

SolrJ是Java程序员与Solr Server最好的对话工具包(除非你不使用HTTP方式，使用Embedded Solr)，SolrJ将所有Solr的对外接口封装成了规整、小巧、灵活的包，使得你可以免去直接解析、格式化Xml。如何使用SolrJ呢？网上没有很好的例子，下面分享一个小例子查询我们已经索引的数据。Solr的最新稳定版本是1.3.0，1.4.0版本尚未发布，可以下载最新的nightly版本研究。

让我们从创建一个CommonsHttpSolrServer实例开始，构造函数中需要提供Solr Server的URL。你可能需要提供自定义Query Parser，简单起见，在此暂不自定义Parser。

1.         CommonsHttpSolrServer server = null;
2.  
3.         try
4.         {
5.             server = new CommonsHttpSolrServer("http://localhost:8080/solr/");
6.         }
7.         catch(Exception e)
8.         {
9.             e.printStackTrace();
10.         }

接下来，我们构造查询，以便向Solr Server发起查询请求，我们创建一个SolrQuery对象，简单的进行实例化，并设定我们要查询的值。setQueryType可以使得你放弃使用默认的QueryType请求处理器(StandardRequestHandler)，你还可以打开facet(分片)，增加你的分片字段(facet fields)。

1.         SolrQuery query = new SolrQuery();
2.         query.setQuery(q);
3.         query.setQueryType("dismax");
4.         query.setFacet(true);
5.         query.addFacetField("firstname");
6.         query.addFacetField("lastname");
7.         query.setFacetMinCount(2);
8.         query.setIncludeScore(true);

然后我们就可以调用server.query来向Solr Server发出查询请求，返回给我们解析好的结果集。

1.          QueryResponse qr = server.query(query);
2.          SolrDocumentList sdl = qr.getResults();

然后就是输出我们的查询结果了。

1.          System.out.println("Found: " + sdl.getNumFound());
2.          System.out.println("Start: " + sdl.getStart());
3.          System.out.println("Max Score: " + sdl.getMaxScore());
4.          System.out.println("---------------------");
5.  
6.          ArrayList<HashMap<String, Object>> hitsOnPage = new ArrayList<HashMap<String, Object>>();
7.  
8.          for(SolrDocument d : sdl)
9.          {
10.                 HashMap<String, Object> values = new HashMap<String, Object>();
11.  
12.                 for(Iterator<Map.Entry<String, Object>> i = d.iterator(); i.hasNext(); )
13.                     Map.Entry<String, Object> e2 = i.next();
14.                     values.put(e2.getKey(), e2.getValue());
15.                 }
16.  
17.                 hitsOnPage.add(values);
18.                 System.out.println(values.get("displayname") + " (" + values.get("displayphone") + ")");
19.             }

再输出分片信息。

1.         List facets = qr.getFacetFields();
2.  
3.         for(FacetField facet : facets)
4.         {
5.                 List facetEntries<FacetField.Count> = facet.getValues();
6.  
7.                 for(FacetField.Count fcount : facetEntries)
8.                 {
9.                     System.out.println(fcount.getName() + ": " + fcount.getCount());
10.                 }
11.         }

上面描述了一个使用SolrJ进行简单查询的过程。注意，你需要把apache-solr-solrj-1.3.0.jar放到你的应用中的lib目录下。