solr与java整合使用

1.新建工程，此处示例只新建一个java工程

2.导入jar包，所有jar包都在下载好的solr压缩包中，可直接导入，注意示例图中的jar包路径

3.新建一个class类测试，代码如下

package com.kwm.solr.test;

import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.common.SolrDocument;
import org.apache.solr.common.SolrDocumentList;

/**
 * solr测试
 * @author Ankang
 *
 */
public class SolrTest {
    private final static String url = "http://localhost:8081/solr/";
    
    public static void main(String[] args) {
        SolrTest st = new SolrTest();
        try {
            st.querySolr();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    public HttpSolrServer createSolrServer(){
        HttpSolrServer hss = new HttpSolrServer(url);
        return hss;
    }
    
    public void querySolr() throws Exception{
        HttpSolrServer hss = new HttpSolrServer(url + "collection1/");
        SolrQuery sq = new SolrQuery();
        sq.set("q", "FileContent:西瓜");
        sq.setHighlight(true);//设置高亮
        QueryResponse response = hss.query(sq);
        SolrDocumentList sdl = response.getResults();
        
        System.out.println("查询结果的总数量"+sdl.getNumFound());
        for(SolrDocument sd : sdl){
            System.out.println("FileContent:"+sd.get("FileContent"));
        }
    }
}

solr7.7.2版本后可使用此类进行 solr检索

    /**
     * 执行solr查询
     * @return
     * @throws Exception
     */
    public JSONObject querySolr() throws Exception{
        JSONObject jsonObject = new JSONObject();
        List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
        
        HttpSolrClient hss = new HttpSolrClient.Builder(url+"solr0705/").build();
        StringBuilder stringBuilder = new StringBuilder();
        SolrQuery sq = new SolrQuery();
        
        String fc1 = "note:资生堂";
        String fc2 = "note:落合因人事变动";
        String fc3 = "note:となりました";
        
        if(!fc1.equals("")) stringBuilder.append(fc1);
        if(!fc2.equals("")) stringBuilder.append(" "+fc2); 
        if(!fc3.equals("")) stringBuilder.append(" "+fc3);
        
        sq.set("q", stringBuilder.toString());//查询条件
//        sq.set("df", "note");
//        sq.set("fq", stringBuilder2.toString());//过滤条件
        sq.set("defType","edismax");
        sq.set("qf","note^10.0");
//        sq.set("sort", "note asc");
        sq.setStart(0);
        sq.setRows(30);
//        sq.set("df", "note");
        sq.setHighlight(true);//设置高亮
        long starttime = System.currentTimeMillis();
        QueryResponse response = hss.query(sq);
        long endtime = System.currentTimeMillis();
        System.out.println("执行程序时间======>>>>> "+(endtime-starttime));
        System.out.println("查询用时==========>>>>>>> "+response.getQTime()+" ms");
        SolrDocumentList sdl = response.getResults();
        System.out.println("查询结果的总数量=======>>>>>>>>> "+sdl.getNumFound()+"条");
        if(sdl.size() > 0){
            for(SolrDocument sd : sdl){
                Map<String, Object> map = new HashMap<String, Object>();
                
                map.put("mainfilenumber", sd.get("mainfilenumber").toString());
                map.put("subfilenumber", sd.get("subfilenumber").toString());
                map.put("note", sd.get("note").toString());
                
//                map.put("weituorjh", sd.get("weituorjh").toString());
                
                list.add(map);
            }
            jsonObject.element("result", list);
        }
        return jsonObject;
    }

如果在 q 中的查询条件太长的话，可用此种形式查询并且用配置权重的方式进行检索查询

sq.set("q", stringBuilder.toString());
sq.setStart(0);
sq.setRows(10);
sq.set("df", "weituorjh");
sq.set("defType","edismax");
sq.set("qf","weituorjh^10.0");
sq.setSort("weituorjh", ORDER.desc);
sq.setHighlight(true);

如需其他操作，可在代码中直接调用即可

Solr 利用 java 代码进行增删改查操作

HttpSolrClient hss = new HttpSolrClient.Builder(url+"solr0705/").build();
        StringBuilder stringBuilder = new StringBuilder();
//        StringBuilder stringBuilder2 = new StringBuilder();
        
        SolrQuery sq = new SolrQuery();
        
        //根据ID删除数据
        hss.deleteById(new ArrayList<String>(){{add("AJ19115075");}});
        hss.commit();
        
        //添加索引数据
        SolrInputDocument sid = new SolrInputDocument();
        sid.addField("id", "AJ19115099");
        sid.addField("weituorjh", "2019109736119");
        hss.add(sid);
        hss.commit();

另附详细参考链接  https://blog.csdn.net/shao_zhiqiang/article/details/51879763