`

利用solr构建企业搜索平台（五）

    博客分类：
  • Solr
Solr企业应用JavaSSHSpring 
阅读更多

相信很多人，在准备提交数据让solr建立索引的那刻，很纳闷，尽管看了不少网上的一些文章，但是我想依然还是有不少不理解的地方。
比如提交一个xml，采用post方式，尽管有些文章说了可以采用httpclient。但是我那个时候，还不是很理解，当然现在看来其实也没有什么了。但是对于一个刚入门solr的初学者，我想讲讲关于solr1.3的 solrj（ sorlr J 目前使用二进制的格式作为默认的格式。对于solr1.2的用户通过显示的设置才能使用XML格式。）！

先上一个例子：

Java代码 复制代码
  1. public static final String SOLR_URL = "http://localhost/solr/core0";   
  2. public static void commit() {   
  3.     Date date = new Date();   
  4.     SolrServer solr = null;   
  5.     try {   
  6.         solr = new CommonsHttpSolrServer(SOLR_URL);   
  7.     } catch (MalformedURLException e1) {   
  8.         e1.printStackTrace();   
  9.     }   
  10. for (int i = 0; i < 10000; i++) {   
  11.             SolrInputDocument sid = new SolrInputDocument();   
  12.             sid.addField("id", i);   
  13.             sid.addField("name", "struts+hibernate+spring 开发大全" + i);   
  14.             sid.addField("summary", "三种框架的综合应用" + i);   
  15.             sid.addField("author", "李良杰" + i);   
  16.             sid.addField("date", new Date());   
  17.             sid.addField("content", "高级应用类书籍" + i);   
  18.             sid.addField("keywords", "SSH" + i);   
  19.             try {   
  20.                 solr.add(sid);   
  21.             } catch (MalformedURLException e) {   
  22.                 e.printStackTrace();   
  23.             } catch (SolrServerException e) {   
  24.                 e.printStackTrace();   
  25.             } catch (IOException e) {   
  26.                 e.printStackTrace();   
  27.             }   
  28.             System.out.println(i);   
  29.             if (i == 999)    
  30.                 System.out.println((new Date().getTime() - date.getTime()) / 60000 + "分钟");   
  31.         }   
  32.         try {   
  33.             solr.commit();   
  34.         } catch (SolrServerException e) {   
  35.             e.printStackTrace();   
  36.         } catch (IOException e) {   
  37.             e.printStackTrace();   
  38.         }   
  39. }  
public static final String SOLR_URL = "http://localhost/solr/core0";
public static void commit() {
	Date date = new Date();
	SolrServer solr = null;
	try {
		solr = new CommonsHttpSolrServer(SOLR_URL);
	} catch (MalformedURLException e1) {
		e1.printStackTrace();
	}
for (int i = 0; i < 10000; i++) {
			SolrInputDocument sid = new SolrInputDocument();
			sid.addField("id", i);
			sid.addField("name", "struts+hibernate+spring 开发大全" + i);
			sid.addField("summary", "三种框架的综合应用" + i);
			sid.addField("author", "李良杰" + i);
			sid.addField("date", new Date());
			sid.addField("content", "高级应用类书籍" + i);
			sid.addField("keywords", "SSH" + i);
			try {
				solr.add(sid);
			} catch (MalformedURLException e) {
				e.printStackTrace();
			} catch (SolrServerException e) {
				e.printStackTrace();
			} catch (IOException e) {
				e.printStackTrace();
			}
			System.out.println(i);
			if (i == 999) 
				System.out.println((new Date().getTime() - date.getTime()) / 60000 + "分钟");
		}
		try {
			solr.commit();
		} catch (SolrServerException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
}



上面这段代码的意思是：利用for提交10000个document，并打印提交10000所需的时间。
1》CommonsHttpSolrServer 使用HTTPClient 和solr服务器进行通信。

2》CommonsHttpSorlrServer 允许设置链接属性。

Java代码 复制代码
  1. server.setSoTimeout(1000);  // socket read timeout     
  2.   server.setConnectionTimeout(100);     
  3.   server.setDefaultMaxConnectionsPerHost(100);     
  4.   server.setMaxTotalConnections(100);     
  5.   server.setFollowRedirects(false);  // defaults to false     
  6.   // allowCompression defaults to false.     
  7.   // Server side must support gzip or deflate for this to have any effect.     
  8.   server.setAllowCompression(true);     
  9.   server.setMaxRetries(1); // defaults to 0.  > 1 not recommended.  
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.

 

3》实现SolrServer接口的另一个类：EmbeddedSorrServer，它不需要http连接。

4》在构造document的时候，可以一个一个添加到solrServer，也可以构建一个包含document的Collection，将Collection添加到solrServer，然后commit。

5》也可以构造一个跟document匹配的JavaBean进行提交
      使用 java 注释创建java bean。@Field ，可以被用在域上，或者是setter方法上。如果一个域的名称跟bean的名称是不一样的，那么在java注释中填写别名，具体的，可以参照下面的域categories         

Java代码 复制代码
  1. import org.apache.solr.client.solrj.beans.Field;     
  2.  public class Item {     
  3.     @Field     
  4.     String id;     
  5.     @Field("cat")     
  6.     String[] categories;      
  7.     @Field     
  8.     List<String> features;      
  9.   }    
import org.apache.solr.client.solrj.beans.Field;  
 public class Item {  
    @Field  
    String id;  
    @Field("cat")  
    String[] categories;   
    @Field  
    List<String> features;   
  }


java注释也可以使用在setter方法上，如下面的例子：

Java代码 复制代码
  1. @Field("cat")     
  2.  public void setCategory(String[] c){     
  3.      this.categories = c;     
  4.  }  
@Field("cat")  
 public void setCategory(String[] c){  
     this.categories = c;  
 }

 
这里应该要有一个相对的，get方法（没有加java注释的）来读取属性

Java代码 复制代码
  1. Item item = new Item();     
  2. item.id = "one";     
  3. item.categories =  new String[] { "aaa", "bbb", "ccc" };   
Item item = new Item();  
item.id = "one";  
item.categories =  new String[] { "aaa", "bbb", "ccc" };


添加给solr         

Java代码 复制代码
  1. server.addBean(item);  
server.addBean(item);

 
将多个bean提交给solr

Java代码 复制代码
  1. List<Item> beans ;     
  2. //add Item objects to the list     
  3. server.addBeans(beans);  
List<Item> beans ;  
//add Item objects to the list  
server.addBeans(beans);

    
注意： 你可以重复使用SolrServer，这样可以提高性能。

6》

Java代码 复制代码
  1. public static void update() {   
  2.     SolrServer solrServer = null;   
  3.     try {   
  4.         solrServer = new CommonsHttpSolrServer(SOLR_URL);   
  5.     } catch (MalformedURLException e) {   
  6.         e.printStackTrace();   
  7.     }   
  8.     UpdateRequest updateRequest = new UpdateRequest();   
  9.     SolrInputDocument sid = new SolrInputDocument();   
  10.     sid.addField("id", 100000);   
  11.     sid.addField("name", "struts+hibernate+spring 开发大全");   
  12.     sid.addField("summary", "三种框架的综合应用");   
  13.     sid.addField("author", "李良杰");   
  14.     sid.addField("date", new Date());   
  15.     sid.addField("content", "高级应用类书籍");   
  16.     sid.addField("keywords", "SSH");   
  17.     updateRequest.setAction(UpdateRequest.ACTION.COMMIT, false, false);     
  18.     updateRequest.add(sid);     
  19.     try {   
  20.         UpdateResponse updateResponse = updateRequest.process(solrServer);   
  21.         System.out.println(updateResponse.getStatus());   
  22.     } catch (SolrServerException e) {   
  23.         e.printStackTrace();   
  24.     } catch (IOException e) {   
  25.         e.printStackTrace();   
  26.     }   
  27. }  
public static void update() {
	SolrServer solrServer = null;
	try {
		solrServer = new CommonsHttpSolrServer(SOLR_URL);
	} catch (MalformedURLException e) {
		e.printStackTrace();
	}
	UpdateRequest updateRequest = new UpdateRequest();
	SolrInputDocument sid = new SolrInputDocument();
	sid.addField("id", 100000);
	sid.addField("name", "struts+hibernate+spring 开发大全");
	sid.addField("summary", "三种框架的综合应用");
	sid.addField("author", "李良杰");
	sid.addField("date", new Date());
	sid.addField("content", "高级应用类书籍");
	sid.addField("keywords", "SSH");
	updateRequest.setAction(UpdateRequest.ACTION.COMMIT, false, false);  
	updateRequest.add(sid);  
	try {
		UpdateResponse updateResponse = updateRequest.process(solrServer);
		System.out.println(updateResponse.getStatus());
	} catch (SolrServerException e) {
		e.printStackTrace();
	} catch (IOException e) {
		e.printStackTrace();
	}
}


提交一个document，采用更新方式，注意：

Java代码 复制代码
  1. updateRequest.setAction(UpdateRequest.ACTION.COMMIT, false, false);  
updateRequest.setAction(UpdateRequest.ACTION.COMMIT, false, false);



7》

Java代码 复制代码
  1. public static void query() {   
  2.     SolrServer solr = null;   
  3.     try {   
  4.         solr = new CommonsHttpSolrServer(SOLR_URL);   
  5.     } catch (MalformedURLException e) {   
  6.         e.printStackTrace();   
  7.         return;   
  8.     }   
  9.     // http://localhost:8983/solr/spellCheckCompRH?q=epod&spellcheck=on&spellcheck.build=true   
  10.     ModifiableSolrParams params = new ModifiableSolrParams();   
  11.     params.set("qt", "/spellCheckCompRH");   
  12.     params.set("q", "编程");   
  13.     params.set("spellcheck", "on");   
  14.     params.set("spellcheck.build", "true");   
  15.     QueryResponse response = null;   
  16.     try {   
  17.         response = solr.query(params);   
  18.     } catch (SolrServerException e) {   
  19.         e.printStackTrace();   
  20.         return;   
  21.     }   
  22.     System.out.println("response = " + response);   
  23. }  
public static void query() {
	SolrServer solr = null;
	try {
		solr = new CommonsHttpSolrServer(SOLR_URL);
	} catch (MalformedURLException e) {
		e.printStackTrace();
		return;
	}
	// http://localhost:8983/solr/spellCheckCompRH?q=epod&spellcheck=on&spellcheck.build=true
	ModifiableSolrParams params = new ModifiableSolrParams();
	params.set("qt", "/spellCheckCompRH");
	params.set("q", "编程");
	params.set("spellcheck", "on");
	params.set("spellcheck.build", "true");
	QueryResponse response = null;
	try {
		response = solr.query(params);
	} catch (SolrServerException e) {
		e.printStackTrace();
		return;
	}
	System.out.println("response = " + response);
}


这是一个查询方法。关键字：“编程”。关于查询的关键字，请参见slor wiki http://wiki.apache.org/solr/QueryParametersIndex，或等待我的博客更新，在后面会有篇文章详细讲这个问题！

8》给solr的索引文件手动进行优化，

Java代码 复制代码
  1. solr.optimize();  
solr.optimize();



9》solrJ 提供了一组API，来帮助我们创建查询，下面是一个faceted query的例子。
Java代码

Java代码 复制代码
  1. SolrServer server = getSolrServer();     
  2. SolrQuery solrQuery = new  SolrQuery().setQuery("ipod").setFacet(true).setFacetMinCount(1).setFacetLimit(8).      addFacetField("category").addFacetField("inStock");       
  3. QueryResponse rsp = server.query(solrQuery);  
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 方法都是返回它自己本身的实例，所以就像你所看到的一样，上面的用法是链式的。

分享到：
| 利用solr构建企业搜索平台（四）
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    SOLR搭建企业搜索平台

    本文将详细阐述如何利用SOLR搭建一个企业搜索平台，包括所需环境、配置步骤以及中文分词的设置。 一、SOLR搭建企业搜索平台 1. **运行环境** - **运行容器**：Tomcat 6.0.20 - **Solr版本**：apache-solr-1.4.0 ...

    利用Solr搭建你的搜索引擎

    标题中的“利用Solr搭建你的搜索引擎”意味着我们将探讨Apache Solr这一开源全文搜索平台的搭建过程。Solr是基于Lucene库的，提供了一个高效、可扩展的搜索和导航功能，广泛应用于各种企业的数据检索需求。 Solr的...

    solr 企业搜索引擎教程

    ### Apache Solr 企业搜索引擎教程知识点总结 #### 1. Apache Solr 概述 - **Solr**：Apache Solr 是一款高度可扩展且高性能的企业级搜索平台，由Apache软件基金会维护。它是一个开源搜索服务器，使用Java语言编写...

    基于Solr的企业级信息检索的设计与实现

    基于Solr构建企业级信息检索系统是一种可行且有效的解决方案。通过深入分析企业需求，精心设计系统架构，可以显著提升企业内部信息检索的效率和用户体验，助力企业提升核心竞争力。Solr的成熟技术和灵活特性使其成为...

    solr实现京东搜索

    本篇文章将详细阐述如何利用Solr实现京东搜索的功能。 一、关键词搜索 在商品信息搜索中，关键词搜索是最基础也最重要的功能。用户输入关键词后，Solr会通过分析器对关键词进行分词处理，然后在索引库中匹配与之...

    Apache Solr（solr-8.11.1.tgz）

    Apache Solr 是一个开源的全文搜索引擎，由Apache软件基金会维护，是Lucene项目的一部分。它提供了高效、可扩展的搜索和导航功能...熟悉这些知识点，可以帮助你更好地利用Apache Solr构建高性能的企业级搜索解决方案。

    solr（solr-9.0.0.tgz）

    总的来说，Solr-9.0.0是一个强大且灵活的搜索平台，适用于需要大量数据搜索和分析的场景，如电商网站的商品搜索、新闻网站的内容检索、企业内部的文档搜索等。通过深入理解和熟练使用Solr，你可以为你的应用程序提供...

    solr资料以及问题汇总

    Solr是Apache软件基金会的一个开源项目，它是基于Java的全文搜索服务器，采用了Lucene库作为其...通过深入学习和实践这些内容，开发者可以掌握如何利用Solr构建高性能的全文搜索引擎，解决各种实际问题，提升系统性能。

    solr搜索引擎的使用介绍

    Solr搜索引擎的使用介绍 Solr，全称为Apache Solr，是Apache软件基金会的一个开源项目，基于Java开发，是一款...通过理解其核心概念、特性以及应用场景，我们可以充分利用Solr来提升系统的搜索性能，优化用户体验。

    solr

    根据提供的信息，我们可以总结出以下关于Apache Solr的相关知识点： ### Apache Solr简介 Apache Solr是一款开源的、高性能的企业级...在Java开发环境下，利用Solr进行高效的搜索服务构建是完全可行且易于实现的。

    开源企业搜索引擎solr的应用教程

    《开源企业搜索引擎Solr的应用教程》 在当今信息爆炸的时代，高效、精准的搜索成为企业的核心竞争力之一。开源的企业搜索引擎Solr...通过深入学习和实践，开发者能够充分利用Solr的优势，为企业构建高性能的搜索应用。

    ES和solr搜索方案对比

    ES（ElasticSearch）和Solr都是基于Lucene的搜索引擎，它们各自提供了一套搜索框架，用于实现高效的全文搜索功能。由于两者都是在Apache License 2下开源的，因此在选择使用哪种搜索方案时，需要根据不同的使用场景...

    solr（solr-9.0.0-src.tgz）源码

    Solr是Apache软件基金会的一个开源项目，它是基于Java的全文搜索服务器，被广泛应用于企业级搜索引擎的构建。源码分析是深入理解一个软件系统工作原理的重要途径，对于Solr这样的复杂系统尤其如此。这里我们将围绕...

    solr导航搜索工具+文档+配置代码

    Solr，全称为Apache Solr，是一款开源的企业级全文搜索引擎，由Java编写，它提供了高效、可扩展的搜索和分析功能。在这个“solr导航搜索工具+文档+配置代码”压缩包中，包含了Solr的相关资源，可以帮助我们快速理解...

    solr-7.7.2.zip

    Solr是中国Apache软件基金会开发的一款开源全文搜索引擎，它基于Java平台，可以实现高效、可扩展的搜索和分析功能。...通过深入理解和实践，可以进一步掌握如何利用Solr构建高性能的企业级搜索解决方案。

    solr各种最近的jar包

    Solr，全称为Apache Solr，是Apache软件基金会的一个开源项目，主要用来处理全文搜索、企业级搜索和数据索引。它基于Java平台，利用...了解它们的功能并正确使用，将有助于你有效地利用Solr进行全文搜索和数据管理。

    solr自学详细教程，吐血总结

    【Solr自学详细教程，吐血总结】 在IT领域，特别是在大数据处理和信息检索中，Apache Solr扮演着至关重要的角色。...通过学习和实践，开发者可以掌握如何利用Solr构建高性能的站内搜索，提升用户的搜索体验。

Magicbox
Global site tag (gtag.js) - Google Analytics