solr java demo 基础入门

    <!--solr的maven依赖-->
    <dependencies>
        <dependency>
            <groupId>org.apache.solr</groupId>
            <artifactId>solr-solrj</artifactId>
            <version>4.10.2</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.11</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>1.7.7</version>
        </dependency>
        <dependency>
            <groupId>commons-logging</groupId>
            <artifactId>commons-logging</artifactId>
            <version>1.1.3</version>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>3.3.2</version>
        </dependency>
    </dependencies>

//pojopackage com.j1.solrj.pojo;import org.apache.solr.client.solrj.beans.Field;public class Foo {    @Field("id")
    private String  id;    @Field("title")
    private String title;    public String getId() {
        return id;
    }    public void setId(String id) {
        this.id = id;
    }    public String getTitle() {
        return title;
    }    public void setTitle(String title) {
        this.title = title;
    }    @Override
    public String toString() {
        StringBuilder builder = new StringBuilder();
        builder.append("Foo [id=");
        builder.append(id);
        builder.append(", title=");
        builder.append(title);
        builder.append("]");
        return builder.toString();
    }}

//Servicepackage com.j1.solrj.service;import java.util.ArrayList;
import java.util.List;
import java.util.Map;import org.apache.commons.lang3.StringUtils;
import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.client.solrj.response.QueryResponse;import cn.itcast.solrj.pojo.Foo;public class SolrjService {    // 定义http的solr服务
    private HttpSolrServer httpSolrServer;    public SolrjService(HttpSolrServer httpSolrServer) {
        this.httpSolrServer = httpSolrServer;
    }    /**
     * 新增数据到solr服务
     *
     * @param foo
     * @throws Exception
     */
    public void add(Foo foo) throws Exception {
        this.httpSolrServer.addBean(foo); //添加数据到solr服务器
        this.httpSolrServer.commit(); //提交
    }    public void delete(List<String> ids) throws Exception {
        this.httpSolrServer.deleteById(ids);
        this.httpSolrServer.commit(); //提交
    }    public List<Foo> search(String keywords, Integer page, Integer rows) throws Exception {
        List<Foo> foos=new   ArrayList <Foo> ();
        SolrQuery solrQuery = new SolrQuery(); //构造搜索条件
        solrQuery.setQuery("title:" + keywords); //搜索关键词
        // 设置分页 start=0就是从0开始，，rows=5当前返回5条记录，第二页就是变化start这个值为5就可以了。
        solrQuery.setStart((Math.max(page, 1) - 1) * rows);
        solrQuery.setRows(rows);        //是否需要高亮
        boolean isHighlighting = !StringUtils.equals("*", keywords) && StringUtils.isNotEmpty(keywords);        if (isHighlighting) {
            // 设置高亮
            solrQuery.setHighlight(true); // 开启高亮组件
            solrQuery.addHighlightField("title");// 高亮字段
            solrQuery.setHighlightSimplePre("<em>");// 标记，高亮关键字前缀
            solrQuery.setHighlightSimplePost("</em>");// 后缀
        }        // 执行查询
        QueryResponse queryResponse = this.httpSolrServer.query(solrQuery);
        try{
            foos = queryResponse.getBeans(Foo.class);
        }catch(Exception e){
            e.printStackTrace();
        }        if (isHighlighting) {
            // 将高亮的标题数据写回到数据对象中
            Map<String, Map<String, List<String>>> map = queryResponse.getHighlighting();
            for (Map.Entry<String, Map<String, List<String>>> highlighting : map.entrySet()) {
                for (Foo foo : foos) {
                    if (!highlighting.getKey().equals(foo.getId().toString())) {
                        continue;
                    }
                    foo.setTitle(StringUtils.join(highlighting.getValue().get("title"), ""));
                    break;
                }
            }
        }        return foos;
    }}

//test 测试package com.j1.solrj.service;import java.io.IOException;
import java.lang.reflect.Array;
import java.util.Arrays;
import java.util.List;import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.client.solrj.impl.XMLResponseParser;
import org.junit.Before;
import org.junit.Test;import cn.itcast.solrj.pojo.Foo;public class SolrjServiceTest {    private SolrjService solrjService;    private HttpSolrServer httpSolrServer;    @Before
    public void setUp() throws Exception {
        // 在url中指定core名称：taotao
       // String url = "http://solr.taotao.com/taotao";
        String url = "http://solr.taotao.com/taotao";
        HttpSolrServer httpSolrServer = new HttpSolrServer(url); //定义solr的server
        httpSolrServer.setParser(new XMLResponseParser()); // 设置响应解析器
        httpSolrServer.setMaxRetries(1); // 设置重试次数，推荐设置为1
        httpSolrServer.setConnectionTimeout(500); // 建立连接的最长时间        this.httpSolrServer = httpSolrServer;
        solrjService = new SolrjService(httpSolrServer);
    }    @Test
    public void testAdd() throws Exception {
        Foo foo = new Foo();
        foo.setId("1425954987819");
        foo.setTitle("new - 轻量级Java EE企业应用实战（第3版）：Struts2＋Spring3＋Hibernate整合开发（附CD光盘）");
      try{
          this.solrjService.add(foo);
      }catch(Exception e){
        e.printStackTrace();
      }    }    @Test
    public void testDelete() throws Exception {
        this.solrjService.delete(Arrays.asList("1425954987818"));
    }    @Test
    public void testSearch() throws Exception {
        List<Foo> foos = this.solrjService.search("new", 1, 10);
        for (Foo foo : foos) {
            System.out.println(foo);
        }
    }    @Test
    public void testDeleteByQuery() throws Exception{
        httpSolrServer.deleteByQuery("title:轻量级Java");
        httpSolrServer.commit();
    }}