solr 的安装配置，

[-]

1. Solr简介
2. Solr与Lucene的关系
3. Solr的简单搭建运行
4. 命令测试管理索引
5. 使用SolrJ与Solr服务器交互
6. SolrJ的简介和使用
7. Solr安装插件与数据库表进行同步

Solr简介

Solr是采用Java开发，基于Lucene的全文检索服务器，同时对其进行了扩展，提供了比Lucene更为丰富的查询语言，同时实现了可配置、可扩展并对查询性能进行了优化，并且提供了一个完善的功能管理界面，是一款非常优秀的全文搜索引擎。 Solr是一个独立的企业级搜索应用服务器，它对外提供类似于Web-Service的API接口，用户可以通过http请求，向搜索引擎服务器提交一定格式的XML文件，生成索引，也可以通过Http G Solret操作提出查找请求，并得到XML格式的返回结果。

Solr与Lucene的关系

Lucene是一套信息检索工具包，但是并不包含搜索引擎系统，它包含了索引结构、读写索引工具、相关性工具、排序等功能，因此在使用Lucene时仍需要关注搜索引擎系统，例如数据获取、解析、分词方面的东西。 solr是基于Lucene开发的，Solr主要是为了打造一款企业级的搜索引擎系统，因此它更接近于常用的搜索引擎系统（百度、搜狗），它是一个搜索引擎服务，通过各种API可以让我们的应用使用搜索服务，而不需要将搜索逻辑耦合在应用中。而且solr可以根据配置文件定义数据解析的方式，更像是一个搜索框架，它也支持主从、热换库操作，还添加了高亮、facet等搜索引擎常见的功能支持。 Nutch是一款开源的Java实现的搜索引擎，它提供了我们运行自己的搜索引擎所需的全部工具。包括全文检索和web爬虫。常用来使用Nutch做爬虫。

Solr的简单搭建运行

Solr 下载地址：http://archive.apache.org/dist/lucene/solr/ 下载解压后的目录：
配置步骤： 1.解压solr-4.7.0.zip到你想到存放的路径，比如当前用户根目录/Users/liuxun/solr-4.7.0
2.cmd打开命令行窗口，进入/Users/liuxun/solr-4.7.0/example目录
3.执行命令：java -jar start.jar
4.通过第三步以后，系统会启动solr自带的jetty服务器，通过    http://localhost:8983/solr/便可访问solr。
此时，solr已成功启动

操作界面说明：



等等还有查询 界面使用并不麻烦

命令测试管理索引

(一) 创建索引 此时solr已安装并启动，但是还没有索引，只有创建好索引，搜索才能有结果
1、命令进入/solr-4.6.0/example/exampledocs目录
2、执行命令：java -jar post.jar solr.xml monitor.xml，此时你已成功提交了2个solr文档
3、执行完第二步后，我们可以通过浏览器访问：http://localhost:8983/solr/collection1/select?q=solr&wt=xml
如果你想导入更多的文档，执行命令：java -jar post.jar *.xml
(二)更新索引 当重复执行命令：java -jar post.jar *.xml后，发现搜索的结果没有出现重复的数据，原因：example目录下的schema.xml中指定了列id为uniqueKey（即：唯一），所以重复提交数据到索引库时，id相同的数据会替换原来document中的数据。
如果想要得到重复的数据，可以通过修改exampledocs目录下*.xml中id值的方式实现
(三)删除索引 1、执行命 令：
java -Ddata=args -Dcommit=false -jar post.jar “<delete><id>SP2514N</id></delete>”，可以删除id为 SP2514N的document
2、执行第一步后，再去搜索发现搜索结果中还有id为SP2514N的数据，其实不是第一步没有删除成功，因为第一步的命令中-Dcommit=false，所以第一步的删除操作没有提交到索引（index）中。
3、在没有打开新的searcher之前，第一步删除数据会一直存在于搜索结果中，所以我们可以强制打开一个新的searcher，执行命令：java -jar post.jar -
(四)查询索引 solr通过http以get的方式进行搜索数据，如：http://localhost:8983/solr/collection1/select?q=solr&wt=xml
q：查询的关键词(此时查询的字段是solrconfig.xml中指定的默认查询字段<str name=”df”>text</str>)
fl：搜索结果返回的字段
sort：排序
wt：搜索结果返回格式
q=video&fl=name,id (return only name and id fields) 
q=video&fl=name,id,score (return relevancy score as well) 
q=video&fl=*,score (return all stored fields, as well as relevancy score) 
q=video&sort=price desc&fl=name,id,price (add sort specification: sort by price descending) 
q=video&wt=json (return response in JSON format) 

