SolrJ的使用

luinstein

SolrJ覆盖了solr的全部功能，下面将自己在实际开发中所使用的程序粘贴出来并适当加以解释，由于本人比较菜，代码书写不是那么的精练，还请见谅。

1、 创建solrserver对象：

try {

              solr = newCommonsHttpSolrServer("http://localhost:8983/solr");

              solr.setConnectionTimeout(100);

              solr.setDefaultMaxConnectionsPerHost(100);

              solr.setMaxTotalConnections(100);

       } catch (Exception e) {

              System.out.println("请检查tomcat服务器或端口是否开启!");

              e.printStackTrace();

       }

2、 添加索引

Collection<SolrInputDocument>docs = newArrayList<SolrInputDocument>();

       for (int i = 0; i < list.size(); i++) {

              Item item = list.get(i);

              //设置每个字段不得为空，可以在提交索引前进行检查

              if (CheckItem(item)) {

                     SolrInputDocument doc = new SolrInputDocument();

                     //在这里请注意date的格式，要进行适当的转化，上文已提到

                     doc.addField("id", item.getId());

                     …………

                     docs.add(doc);

              }

       }

       try {

              solr.add(docs);

              //对索引进行优化

              solr.optimize();

              solr.commit();

       } catch (Exception e) {

              e.printStackTrace();

       }

3、 使用bean对象添加索引

      创建一个对应于solr索引的类别：

      public class Item {

            @Field

            private String id;

            …………

            public void setId(String id) {

                  this.id = id;

            }

            public String getId() {

                  return id;

            }

            …………

            public Item(){

            }

      }

      使用数据创建bean对象列表，

       try{

             solr.addBeans(beansList);

             } catch (Exception e) {

                    e.printStackTrace();

             } finally {

                    try {

                           solr.optimize();

                           solr.commit();

                    } catch (Exception e) {

                           e.printStackTrace();

                    }

             }

      索引提交完毕。

4、 删除索引

      据查询结果删除：      

       try{

                    //删除所有的索引

                    solr.deleteByQuery("*:*");

                    solr.commit();

             } catch (Exception e) {

                    e.printStackTrace();

             }

      根据索引号删除索引：

      try {

                    solr.deleteById(ids);

                    solr.commit();

             } catch (Exception e) {

                    e.printStackTrace();

             }

5、 查询

      SolrJ提供的查询功能比较强大，可以进行结果中查询、范围查询、排序等。

      下面是笔者封装的一个查询函数：

1. public static QueryResponse Search(String[] field, String[] key,int start,
   
2. 
   
3.                     int count, String[] sortfield, Boolean[] flag, Boolean hightlight){
   
4. 
   
5.              //检测输入是否合法
   
6. 
   
7.              if (null == field || null == key || field.length != key.length){
   
8. 
   
9.                     return null;
   
10. 
    
11.              }
    
12. 
    
13.              if (null == sortfield || null == flag || sortfield.length !=flag.length) {
    
14. 
    
15.                     return null;
    
16. 
    
17.              }
    
18. 
    
19.              SolrQuery query = null;
    
20. 
    
21.              try {
    
22. 
    
23.                     //初始化查询对象
    
24. 
    
25.                     query = new SolrQuery(field[0] + ":" + key[0]);
    
26. 
    
27.                     for (int i = 0; i < field.length; i++) {
    
28. 
    
29.                            query.addFilterQuery(field + ":" + key);
    
30. 
    
31.                     }
    
32. 
    
33.                     //设置起始位置与返回结果数
    
34. 
    
35.                     query.setStart(start);
    
36. 
    
37.                     query.setRows(count);
    
38. 
    
39.                     //设置排序
    
40. 
    
41.                     for(int i=0; i<sortfield.length; i++){
    
42. 
    
43.                            if (flag) {
    
44. 
    
45.                                   query.addSortField(sortfield, SolrQuery.ORDER.asc);
    
46. 
    
47.                            } else {
    
48. 
    
49.                                   query.addSortField(sortfield, SolrQuery.ORDER.desc);
    
50. 
    
51.                            }
    
52. 
    
53.                     }
    
54. 
    
55.                     //设置高亮
    
56. 
    
57.                     if (null != hightlight) {
    
58. 
    
59.                            query.setHighlight(true); // 开启高亮组件
    
60. 
    
61.                            query.addHighlightField("title");// 高亮字段
    
62. 
    
63.                            query.setHighlightSimplePre("<fontcolor="red">");// 标记
    
64. 
    
65.                            query.setHighlightSimplePost("</font>");
    
66. 
    
67.                            query.setHighlightSnippets(1);//结果分片数，默认为1
    
68. 
    
69.                            query.setHighlightFragsize(1000);//每个分片的最大长度，默认为100
    
70. 
    
71.                     }
    
72. 
    
73.              } catch (Exception e) {
    
74. 
    
75.                     e.printStackTrace();
    
76. 
    
77.              }
    
78. 
    
79.              QueryResponse rsp = null;
    
80. 
    
81.              try {
    
82. 
    
83.                     rsp = solr.query(query);
    
84. 
    
85.              } catch (Exception e) {
    
86. 
    
87.                     e.printStackTrace();
    
88. 
    
89.                     return null;
    
90. 
    
91.              }
    
92. 
    
93.              //返回查询结果
    
94. 
    
95.              return rsp;
    
96. 
    
97.       }

