solr学习笔记（四）使用solrJ

xuanxi

solr   2009-01-13 10:30   阅读748   评论0  
字号： 大  中  小
使用solrj
CommonsHttpSolrServer
    CommonsHttpSolrServer 使用HTTPClient 和solr服务器进行通信。

Java代码
String url = "http://localhost:8983/solr";   
  SolrServer server = new CommonsHttpSolrServer( url );  

  Setting XMLResponseParser
     sorlr J 目前使用二进制的格式作为默认的格式。对于solr1.2的用户通过显示的设置才能使用XML格式。

   

Java代码
server.setParser(new XMLResponseParser());  

   Changing other Connection Settings
      CommonsHttpSorlrServer 允许设置链接属性。

     

Java代码
String url = "http://localhost:8983/solr"  
  CommonsHttpSolrServer server = new CommonsHttpSolrServer( url );   
  server.setSoTimeout(1000);  // socket read timeout   
  server.setConnectionTimeout(100);   
  server.setDefaultMaxConnectionsPerHost(100);   
  server.setMaxTotalConnections(100);   
  server.setFollowRedirects(false);  // defaults to false   
  // allowCompression defaults to false.   
  // Server side must support gzip or deflate for this to have any effect.   
  server.setAllowCompression(true);   
  server.setMaxRetries(1); // defaults to 0.  > 1 not recommended.  
EmbeddedSolrServer
      EmbeddedSorrServer提供和CommonsHttpSorlrServer相同的接口，它不需要http连接。

     

Java代码
SolrCore core = SolrCore.getSolrCore();   
  SolrServer server = new EmbeddedSolrServer( core );   
  ...  
   如果你想要使用 Multicore 特性，那么你可以这样使用：

  

Java代码
File home = new File( getSolrHome() );   
   File f = new File( home, "solr.xml" );   
   multicore.load( getSolrHome(), f );   
  
   EmbeddedSolrServer server = new EmbeddedSolrServer( multicore, "core name as defined in solr.xml" );  
      如果你在你的项目中内嵌solr服务，这将是一个不错的选择。无论你能否使用http，它都提供相同的接口。
  用法
    solrj 被设计成一个可扩展的框架，用以向solr服务器提交请求，并接收回应。

    我们已经将最通用的一些命令封装在了solrServer类中了。

   Adding Data to Solr
    首先需要获得一个server的实例，
Java代码
SolrServer server = getSolrServer();  
如果，你使用的是一个远程的solrServer的话呢，你或许会这样来实现getSolrServer()这个方法：      
Java代码
public SolrServer getSolrServer(){   
    //the instance can be reused   
    return new CommonsHttpSolrServer();   
}  

如果，你使用的是一个本地的solrServer的话，你或许会这样来实现getSolrServer()方法：      
Java代码
public SolrServer getSolrServer(){   
    //the instance can be reused   
    return new EmbeddedSolrServer();   
}  

如果，你在添加数据之前，想清空现有的索引，那么你可以这么做：
        

Java代码
server.deleteByQuery( "*:*" );// delete everything!  
构造一个document
         

Java代码
SolrInputDocument doc1 = new SolrInputDocument();   
doc1.addField( "id", "id1", 1.0f );   
doc1.addField( "name", "doc1", 1.0f );   
doc1.addField( "price", 10 );      
构造另外一个文档，每个文档都能够被独自地提交给solr，但是，批量提交是更高效的。每一个对SolrServer的请求都是http请求，当然对于EmbeddedSolrServer来说，是不一样的。     
Java代码
SolrInputDocument doc2 = new SolrInputDocument();   
doc2.addField( "id", "id2", 1.0f );   
doc2.addField( "name", "doc2", 1.0f );   
doc2.addField( "price", 20 );   
构造一个文档的集合
        

Java代码
Collection docs = new  ArrayList();   
docs.add( doc1 );   
docs.add( doc2 );   
将documents提交给solr
Java代码
server.add( docs );  
提交一个commit
Java代码
server.commit();  
在添加完documents后，立即做一个commit，你可以这样来写你的程序：
Java代码
UpdateRequest req = new UpdateRequest();   
  req.setAction( UpdateRequest.ACTION.COMMIT, false, false );   
  req.add( docs );   
  UpdateResponse rsp = req.process( server );     
  Directly adding POJOs to Solr
   使用 java 注释创建java bean。@Field ，可以被用在域上，或者是setter方法上。如果一个域的名称跟bean的名称是不一样的，那么在java注释中填写别名，具体的，可以参照下面的域categories         
Java代码
import org.apache.solr.client.solrj.beans.Field;   
  
public class Item {   
    @Field  
    String id;   
  
    @Field("cat")   
    String[] categories;   
  
    @Field  
    List features;   
  
  }   
java注释也可以使用在setter方法上，如下面的例子：
        

Java代码
@Field("cat")   
public void setCategory(String[] c){   
     this.categories = c;   
}   
          这里应该要有一个相对的，get方法（没有加java注释的）来读取属性

Get an instance of server
Java代码
SolrServer server = getSolrServer();   
创建bean实例
        

Java代码
Item item = new Item();   
item.id = "one";   
item.categories =  new String[] { "aaa", "bbb", "ccc" };   
添加给solr         
Java代码
server.addBean(item);   
将多个bean提交给solr
     

Java代码
List beans ;   
//add Item objects to the list   
server.addBeans(beans);     
    注意： 你可以重复使用SolrServer，这样可以提高性能。

  Reading Data from Solr
   获取solrserver的实例
            

Java代码
SolrServer server = getSolrServer();   
   构造 SolrQuery
     

Java代码
SolrQuery query = new SolrQuery();   
query.setQuery( "*:*" );   
query.addSortField( "price", SolrQuery.ORDER.asc );      
   向服务器发出查询请求
   

Java代码
QueryResponse rsp = server.query( query );      
   获取结果。
   

Java代码
SolrDocumentList docs = rsp.getResults();   
   想要以javabean的方式获取结果，那么这个javabean必须像之前的例子一样有java注释。
Java代码
List beans = rsp.getBeans(Item.class);   
    高级用法
       solrJ 提供了一组API，来帮助我们创建查询，下面是一个faceted query的例子。

Java代码
SolrServer server = getSolrServer();   
SolrQuery solrQuery = new  SolrQuery().   
               setQuery("ipod").   
               setFacet(true).   
               setFacetMinCount(1).   
               setFacetLimit(8).   
               addFacetField("category").   
               addFacetField("inStock");     
QueryResponse rsp = server.query(solrQuery);  
所有的 setter/add 方法都是返回它自己本身的实例，所以就像你所看到的一样，上面的用法是链式的。