使用SolrJ与Solr服务器交互

我们要使用Solr服务，可以直接使用urlconnecion按照规则去调用Solr服务的接口，如果是web应用除了可以使用URLConnection在后台调用外还可以使用AJAX技术(XmlHttpRequest)调用，但是需要自己封装数据，解析数据，非常麻烦。 SolrJ提供了针对各种客户端的API，可以省去这些繁琐的步骤，面向API编程 直接与Solr服务器进行交互。

SolrJ的简介和使用：

solrj是solr的java客户端，用于访问solr索引库。
它提供了添加、删除、查询、优化等功能。 
Jar 包位置
解压目录:
它是集成到solr压缩包里的，解压文件后，有个目录/dist/，里面就存放了solrj所用到的jar(/dist/solrj-lib/*.jar和/dist/*.jar)，把这些所有的jar都添加到项目中的classpath就可以直接开发了。 Demo示例如下(以上传GitHub https://github.com/LX1993728/SolrJ_java_Test) Product.java [java] view plain copy

1. public class Product {  
2.     //Field中的value要遵循核心中schema中<fields>的规则  
3.     @Field(value="id")  
4.       
5.     private String id;  
6.       
7.     @Field(value="name")  
8.     private String name;  
9.       
10.     @Field(value="description")  
11.     private String desc;  
12.       
13.     @Field(value="price")  
14.     private float price;  
15.        // setter  getter  
16.        // ......  
17. }  

@Field 表示 当前属性与索引库中哪个已经声明的字段名相对应  （具体规则由schema指定） SolrDao.java （索引的增删改查） [java] view plain copy

1. package liuxun.solrj.dao;  
2.   
3. import java.io.IOException;  
4. import java.util.List;  
5. import java.util.Map;  
6.   
7. import org.apache.solr.client.solrj.SolrQuery;  
8. import org.apache.solr.client.solrj.SolrServer;  
9. import org.apache.solr.client.solrj.SolrServerException;  
10. import org.apache.solr.client.solrj.impl.HttpSolrServer;  
11. import org.apache.solr.client.solrj.response.QueryResponse;  
12. import org.apache.solr.common.SolrDocument;  
13. import org.apache.solr.common.SolrDocumentList;  
14. import org.apache.solr.common.SolrInputDocument;  
15.   
16. import liuxun.solrj.bean.Product;  
17.   
18. /** 
19.  * 使用solrJ 向solr 提交请求，增删改查， solrJ 底层页是发送http 协议... 
20.  *  
21.  * @author liuxun 
22.  */  
23. public class SolrDao {  
24.     // 在solr 当中有一些默认的字段和动态字段规则，配置在文件/example/solr/collection1/conf/schema.xml  
25.   
26.     // 添加默认索引属性  
27.     public void addDefaultField() throws SolrServerException, IOException {  
28.         // 声明要连接solr服务器的地址  
29.         String url = "http://localhost:8983/solr";  
30.         SolrServer solr = new HttpSolrServer(url);  
31.         SolrInputDocument doc = new SolrInputDocument();  
32.         doc.addField("id", "默认情况下必须添加的字段，用来区分文档的唯一标识");  
33.         doc.addField("name", "默认的名称属性字段");  
34.         doc.addField("description", "默认的表示描述信息的字段");  
35.         solr.add(doc);  
36.   
37.         solr.commit();  
38.     }  
39.   
40.     // 添加动态索引属性  
41.     public void addDynamicField() throws SolrServerException, IOException {  
42.         // 声明要连接solr服务器的地址  
43.         String url = "http://localhost:8983/solr";  
44.         SolrServer solr = new HttpSolrServer(url);  
45.   
46.         SolrInputDocument doc = new SolrInputDocument();  
47.         doc.addField("id", "adwweqwewe");  
48.         doc.addField("nam_s", "动态字段的StringField类型格式为*_s");  
49.         doc.addField("desc_s", "动态字段的TextField类型格式为*_t");  
50.         solr.add(doc);  
51.         solr.commit();  
52.     }  
53.   
54.     // 添加索引  
55.     public void addIndex(Product product) throws SolrServerException, IOException {  
56.         // 声明要连接solr服务器的地址  
57.         String url = "http://localhost:8983/solr";  
58.         SolrServer solr = new HttpSolrServer(url);  
59.         solr.addBean(product);  
60.         solr.commit();  
61.     }  
62.   
63.     // 更新索引  
64.     public void updateIndex(Product product) throws IOException, SolrServerException {  
65.         // 声明要连接solr服务器的地址  
66.         String url = "http://localhost:8983/solr";  
67.         SolrServer solr = new HttpSolrServer(url);  
68.         solr.addBean(product);  
69.         solr.commit();  
70.     }  
71.   
72.     // 删除索引  
73.     public void delIndex(String id) throws SolrServerException, IOException {  
74.         // 声明要连接solr服务器的地址  
75.         String url = "http://localhost:8983/solr";  
76.         SolrServer solr = new HttpSolrServer(url);  
77.         solr.deleteById(id);  
78.         // solr.deleteByQuery("id:*");  
79.         solr.commit();  
80.     }  
81.   
82.     // 查找索引  
83.     public void findIndex() throws SolrServerException {  
84.         // 声明要连接solr服务器的地址  
85.         String url = "http://localhost:8983/solr";  
86.         SolrServer solr = new HttpSolrServer(url);  
87.   
88.         // 查询条件  
89.         SolrQuery solrParams = new SolrQuery();  
90.         solrParams.setStart(0);  
91.         solrParams.setRows(10);  
92.         solrParams.setQuery("name:苹果 +description:全新4G");  
93.         // 开启高亮  
94.         solrParams.setHighlight(true);  
95.         solrParams.setHighlightSimplePre("<font color='red'>");  
96.         solrParams.setHighlightSimplePost("</font>");  
97.   
98.         // 设置高亮的字段  
99.         solrParams.setParam("hl.fl", "name,description");  
100.         // SolrParams是SolrQuery的子类  
101.         QueryResponse queryResponse = solr.query(solrParams);  
102.   
103.         // (一)获取查询的结果集合  
104.         SolrDocumentList solrDocumentList = queryResponse.getResults();  
105.   
106.         // (二)获取高亮的结果集  
107.         // 第一个Map的键是文档的ID，第二个Map的键是高亮显示的字段名  
108.         Map<String, Map<String, List<String>>> highlighting = queryResponse.getHighlighting();  
109.   
110.         for (SolrDocument solrDocument : solrDocumentList) {  
111.             System.out.println("=====" + solrDocument.toString());  
112.             Map<String, List<String>> fieldsMap = highlighting.get(solrDocument.get("id"));  
113.             List<String> highname = fieldsMap.get("name");  
114.             List<String> highdesc = fieldsMap.get("description");  
115.             System.out.println("highname======" + highname);  
116.             System.out.println("highdesc=====" + highdesc);  
117.         }  
118.   
119.         // (三) 将响应结果封装到Bean  
120.         List<Product> products = queryResponse.getBeans(Product.class);  
121.   
122.         System.out.println(products + "+++++++++++");  
123.         for (Product product : products) {  
124.             System.out.println(product);  
125.         }  
126.     }  
127. }  

测试： SolrDaoTest [java] view plain copy

1. package liuxun.solrj.junit;  
2.   
3. import static org.junit.Assert.*;  
4.   
5. import java.io.IOException;  
6.   
7. import org.apache.solr.client.solrj.SolrServerException;  
8. import org.junit.Before;  
9. import org.junit.Test;  
10.   
11. import liuxun.solrj.bean.Product;  
12. import liuxun.solrj.dao.SolrDao;  
13.   
14. public class SolrDaoTest {  
15.   
16.     private SolrDao solrDao = new SolrDao();  
17.       
18.     @Test  
19.     public void testAddDefaultField() throws SolrServerException, IOException {  
20.         solrDao.addDefaultField();  
21.     }  
22.   
23.     @Test  
24.     public void testAddDynamicField() throws SolrServerException, IOException {  
25.         solrDao.addDynamicField();  
26.     }  
27.   
28.     @Test  
29.     public void testAddIndex() throws SolrServerException, IOException {  
30.         for(int i=1;i<=2;i++){  
31.             Product product=new Product();  
32.             product.setId(String.valueOf(i));  
33.             product.setName("苹果（Apple）iPhone 5c 16G版 3G手机（白色）电信版");  
34.             product.setDesc("选择“购机送费版”北京用户享全新4G合约套餐资费全网最低！");  
35.             product.setPrice(9f);  
36.             solrDao.addIndex(product);  
37.         }  
38.     }  
39.   
40.     @Test  
41.     public void testUpdateIndex() throws IOException, SolrServerException {  
42.         Product product=new Product();  
43.         product.setId(String.valueOf(2));  
44.         product.setName("毛衣的毛衣黑色毛衣");  
45.         product.setDesc("女士专用 三点不漏..");  
46.         product.setPrice(9f);  
47.         solrDao.updateIndex(product);  
48.     }  
49.   
50.     @Test  
51.     public void testDelIndex() throws SolrServerException, IOException {  
52.         solrDao.delIndex("2");  
53.     }  
54.   
55.     @Test  
56.     public void testFindIndex() throws SolrServerException {  
57.         solrDao.findIndex();  
58.     }  
59.   
60. }  

控制台打印：
在solr图形界面搜索：

Solr安装插件与数据库表进行同步

修改solrconfig.xml,添加下面这段代码： 
[html] view plain copy

1. <requestHandler name="/dataimport" class="org.apache.solr.handler.dataimport.DataImportHandler">  
2.     <lst name="defaults">  
3.       <str name="config">data-config.xml</str>  
4.     </lst>  
5. </requestHandler>    

然后再solrconfig.xml文件统计的目录下新增上面声明的data-config.xml。内容如下： [html] view plain copy

1. <?xml version="1.0" encoding="UTF-8" ?>    
2. <dataConfig>     
3. <dataSource type="JdbcDataSource"     
4.           driver="com.mysql.jdbc.Driver"     
5.           url="jdbc:mysql://localhost:3306/solr_test"     
6.           user="root"     
7.           password="root"/>     
8. <document>     
9.     <entity name="id" query="select id,name,manu from solr" dataSource="JdbcDataSource"></entity>     
10. </document>     
11. </dataConfig>   

因为需要连接数据库所以需要连接数据库的jar 包，以及操作索引库的jar 包，在collection 下面创建lib 目录将jar 包拷贝到lib 目录下 (solr-dataimporthandler-4.7.0，solr-dataimporthandler-extras-4.7.0以及连接mysql 的jar 包) 配置的目录如下

测试导入：
查询是否导入成功 转载：http://blog.csdn.net/u013087513/article/details/76034373?locationNum=3&fps=1点击打开链接