java 连接solrcloud_Solr 14 - SolrJ操作SolrCloud集群 (Solr的Java API)
1 pom.xml文件的配置
2 SolrJ操作SolrCloud
public class SolrCloudTest {
// ZooKeeper地址
private static String zkHostString = "10.0.20.50:2181, 10.0.20.51:2181, 10.0.20.52:2181";
// collection默认名称, 比如Solr服务器上的collection是collection_shard1_replica1, 就是去掉"_shard1_replica1"的名称
private static String defaultCollection = "my_collection";
// 客户端连接超时时间
private static int zkClientTimeout = 3000;
// ZooKeeper连接超时时间
private static int zkConnectTimeout = 3000;
// cloudSolrServer实际
private CloudSolrServer cloudSolrServer;
// 测试方法之前构造 CloudSolrServer
@Before
public void init() {
cloudSolrServer = new CloudSolrServer(zkHostString);
cloudSolrServer.setDefaultCollection(defaultCollection);
cloudSolrServer.setZkClientTimeout(zkClientTimeout);
cloudSolrServer.setZkConnectTimeout(zkConnectTimeout);
cloudSolrServer.connect();
}
// 向SolrCloud中创建索引
@Test
public void testCreateIndexToSolrCloud() throws Exception {
SolrInputDocument document = new SolrInputDocument();
document.addField("id", "100001");
document.addField("title", "李四");
cloudSolrServer.add(document);
cloudSolrServer.commit();
}
// 搜索索引
@Test
public void testSearchIndexFromSolrCloud() throws Exception {
SolrQuery query = new SolrQuery();
query.setQuery("*:*");
try {
QueryResponse response = cloudSolrServer.query(query);
SolrDocumentList docs = response.getResults();
System.out.println("文档个数: " + docs.getNumFound());
System.out.println("查询时间: " + response.getQTime());
for (SolrDocument doc : docs) {
ArrayList title = (ArrayList) doc.getFieldValue("title");
String id = (String) doc.getFieldValue("id");
System.out.println("id: " + id);
System.out.println("title: " + title);
System.out.println();
}
} catch (SolrServerException e) {
e.printStackTrace();
} catch (Exception e) {
System.out.println("Unknowned Exception!!!!");
e.printStackTrace();
}
}
// 删除索引
@Test
public void testDeleteIndexFromSolrCloud() throws Exception {
// 根据id删除
UpdateResponse response = cloudSolrServer.deleteById("zhangsan");
// 根据多个id删除
// cloudSolrServer.deleteById(ids);
// 自动查询条件删除
// cloudSolrServer.deleteByQuery("product_keywords:教程");
// 提交
cloudSolrServer.commit();
}
}
版权声明
作者: 马瘦风
出处: 博客园 马瘦风的博客
您的支持是对博主的极大鼓励, 感谢您的阅读.
本文版权归博主所有, 欢迎转载, 但请保留此段声明, 并在文章页面明显位置给出原文链接, 否则博主保留追究相关人员法律责任的权利.
java 连接solrcloud_Solr 14 - SolrJ操作SolrCloud集群 (Solr的Java API)相关推荐
- SolrCloud集群的安装使用以及Zookeeper的介绍
注:附件在最下面 SolrCloud 认识系统架构 集群概述 为什么要使用服务器集群 此前我们在进行项目的开发时,使用的标准的Javaweb的工程开发模式,这种方式使用一个服务器部署和发布服务器程序, ...
- Redis集群搭建及java连接redis
Redis集群搭建及java连接redis Redis集群分为三种: 1.主从关系模式2.Sentinel哨兵关系模式3.Cluster去中心化模式 1.主从关系模式 1.1.什么是主从模式? (1) ...
- python操作redis集群_python 连接管理作redis集群
python的redis库是不支持集群操作的,推荐库:redis-py-cluster. 安装 pip3 install redis-py-cluster 连接redis集群 #!/usr/bin/e ...
- 在IDEA中创建maven项目编写java代码操作HDFS集群
一.安装win10编译过的hadoop 1.将编译好的hadoop包放在非中文目录 2.配置HADOOP_HOME环境变量 3.将hadoop包的bin目录加到PATH环境变量中 二.在idea中创建 ...
- 大型互联网架构与集群技术(Java方向)
java架构必须掌握的几点技术? 关于学习架构,必须会的几点技术 1. java反射技术 2. xml文件处理 3. properties属性文件处理 4. 线程安全机制 5. annocation注 ...
- Solr学习(三)SolrCloud集群搭建与创建Collection
1.什么是SolrCloud SolrCloud是Solr提供的分布式搜索方案,当你需要大规模,容错,分布式索引和检索能力时使用 SolrCloud.当一个系统的索引数据量少的时候是不需要使用Solr ...
- ElasticSearch集群安装及Java客户端使用
ElasticSearch集群安装及Java客户端使用 1.传统模式安装 1.1 ElasticSearch安装 下载Es安装包 ElasticSearch的官方地址:https://www.elas ...
- 基于zookeeper的solrCloud集群搭建
转自:https://blog.csdn.net/yougoule/article/details/78445759 基于原文对实践遇到的问题稍作补充 1.安装及搭建相关环境 1.1环境准备 cen ...
- python 操作redis集群
python 操作redis集群 一.连接redis集群 python的redis库是不支持集群操作的,推荐库:redis-py-cluster,一直在维护.还有一个rediscluster库,看Gi ...
最新文章
- 为何Google将几十亿行源代码放在一个仓库?
- scipy笔记:wishart (威沙特分布)
- 龙门吊matlab,龙门吊车重物防摆双闭环PID控制设计.doc
- iOS核心动画学习整理
- 基于Salmon的转录组定量流程
- Python学习-28.Python中的列表切片
- 同步您的Google Chrome书签,主题等
- html:(1) 登录界面
- 第三节:框架前期准备篇之利用Newtonsoft.Json改造MVC默认的JsonResult
- shell 文件 开头的格式
- 【干货】从数字化洞察新消费趋势看数字化如何赋能企业.pdf(附下载链接)
- Delphi 2009 之 TStringBuilder 类[1]: Create
- python 实现注册、登录功能
- vue3 eslint吐槽记录
- java 设计模式 抽象工厂_Java设计模式----------抽象工厂模式
- 校园二手交易平台小程序《云开发演示》
- 人人都可以参与开源!龙蜥社区最不容错过的开发者活动来了
- spring注解@Lazy
- 驾照考试之科目三(深圳东周版)
- iOS开发之MOVE设计模式
热门文章
- 马斯克挽尊,回应为何电动皮卡车窗玻璃怼不过钢球...
- “浴霸”三摄出镜率真高!中兴Blade 20工信部入网
- 中国移动首款自主品牌5G手机上市:同步支持NSA/SA
- 两名黑客因发现特斯拉漏洞获Model 3一辆和3.5万美元奖金
- awk文本处理总结(入门,中级,高级)
- 人生路上必须明白的七个哲理[转]
- 各地女孩被刮开短裙的反映
- python中的urlencode和urldecode
- 栈和队列:1.栈(Stack)
- 我的docker随笔37:使用gitlab和jenkins实现CICD