【springboot】【solr】springboot+solr集群

在此基础上：win10下solr7.2.1+tomcat9.0.33+zookeeper3.5.6集群

或者直接添加依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-solr</artifactId>
</dependency>

application.yml

spring:
  data:
    solr:
      host: http://127.0.0.1:8800/solr,http://127.0.0.1:8801/solr,http://127.0.0.1:8802/solr
      repositories:
        enabled: true
      zk-host: 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183

测试类

package com.xiaostudy.solr;

import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.SolrRequest;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.CloudSolrClient;
import org.apache.solr.client.solrj.request.QueryRequest;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.common.SolrDocumentList;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.io.IOException;

@SpringBootTest
class SolrApplicationTests {

    @Autowired
    private CloudSolrClient cloudSolrClient;

    @Test
    void contextLoads() {
        System.out.println(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
        SolrDocumentList query = query("id:1");
        System.out.println(query.getNumFound());
        System.out.println("<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<");
    }

    public SolrDocumentList query(String value) {
        SolrDocumentList st = null;
        SolrQuery param = new SolrQuery();
        param.setQuery( value );
        param.setRows(5);
        QueryResponse rsp = null;
        try {
            QueryRequest req = new QueryRequest( param, SolrRequest.METHOD.POST );
//            req.setBasicAuthCredentials("username", "password");//如果有密码的话
            cloudSolrClient.setDefaultCollection("test2");
            rsp = req.process(cloudSolrClient);
            st = rsp.getResults();
        } catch (SolrServerException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return st;
    }

}

 

 

 

 

 

 

另外：单机版

application.yml

spring:
  data:
    solr:
      host: http://127.0.0.1:8080/solr

测试类

package com.xiaostudy.solr;

import org.apache.solr.client.solrj.SolrClient;
import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.SolrRequest;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.common.SolrDocumentList;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.io.IOException;

@SpringBootTest
class SolrApplicationTests {

    @Autowired
    private SolrClient solrClient;

    @Test
    void contextLoads() {
        System.out.println(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
        SolrDocumentList query = query("id:2");
        System.out.println(query.getNumFound());
        System.out.println("<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<");
    }

    public SolrDocumentList query(String value) {
        SolrDocumentList st = null;
        SolrQuery param = new SolrQuery();
        param.setQuery( value );
        param.setRows(5);
        try {
            QueryResponse archives = solrClient.query("test2", param, SolrRequest.METHOD.POST);
            st = archives.getResults();
        } catch (SolrServerException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return st;
    }

}