ApacheSolr9.1（三）集群模式下通过HttpAPI操作ApacheSolr

Solr是一个基于Apache Lucene的搜索服务器&＃xff0c;Apache Lucene是开源的、基于Java的信息检索库&＃xff0c;Solr能为用户提供无论在任何时候都可以根据用户的查询请求返回结果&＃xff0c;它被设计为一个强大的文档检索引擎。
Apache Solr 9.1对外提供的客户端接口方式主要有

• 1&＃xff09;. SolrJ&＃xff1a; 此方案也是官方建议采用的方案。
  优点&＃xff1a;集成简单、方便&＃xff0c;接口都已被进行了高度封装&＃xff0c;使用起来非常方便、简便&＃xff1b;
  缺点&＃xff1a;对JDK版本有要求&＃xff0c;不能低于JDK11,导致应用程序还未升级到JDK11的将无法使用SolrJ;
• 2&＃xff09;. HttpUrl: 此方案通过GET、POST、DELETE等方式通过提交http Url就可以实现所有的接口功能&＃xff1b;
  优点&＃xff1a;对JDK版本无要求&＃xff0c;只要通过http客户端通过url&＃43;参数值的方式与solr服务交互&＃xff0c;无技术难度&＃xff1b;
  缺点&＃xff1a;相对SolrJ来说&＃xff0c;对接口调用略显繁琐&＃xff0c;主要代码量集中于Http客户端&＃xff0c;接口部分主要是封装JSON或XML的参数&＃xff1b;
• 本文将针对Solr服务提供Http接口进行验证。

Apache Solr系列文章&＃xff1a;
1、Apache Solr 9.1-&＃xff08;一&＃xff09;初体验单机模式运行
2、Apache Solr 9.1-&＃xff08;二&＃xff09;集群模式运行
3、Apache Solr 9.1-&＃xff08;三&＃xff09;集群模式下通过Http API操作Apache Solr

1、各组件版本说明

2、部署架构

3、硬件环境准备

4、各服务器节点服务部署情况

5、Apache Solr 9.1集群模式环境搭建

关与Apache Solr 9.1集群模式环境搭建请参见【Apache Solr 9.1-&＃xff08;二&＃xff09;集群模式运行】

1、Zookeeper可视化客户端 - ZooInspector

说明&＃xff1a;
ZooInspector提供的功能&＃xff1a;
1&＃xff09;. 连接/断开Zookeeper服务&＃xff08;单节点服务或集群服务&＃xff09;&＃xff1b;
2&＃xff09;. 查看Zookeeper服务中存放的目录和文件及内容&＃xff1b;
3&＃xff09;. 新建节点&＃xff1b;
4&＃xff09;. 删除节点&＃xff1b;

1&＃xff09;、下载

点击此处【ZooInspector】进行下载

2&＃xff09;、运行

解压后进入build目录&＃xff0c;执行:

java -jar zookeeper-dev-ZooInspector.jar


说明&＃xff1a;
Connect String&＃xff1a;Zookeeper服务器地址
1&＃xff09;. 如果Zookeeper服务是单节点&＃xff0c;则在Connect String处只写一个ip:端口即可&＃xff1b;
2&＃xff09;. 如果Zookeeer服务是集群模式&＃xff0c;则在Connect String处需要将所有节点的地址都写上&＃xff0c;并以[,]号分隔&＃xff1b;

连接成功如下图所示&＃xff1a;

2、将本地配置文件、目录上传到zookeeper集群服务指定的目录下

在本节中实现上传文件和目录主要是通过Apache Solr中自带的zookeeper客户端工具脚本zkcli.sh¹&＃xff0c;与Zookeeper安装目录下zkCli.sh²是不同的脚本&＃xff0c;本节中使用的是zkcli.sh&＃xff0c;并不是Zookeeper的zkCli.sh。

1&＃xff09;、将本地配置文件上传到zookeeper集群服务指定的目录下

[root&＃64;hnode1 solr]# cd /opt/solr/solr-9.1.0/server/scripts/cloud-scripts
[root&＃64;hnode1 cloud-scripts]# ./zkcli.sh -zkhost hnode1:2181,hnode2:2181,hnode3:2181 -cmd putfile /solr/configs/_default/managed-schema.xml /opt/solr/conf/managed-schema.xml


2&＃xff09;、将本地配置文件整个目录上传到zookeeper集群服务指定的目录下

在本例中将演示将本地/opt/solr/conf整个目录下的文件上传到zookeeper集群服务的/solr/configs/chatmessage目录下&＃xff0c;且/solr/configs/chatmessage节点不需要提前创建

