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
分享到:
相关推荐
### Solr 学习笔记:关键命令使用说明 Solr 是一个开源的、高性能的全文检索引擎,基于 Java 开发,常被用于大型网站的搜索系统。本文将围绕给定内容中的关键命令进行详细的解析,主要包括 Solr 的启动、集群管理、...
在本篇Solr学习笔记中,我们将探讨Solr的分布式索引功能,这对于处理大量数据和实现高可用性至关重要。Solr的分布式索引能力允许我们跨越多个节点分布和处理索引过程,从而提高索引速度和查询性能。在实际应用中,这...
solr 学习笔记主要涵盖了 Solr 的基本安装与配置,以及 Solr 服务器复制的配置,这些都是初学者需要掌握的基础知识。 Solr 是一款基于 Lucene 的全文搜索引擎,广泛应用于大数据检索和文本分析。在安装 Solr 时,...
`xufuli.txt`可能是一个用户自定义的文档,可能是Solr学习笔记、配置示例或者使用心得。不过,由于具体内容未知,这里无法详细展开。 总之,Solr 4.10.3是一个强大且灵活的搜索引擎,适用于各种规模的企业级应用。...
doc.addField("title", "Solr学习笔记"); client.add(doc); client.commit(); ``` 对于查询操作,你可以使用`SolrQuery`类来构造查询条件,然后调用`query()`方法执行查询: ```java SolrQuery query = new ...
**Lucene学习笔记** Lucene是一个高性能、全文检索库,由Apache软件基金会开发并维护,是Java编程语言中广泛使用的搜索引擎库。它提供了一个简单但功能强大的API,用于索引和搜索文本数据,使得开发者可以轻松地在...
对于中文文档,通常使用第三方开发的分词器,如IK分词器,它可以根据中文语言特点进行更合理的分词处理。 - **查询机制**:Lucene使用TermQuery进行查询。Term代表文档中最小的分词单位。查询时,系统会根据输入的...
这篇工作笔记涵盖了从编程语言、版本控制、构建工具到持续集成、数据库管理和消息队列等多个领域的知识。以下是对这些知识点的详细解释: 1. 图灵源码中心:这是一个提供高质量源码学习资源的平台,对开发者深入...
压缩包中的“Nutch.pdf”可能是Nutch的官方文档、教程或者是博主整理的学习笔记。这份PDF文档通常会详细讲解Nutch的架构、工作流程、配置方法,以及一些示例和最佳实践。学习者可以通过阅读这份文档,系统地了解...