`
kylinsoong
  • 浏览: 240048 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Solr学习笔记(三)Solr客户端开发实例

阅读更多

Warming Up:

本文章通过两种方法索引数据为主线,说明Solr客户端开发,两种方法分别是:直接发送XML文件到Solr服务器;通过Solrj建立客户端程序。本文分别从这两个方面各写一个例子程序;

Dependency:Solr: apache-solr-1.4.1    Tomcat: apache-tomcat-7.0.0

Note:本文谈论到不止数据索引,还包括对Solr索引数据的优化,回滚,删除等处理

 

方法1:直接发送XML文件到Solr服务器

由题目可知,直接发送数据到Solr服务器,必须和服务器建立交互关系,这里我提供的解决办法自己写一个Tomcat客户端,此客户端负责和Solr服务器(Tomcat)完成交互;另外要发送的XML必须符合一定规律,否则不能够索引,如下面所示是本文中药发送的XML,通过它我们可以简单学习这种XML的基本格式:根目录<add></add>里面包含又一系列document,而这一些列document里面又包含了各个document的一系列Field,如下代码段所示:

 

<add>
	<doc>
  	<field name="id">101</field>
  	<field name="name">kylin soong is a programmer</field>
	</doc>
	<doc>
  	<field name="id">102</field>
 	 <field name="name">kobe bryant is a basketball player</field>
	</doc>
	<doc>
  	<field name="id">103</field>
  	<field name="name">jay chou is a singer</field>
	</doc>
	<doc>
	  <field name="id">104</field>
	  <field name="name">jane zhang is a singer</field>
	</doc>	
	<doc>
	  <field name="id">105</field>
	  <field name="name">coco lee is a singer</field>
	</doc>		
	<doc>
	  <field name="id">106</field>
	  <field name="name">andy liu is a actor</field>
	</doc>
</add>

 

如上XML名为kobe.xml,会在下面的例子中看到;

TomcatClient为我自己命名的类,及相关类在附件下项目com.javaeye.solr.tomcat包下面,主要类为:TomcatClient.java,该类主要public方法如下:

public TomcatClient(String solrURL)为构造方法,通过提供字符串建立与Tomcat上SolrURL,通过此URL可以进行Stream交换

public int postFiles(String[] files, int startIndexInArgs)

public void postFile(File file, Writer output)

public void postData(Reader data, Writer output) 这三个方法都是向Solr上建立索引的方法,第一个是为一系列File建立索引,第二个为一个File建立索引,第三个是把File通过字节的形式读取传入,这个方法适合File比较小,

注意,不推荐使用第三个方法,因为第三个方法没有考虑到编码的问题,如果File中有中文就会有问题

public void commit(Writer output)

public void rollback(Writer output)

public void optimize(Writer output)

public void deleteByUniqueKey(String key, Writer output)这四个方法分别是提交,回滚、优化、删除

 

接下来我们就给出一段简单运行结果,运行j简单代码如下:

public static void main(String[] args) throws IOException {
		File file = new File("D:\\new period\\solr\\post\\kobe.xml");	
		String url = "http://localhost:8080/solr";
		
		TomcatClient client = new TomcatClient(url);
		StringWriter output = null; 
		output = new StringWriter(); 
		client.postFile(file, output);
		output = new StringWriter(); 
		client.commit(output);
	}

 接下来我们去看我们去Solr管理界面看运行结果如下图:

 

 点击查询可以看到如下结果:

  <?xml version="1.0" encoding="UTF-8" ?> 
- <response>
- <lst name="responseHeader">
  <int name="status">0</int> 
  <int name="QTime">0</int> 
- <lst name="params">
  <str name="indent">on</str> 
  <str name="start">0</str> 
  <str name="q">singer</str> 
  <str name="rows">10</str> 
  <str name="version">2.2</str> 
  </lst>
  </lst>
- <result name="response" numFound="3" start="0">
- <doc>
  <str name="id">103</str> 
  <str name="name">jay chou is a singer</str> 
  </doc>
- <doc>
  <str name="id">104</str> 
  <str name="name">jane zhang is a singer</str> 
  </doc>
- <doc>
  <str name="id">105</str> 
  <str name="name">coco lee is a singer</str> 
  </doc>
  </result>
  </response>

 

 如上结果singer出现三次分别id号:103,104,105,当然可以验证删除,优化等,这里就简要带过,不过需要注意的是对Solr服务器昨晚处理后必须调运Commit方法进行提交,不然不会起作用;

 

 方法2:Solrj建立与服务器交互

Solrj 是访问 Solr 的 Java 客户端,它提供添加、更新和查询Solr 索引的接口;下面介绍一些Solrj关键类:

1、CommonsHttpSolrServer,该类提供了一系列与Solr交互的方法,包括增、删、改、查、优化、回滚等一系列操作,

当然他还有一系列构造方法和Set方法,可以通过这些参数控制Http请求的属性,如下:

String url = "http://localhost:8080/solr";
CommonsHttpSolrServer s = new CommonsHttpSolrServer(url);
s.setConnectionTimeout(100); 
s.setDefaultMaxConnectionsPerHost(100);
s.setMaxTotalConnections(100);

 

 2、SolrInputDocument,该类实现了Map接口,可以向其中添加一系列键值对,这用来创建Lucene的Document(Solr底层是Lucene),用来建立索引;该类还实现了Iterable结构,这样可以循环输出:如下为一段测试代码:

SolrInputDocument test = new SolrInputDocument();
		test.addField("id", "sdfs");
		test.addField("name", "wee");
		test.addField("cat", "cat");
		for(Iterator iterator = test.iterator();iterator.hasNext();) {
			SolrInputField field = (SolrInputField) iterator.next();
			System.out.println(field.getName() + " - " + field.getValue());
		}

 

3、SolrQuery, Solr查询类,该类包含基本查询参数,例如"*:*"表示查询索引中所有Document;

4、QueryResponse,该类代表查询结果,它封装了一系列方法查看满足条件的Documents信息,如下代码:

SolrQuery query = new SolrQuery("*:*");
String url = "http://localhost:8080/solr";
CommonsHttpSolrServer solrServer = (CommonsHttpSolrServer) client.createNewSolrServer(url);
QueryResponse response  = commonsHttpSolrServer.query(query);
		SolrDocumentList list = response.getResults();
		System.out.println(list);

 

5,开始:SolrjClient有三类方法:启动连接Solr方法,索引数据的方法及查询索引的方法:

下面贴出一些测试代码(全部代码贱附件)

url = "http://localhost:8080/solr";
		client = new SolrjClient();
		client.startSolrServer(url);
List<SolrInputDocument> docs = new ArrayList<SolrInputDocument>();
		for (int i = 0; i < 10; i++) {
			SolrInputDocument doc = new SolrInputDocument();
			doc.addField("id", i);
			doc.addField("severity",i);
			doc.addField("sLocation","Beijing_" + i);
			doc.addField("msg", "kobe bryant" + i);
			doc.addField("name", "kylin soong" + i);
			docs.add(doc);
		}
		client.addDocs(docs);

 

如上向8080端口上服务器添加10条数据:

然后若测试查询:

String[] fields = new String[]{"id", "name", "msg"};
		List<SolrDocument> lists = client.query("kobe",10,fields);
		System.out.println(lists.size());
		for(SolrDocument doc : lists) {
			for(Iterator iterator = doc.iterator();iterator.hasNext();) {
				Map.Entry<String, Object> entry = (Entry<String, Object>) iterator.next();
				System.out.print(entry.getKey() + "=" + entry.getValue() + " ");
				//				System.out.print(iterator.next() + "   ");
			}
			System.out.println();
		}

 显示查询结果:

10
id=0 msg=kobe bryant0 name=kylin soong0 
id=1 msg=kobe bryant1 name=kylin soong1 
id=2 msg=kobe bryant2 name=kylin soong2 
id=3 msg=kobe bryant3 name=kylin soong3 
id=4 msg=kobe bryant4 name=kylin soong4 
id=5 msg=kobe bryant5 name=kylin soong5 
id=6 msg=kobe bryant6 name=kylin soong6 
id=7 msg=kobe bryant7 name=kylin soong7 
id=8 msg=kobe bryant8 name=kylin soong8 
id=9 msg=kobe bryant9 name=kylin soong9 

 

 

PS: 到此结束,可以根据附件中代码提供的测试例子进行详细研究;

 

 

 

 

 

 

 

  • 大小: 36.8 KB
分享到:
评论
1 楼 qepipnu 2014-08-25  
求solr 客户端 jar包

相关推荐

    solr学习笔记

    ### Solr 学习笔记:关键命令使用说明 Solr 是一个开源的、高性能的全文检索引擎,基于 Java 开发,常被用于大型网站的搜索系统。本文将围绕给定内容中的关键命令进行详细的解析,主要包括 Solr 的启动、集群管理、...

    Solr 学习笔记(五)-Solr扩展之分布式索引实例

    在本篇Solr学习笔记中,我们将探讨Solr的分布式索引功能,这对于处理大量数据和实现高可用性至关重要。Solr的分布式索引能力允许我们跨越多个节点分布和处理索引过程,从而提高索引速度和查询性能。在实际应用中,这...

    solr 学习笔记

    solr 学习笔记主要涵盖了 Solr 的基本安装与配置,以及 Solr 服务器复制的配置,这些都是初学者需要掌握的基础知识。 Solr 是一款基于 Lucene 的全文搜索引擎,广泛应用于大数据检索和文本分析。在安装 Solr 时,...

    solr-4.10.3.rar

    `xufuli.txt`可能是一个用户自定义的文档,可能是Solr学习笔记、配置示例或者使用心得。不过,由于具体内容未知,这里无法详细展开。 总之,Solr 4.10.3是一个强大且灵活的搜索引擎,适用于各种规模的企业级应用。...

    使用java实现solr-7.1.0的api和solr最新支持的sql查询

    doc.addField("title", "Solr学习笔记"); client.add(doc); client.commit(); ``` 对于查询操作,你可以使用`SolrQuery`类来构造查询条件,然后调用`query()`方法执行查询: ```java SolrQuery query = new ...

    lucene学习笔记

    **Lucene学习笔记** Lucene是一个高性能、全文检索库,由Apache软件基金会开发并维护,是Java编程语言中广泛使用的搜索引擎库。它提供了一个简单但功能强大的API,用于索引和搜索文本数据,使得开发者可以轻松地在...

    jt14日常笔记

    对于中文文档,通常使用第三方开发的分词器,如IK分词器,它可以根据中文语言特点进行更合理的分词处理。 - **查询机制**:Lucene使用TermQuery进行查询。Term代表文档中最小的分词单位。查询时,系统会根据输入的...

    工作笔记.docx

    这篇工作笔记涵盖了从编程语言、版本控制、构建工具到持续集成、数据库管理和消息队列等多个领域的知识。以下是对这些知识点的详细解释: 1. 图灵源码中心:这是一个提供高质量源码学习资源的平台,对开发者深入...

    分享一个Nutch入门学习的资料

    压缩包中的“Nutch.pdf”可能是Nutch的官方文档、教程或者是博主整理的学习笔记。这份PDF文档通常会详细讲解Nutch的架构、工作流程、配置方法,以及一些示例和最佳实践。学习者可以通过阅读这份文档,系统地了解...

Global site tag (gtag.js) - Google Analytics