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

jdgue

使用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。

• 
          CommonsHttpSolrServer server = null;
  
• 
  
• 
          try
  
• 
          {
  
• 
              server = new CommonsHttpSolrServer("http://localhost:8080/solr/");
  
• 
          }
  
• 
          catch(Exception e)
  
• 
          {
  
• 
              e.printStackTrace();
  
• 
          }
  

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

• 
          SolrQuery query = new SolrQuery();
  
• 
          query.setQuery(q);
  
• 
          query.setQueryType("dismax");
  
• 
          query.setFacet(true);
  
• 
          query.addFacetField("firstname");
  
• 
          query.addFacetField("lastname");
  
• 
          query.setFacetMinCount(2);
  
• 
          query.setIncludeScore(true);
  

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

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

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

• 
           System.out.println("Found: " + sdl.getNumFound());
  
• 
           System.out.println("Start: " + sdl.getStart());
  
• 
           System.out.println("Max Score: " + sdl.getMaxScore());
  
• 
           System.out.println("---------------------");
  
• 
  
• 
           ArrayList hitsOnPage = new ArrayList();
  
• 
  
• 
           for(SolrDocument d : sdl)
  
• 
           {
  
• 
                  HashMap values = new HashMap();
  
• 
  
• 
                  for(Iterator i = d.iterator(); i.hasNext(); )
  
• 
                      Map.Entry e2 = i.next();
  
• 
                      values.put(e2.getKey(), e2.getValue());
  
• 
                  }
  
• 
  
• 
                  hitsOnPage.add(values);
  
• 
                  System.out.println(values.get("displayname") + " (" + values.get("displayphone") + ")");
  
• 
              }
  

再输出分片信息。

• 
          List facets = qr.getFacetFields();
  
• 
  
• 
          for(FacetField facet : facets)
  
• 
          {
  
• 
                  List facetEntries = facet.getValues();
  
• 
  
• 
                  for(FacetField.Count fcount : facetEntries)
  
• 
                  {
  
• 
                      System.out.println(fcount.getName() + ": " + fcount.getCount());
  
• 
                  }
  
• 
          }
  

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