SolrJ的使用

封装了查询的关键字，查询过滤条件， 查询排序， or查询

[java] view plain copy

    SolrQuery solrQuery = new SolrQuery();  
            //solrQuery.setQuery("status:1");  
            solrQuery.set("q", "storeName:" + "麦兜");  
            solrQuery.addFilterQuery("status:" + BaseConstant.STATUS_ENABLE);  
            solrQuery.setQuery("name:连衣裙  OR storeName:8");  
            solrQuery.setSort("onlineTime", ORDER.desc);  
            //高亮  
            solrQuery.setHighlight(true);  
            solrQuery.addHighlightField("storeName");  
            solrQuery.setHighlightSimplePre("<span style='color:red'>");  
            solrQuery.setHighlightSimplePost("</span>");  
              
            Page<Goods> page = SolrUtil.getPage(new Page<Goods>(), solrQuery, Goods.class);  



在网上的搜的语法

[java] view plain copy

    //AND 并且  
        SolrQuery params = new SolrQuery("name:apple AND manu:inc");  
          
        //OR 或者  
        params.setQuery("name:apple OR manu:apache");  
        //空格 等同于 OR  
        params.setQuery("name:server manu:dell");  
          
        //params.setQuery("name:solr - manu:inc");  
        //params.setQuery("name:server + manu:dell");  
          
        //查询name包含solr apple  
        params.setQuery("name:solr,apple");  
        //manu不包含inc  
        params.setQuery("name:solr,apple NOT manu:inc");  
          
        //50 <= price <= 200  
        params.setQuery("price:[50 TO 200]");  
        params.setQuery("popularity:[5 TO 6]");  
        //params.setQuery("price:[50 TO 200] - popularity:[5 TO 6]");  
        //params.setQuery("price:[50 TO 200] + popularity:[5 TO 6]");  
          
        //50 <= price <= 200 AND 5 <= popularity <= 6  
        params.setQuery("price:[50 TO 200] AND popularity:[5 TO 6]");  
        params.setQuery("price:[50 TO 200] OR popularity:[5 TO 6]");  
          
        //过滤器查询，可以提高性能 filter 类似多个条件组合，如and  
        //params.addFilterQuery("id:VA902B");  
        //params.addFilterQuery("price:[50 TO 200]");  
        //params.addFilterQuery("popularity:[* TO 5]");  
        //params.addFilterQuery("weight:*");  
        //0 < popularity < 6  没有等于  
        //params.addFilterQuery("popularity:{0 TO 6}");  
          
        //排序  
        params.addSortField("id", ORDER.asc);  
        //分页：start开始页，rows每页显示记录条数   64         //params.setStart(0);  
        //params.setRows(200);  
          
        //设置高亮  
        params.setHighlight(true); // 开启高亮组件  
        params.addHighlightField("name");// 高亮字段  
        params.setHighlightSimplePre("<font color='red'>");//标记，高亮关键字前缀  
        params.setHighlightSimplePost("</font>");//后缀  
        params.setHighlightSnippets(1);//结果分片数，默认为1  
        params.setHighlightFragsize(1000);//每个分片的最大长度，默认为100  
       
      

案例使用：搜索框和筛选

public class ResultModel {

    //总记录数
    private Long recordCount;
    //每页数量
    private Integer perCount = 20;
    //当前页数
    private Integer curPage = 0;
    //商品列表
    private List<Product> productList;
    
    public Long getRecordCount() {
        return recordCount;
    }
    public void setRecordCount(Long recordCount) {
        this.recordCount = recordCount;
    }
    public Integer getPerCount() {
        return perCount;
    }
    public void setPerCount(Integer perCount) {
        this.perCount = perCount;
    }
    public Integer getPageCount() {
        if (recordCount % perCount == 0)
            return (int) (recordCount / perCount);
        else 
            return (int) (recordCount / perCount) + 1;
    }
    public Integer getCurPage() {
        return curPage;
    }
    public void setCurPage(Integer curPage) {
        this.curPage = curPage;
    }
    public List<Product> getProductList() {
        return productList;
    }
    public void setProductList(List<Product> productList) {
        this.productList = productList;
    }
}


@Service
public class MyServiceImpl implements MyService {
    
    @Autowired
    private HttpSolrServer solrServer;

    @Override
    public ResultModel queryProducts(String keywords, String catalogName, String priceArea, String sort,
            Integer pageNum) throws Exception {
        
        //结果保存域
        ResultModel resultModel = new ResultModel();
        
        SolrQuery query = new SolrQuery();
        //设置默认查询域
        query.set("df", "product_keywords");
        //设置查询关键字
        query.setQuery(StringUtils.isEmpty(keywords) ? "*:*" : "keywords");
        //添加过滤条件
        if (StringUtils.isEmpty(catalogName))
            query.addFilterQuery("product_catalog_name:" + catalogName);
        if (StringUtils.isEmpty(priceArea)) {
            String[] prs = priceArea.split("-");
            if (prs .length == 2)
                query.addFilterQuery("product_price:[" + prs[0] + " TO " + prs[1] + "]");
            else
                query.addFilterQuery("product_price:[" + prs[0] + " TO *]");
        }
        //排序条件
        if (StringUtils.isEmpty(sort))
            query.addSort("product_price", "1".equals(sort)? ORDER.desc : ORDER.asc);
        
        //设置查询页数
        query.setRows(resultModel.getPageCount());            
        if (pageNum != null) {
            query.setStart(resultModel.getPageCount() * (pageNum - 1));
        } else {
            query.setStart(0);
        }
        
        //设置信息高亮
        query.setHighlight(true);
        query.addHighlightField("product_name");
        query.setHighlightSimplePre("<font color='red'>");
        query.setHighlightSimplePost("</font>");
        
        //获取查询结果
        QueryResponse response = solrServer.query(query);
        //获取结果集
        SolrDocumentList res = response.getResults();
        //获取记录总数
        long rocoderNum = res.getNumFound();
        //获取高亮信息结果集
        Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();
        //获取商品列表
        List<Product> pros = new ArrayList<>();
        for (SolrDocument doc : res) {
            Product p = new Product();
            p.setPid(doc.get("id").toString());
            p.setCatalog_name(doc.get("product_catalog_name").toString());
            p.setPrice(Float.parseFloat(doc.get("product_price").toString()));
            p.setPicture(doc.get("product_picture").toString());
            
            //名称高亮
            List<String> list = highlighting.get("id").get("product_name");
            if (list != null) 
                p.setName(list.get(0));
            
            pros.add(p);
        }
        
        //保存结果
        resultModel.setCurPage(pageNum);
        resultModel.setRecordCount(rocoderNum);
        resultModel.setProductList(pros);
        
        return resultModel;
    }
    
    
}

注意：Solr7之后，HttpSolrServer已经没有了，取而代之是HttpSolrClient，而且创建方式也变了，使用Builder模式创建，所以这里用到了工厂方法

<!-- 配置SolrServer对象 实例工厂 -->
    <!-- 单机版 -->
    <bean id="httpSolrClientBuilder" class="org.apache.solr.client.solrj.impl.HttpSolrClient.Builder">
        <constructor-arg name="baseSolrUrl" value="${SOLR.SERVER.URL}"/>
    </bean>
    <bean id="httpSolrClient" factory-bean="httpSolrClientBuilder" factory-method="build"/>
    

资源配置文件中：单机版需要指定solrcore
SOLR.SERVER.URL = xxxxx:8983/solr/core1