[root&＃64;hnode1 solr]# cd /opt/solr/solr-9.1.0/server/scripts/cloud-scripts
# 下面通过zkcli.sh脚本连接zookeeper服务的/solr/目录下后&＃xff0c;将本地/opt/solr/conf/目录下所有文件以配置文件的方式上传到/solr/configs/chatmessage节点下
[root&＃64;hnode1 cloud-scripts]# ./zkcli.sh -zkhost hnode1:2181,hnode2:2181,hnode3:2181/solr -cmd upconfig -confdir /opt/solr/conf -confname chatmessage


关与Collection详细的接口说明请参见【Apache Solr 9.1 Collection管理文档】

1、创建Collection

v2版接口

curl -X POST http://localhost:8983/api/collections -H &＃39;Content-Type: application/json&＃39; -d &＃39;
{
"create": {
"name": "chatmessage",
"config": "chatmessage",
"numShards": 1
}
}


• 上面接口参数中config参数指定的就是Zookeeper服务上存放的此collection对应的配置节点名称&＃xff0c;如果不指定将从_default下复制一份做为此collection的配置,当删除此collection时&＃xff0c;新复制的配置目录也会一起被删除&＃xff1b;
• 创建Collection的前提是需要先在Zookeeper集群服务上存在对应此Collection的配置&＃xff0c;所以创建collection的时候&＃xff0c;如果zookeeper上无此collection的配置&＃xff0c;需要先将配置上传到zookeeper集群上&＃xff1b; 上传方法参见本文 【二、Zookeeper管理 -> 2、将本地配置文件、目录上传到zookeeper集群服务指定的目录下 -> 2&＃xff09;、将本地配置文件整个目录上传到zookeeper集群服务指定的目录下】 的具体操作&＃xff1b;

2、删除Collection

curl -X DELETE http://localhost:8983/api/collections/collection名称


3、获取所有Collection

curl -X GET http://localhost:8983/api/collections


返回结果&＃xff1a;

{
"responseHeader":{
"status":0,
"QTime":2011},
"collections":["collection1",
"example1",
"example2"]}


4、备份Collection

curl -X POST http://localhost:8983/api/collections -H &＃39;Content-Type: application/json&＃39; -d &＃39;
{
"backup-collection": {
"name": "techproducts_backup",
"collection": "techproducts",
"location": "file:///path/to/my/shared/drive"
}
}
&＃39;


5、获取每次备份的信息

curl -X POST http://localhost:8983/v2/collections/backups -H &＃39;Content-Type: application/json&＃39; -d &＃39;
{
"list-backups" : {
"name": "myBackupName",
"location": "/path/to/my/shared/drive"
}
}
&＃39;


6、将备份还原到Collection中

可以将备份的Collection的索引数据和关联的配置还原到指定的Collection中

curl -X POST http://localhost:8983/v2/collections/backups -H &＃39;Content-Type: application/json&＃39; -d &＃39;
{
"list-backups" : {
"name": "myBackupName",
"location": "/path/to/my/shared/drive"
}
}
&＃39;


7、删除备份文件

curl -X POST http://localhost:8983/v2/collections/backups -H &＃39;Content-Type: application/json&＃39; -d &＃39;
{
"delete-backups" : {
"name": "myBackupName",
"location": "/path/to/my/shared/drive",
"backupId": 0
}
}
&＃39;

四、Document的操作接口

Apache Solr 9.1 插入、更新、删除Document记录使用的URL都是&＃xff1a;http://solr服务ip:端口/solr/collection名称/update

1、批量插入数据

例如&＃xff1a;

curl -X POST -H &＃39;Content-Type: application/json&＃39; &＃39;http://localhost:8983/solr/my_collection/update&＃39; --data-binary &＃39;
[
{
"id": "1",
"title": "Doc 1"
},
{
"id": "2",
"title": "Doc 2"
}
]&＃39;


2、删除数据

1&＃xff09;. 根据主键、ID删除Document

例如&＃xff1a;[删除id值为ID的Document]

curl -X POST -H &＃39;Content-Type: application/json&＃39; &＃39;http://localhost:8983/solr/my_collection/update&＃39; --data-binary &＃39;
{"delete": { "id":"ID" }}&＃39;


2&＃xff09;. 根据查询条件删除Document

例如&＃xff1a;[删除所有isRead字段值为0的Document]

curl -X POST -H &＃39;Content-Type: application/json&＃39; &＃39;http://localhost:8983/solr/my_collection/update&＃39; --data-binary &＃39;
{"delete": {"query":"isRead:0"}}&＃39;


3、更新数据

例如&＃xff1a;

curl -X POST -H &＃39;Content-Type: application/json&＃39; &＃39;http://localhost:8983/solr/my_collection/update&＃39; --data-binary &＃39;
[
{
"id": "1",
"title": "Doc 1"
},
{
"id": "2",
"title": "Doc 2"
}
]&＃39;


4、查询数据

例如&＃xff1a;

curl http://localhost:8983/solr/my_collection/query -d &＃39;
{
"query" : "memory",
"filter" : "inStock:true"
}&＃39;