复制代码

补充一下范围查询的格式：[star t TOend]，start与end是相应数据格式的值的字符串形式，“TO”    一定要保持大写！

6、 读取查询结果

      DocList读取返回结果：

      SolrDocumentList solrList = rsp.getResults();

      Beans读取返回结果：

      List<Item> tmpLists =rsp.getBeans(Item.class);

      读取高亮显示结果：

1. rsp = Search(field, key, 0, 10, sortfield, flag, true);
   
2. 
   
3.                     if(null == rsp){
   
4. 
   
5.                            return;
   
6. 
   
7.                     }
   
8. 
   
9.                     Map<String, Map<String,List<String>>>hightlight = rsp.getHighlighting();
   
10. 
    
11.                     //Item即为上面定义的bean类
    
12. 
    
13.                     List<Item> tmpLists =rsp.getBeans(Item.class);
    
14. 
    
15.                     for (int i = 0; i < tmpLists.size(); i++){
    
16. 
    
17.                            //hightlight的键为Item的id，值唯一，我们设置的高亮字段为title
    
18. 
    
19.                            String hlString =hightlight.get(tmpLists.get(i).getId()).get("title").toString();
    
20. 
    
21.                            if (null != hlString) {
    
22. 
    
23.                                   System.out.println(hlString);
    
24. 
    
25.                            }
    
26. 
    
27.                     }

复制代码

7、 Facet的一个应用：自动补全

1. //prefix为前缀，min为最大返回结果数
   
2. 
   
3.       public static String[] autoComplete(String prefix, int min){
   
4. 
   
5.              String words[] = null;
   
6. 
   
7.              StringBuffer sb = new StringBuffer("");
   
8. 
   
9.              SolrQuery query = new SolrQuery("*.*");
   
10. 
    
11.              QueryResponse rsp= new QueryResponse();
    
12. 
    
13.              //Facet为solr中的层次分类查询
    
14. 
    
15.              try {
    
16. 
    
17.                     query.setFacet(true);
    
18. 
    
19.                     query.setQuery("*:*");
    
20. 
    
21.                     query.setFacetPrefix(prefix);
    
22. 
    
23.                     query.addFacetField("title");
    
24. 
    
25.                     rsp = solr.query(query);
    
26. 
    
27.              } catch (Exception e) {
    
28. 
    
29.                     // TODO: handle exception
    
30. 
    
31.                     e.printStackTrace();
    
32. 
    
33.                     return null;
    
34. 
    
35.              }
    
36. 
    
37.              if(null != rsp){
    
38. 
    
39.                     FacetField ff = rsp.getFacetField("title");
    
40. 
    
41.                     List<Count> countList =ff.getValues();
    
42. 
    
43.                     if(null == countList){
    
44. 
    
45.                            return null;
    
46. 
    
47.                     }
    
48. 
    
49.                     for(int i=0; i<countList.size(); i++){
    
50. 
    
51.                            String tmp[] = countList.get(i).toString().split(" ");
    
52. 
    
53.                            //排除单个字
    
54. 
    
55.                            if(tmp[0].length()< 2){
    
56. 
    
57.                                   continue;
    
58. 
    
59.                            }
    
60. 
    
61.                            sb.append(tmp[0] + " ");
    
62. 
    
63.                            min--;
    
64. 
    
65.                            if(min == 0){
    
66. 
    
67.                                   break;
    
68. 
    
69.                            }
    
70. 
    
71.                     }
    
72. 
    
73.                     words = sb.toString().split(" ");
    
74. 
    
75.              }else{
    
76. 
    
77.                     return null;
    
78. 
    
79.              }
    
80. 
    
81.              return words;
    
82. 
    
83.       }

复制代码

二、总结
      在使用solr之前，笔者曾经用lucene与MMAnalyer自行搭建了一个索引搜索体系，由于要组合运用lucene的API，且lucene索引支持的数据格式有限，所以效率要大大低于solr，查询尚可，建立索引的速度差距尤为明显，Solr无疑是建立站内搜索等任务的首选。本人对于Solr的研究也是刚刚起步，希望能和更多的朋友交流、进步。
三、参考资料

1、 ITeye中Solr相关的网页

2、 累积：技海拾贝――Apache_Solr_初级教程.pdf

3、 solr_使用安装介绍.doc

4、 solr_DOC_CN.pdf

from:http://go.cxweb.com.cn/mkqzf