0. 引言

我们前面学习了solr的服务端基础操作，实际项目中我们还需要在客户端调用solr，就像调用数据库一样，我们可以基于solrJ来实现对solr的客户端操作

1. SolrJ简介

SolrJ 是 Solr官方提供的 Java 客户端库，主要用于与 Solr 服务器进行交互。内部封装了一组API，可以方便地实现对solr服务端的各类操作。

使用 SolrJ，可以通过编写 Java 代码来实现对 Solr 的索引操作，比如增删改查。同时，SolrJ 还支持多种查询方式，如简单查询、复杂查询、分页查询、聚合查询等。同时也包括了对solr的索引管理、权限控制等操作

2. 项目引入SolrJ

1、引入jar包：https://central.sonatype.com/artifact/org.apache.solr/solr-solrj/8.2.0

<dependency><groupId>org.apache.solr</groupId><artifactId>solr-solrj</artifactId><version>8.2.0</version>
</dependency>

2、首先创建实体类，还是以我们在前几节创建的orders核心为例

注意：这里需要给字段上加上@Field注解，其值是该字段在solr中的字段名

@Data
public class Orders {@Field("id")private Long id;@Field("order_no")private String orderNo;@Field("address")private String address;@Field("product_name")private String productName;@Field("remarks")private String remarks;@Field("status")private Integer status;@Field("create_user")private String createUser;@Field("create_time")private Date createTime;@Field("labels")private List<String> labels;}

3、创建一个配置类SolrProperties，用户声明配置项

@ConfigurationProperties(prefix = "solr")
@Component
@Data
public class SolrProperties {private String host;private Integer connectionTimeout;private Integer socketTimeout;}

4、配置文件中添加对应的配置项

# solr地址
solr.host=http://192.168.244.41:8983/solr
# 连接超时
solr.connectionTimeout=10000
# 读取超时
solr.socketTimeout=3000

5、创建bean配置类SolrConfig，用于创建solr连接bean，注意这里我们演示的是单机版的solr，集群版的需要使用CloudSolrClient

@Configuration
public class SolrConfig {@Resourceprivate SolrProperties solrProperties;@Beanpublic HttpSolrClient solrClient(){return new HttpSolrClient.Builder(solrProperties.getHost()).withConnectionTimeout(solrProperties.getConnectionTimeout()).withSocketTimeout(solrProperties.getSocketTimeout()).build();}
}

6、创建一个测试controller，用于演示客户端的操作，因为我们之前已经配置了通过dataimport自动同步mysql数据到solr。所以solr本身的增删改，我们这里就不演示了，只要删除数据库后会自动同步，主要演示实现查询操作

@RestController
@RequestMapping("orders")
@AllArgsConstructor
public class OrdersController {private final HttpSolrClient solrClient;@GetMapping("search")public List<Orders> search(String productName, String address, String remarks, String labels) throws SolrServerException, IOException {SolrQuery query = new SolrQuery();if (!StringUtils.isEmpty(productName)) {query.setQuery("product_name:" + productName);}if (!StringUtils.isEmpty(address)) {query.setQuery("address:" + address);}if (!StringUtils.isEmpty(remarks)) {query.setQuery("remarks:" + remarks);}if (!StringUtils.isEmpty(labels)) {query.setQuery("labels:" + labels);}if(StringUtils.isEmpty(query.getQuery())){query.setQuery("*:*");}query.setStart(0);query.setRows(5);QueryResponse response = solrClient.query("orders",query);List<Orders> list = response.getBeans(Orders.class);return list;}}