javaAPI调用solrcloud上传配置和删除/创建集合。网上大多都是通过http路径调用创建,以下是通过Zookeeper+solr进行操作:
public class SolrConfig { static String ZK_HOST="10.8.177.204:2181,10.8.177.210:2181,10.8.177.33:2181,10.8.177.22:2181"; static SolrZkClient zkClient=new SolrZkClient(ZK_HOST,30000); static ZkConfigManager zkConfigManager=new ZkConfigManager(zkClient); /** * 上传配置 * @param configName * @param configPath * @throws IOException */ public static void uploadConfig(String configName,String configPath)throws IOException{ System.out.println("准备上传配置:"+configName); zkConfigManager.uploadConfigDir(Paths.get(configPath),configName); System.out.println("上传配置成功!"); } /** * 删除集合 * @param deleteName * @throws IOException * @throws SolrServerException */ public static void deleteCollection(String deleteName)throws IOException,SolrServerException{ SolrClient solrClient=new CloudSolrClient(ZK_HOST); CollectionAdminRequest.Delete delete=new CollectionAdminRequest.Delete(); delete.setCollectionName(deleteName); CollectionAdminResponse response=delete.process(solrClient); System.out.println(response); solrClient.close(); } /** * 创建集合 * @param collectionName * @param configName * @throws IOException * @throws SolrServerException */ public static void createCollection(String collectionName,String configName)throws IOException,SolrServerException{ SolrClient solrClient=new CloudSolrClient(ZK_HOST); CollectionAdminRequest.Create create=new CollectionAdminRequest.Create(); create.setConfigName(configName); create.setCollectionName(collectionName); create.setNumShards(4);//分片 create.setMaxShardsPerNode(4);//每个节点最多持有片 create.setReplicationFactor(2);//复制 CollectionAdminResponse response=create.process(solrClient); System.out.println(response); solrClient.close(); } public static void main(String[] args){ try { String collectionName="shb1026"; String config="solrAndHbase"; // String configPath = "G:\\config\\solr_conf\\nlp\\"; // uploadConfig(config, configPath); // deleteCollection(collectionName); createCollection(collectionName,config); }catch (Exception e){ e.printStackTrace(); } } }
相关推荐
solrcloud5结合zookeeper搭建、使用详解,是一部难得的好教程
solrcloud与zookeeper
该项目旨在帮助在Docker环境中尝试最新版本SolrCloud(和Zookeeper)的开发人员和新手。 此项目的版本完全基于较新的Solr和Zookeeper官方图像。 先决条件 Mac-OS或Linux环境 泊坞窗最新版本- 多克尔-撰写最新...
Win7 下面 安装solrCloud5.2.1 + tomcat7 + zookeeper3.4.6 集成。 有安装步骤,裁图和说明 1分物超所值 哈哈
该项目旨在帮助在Kubernetes环境中尝试使用最新版本的SolrCloud(和Zookeeper)的开发人员和新手。 在这里,您将发现基本上两种不同的配置: 一个(或多个)Solr实例和一个Zookeeper配置为“独立”节点 一个(或多...
java中zookeeper使用学习总结:zk的应用领域,zk的数据结构,使用zk实现分布式锁
使用dubbo+zookeeper搭建的分布式代码案例,包含全套的代码和分布式集成的说明文档。
使用JAVA代码实现zookeeper服务的节点删除功能,代码带有注释简单易懂
java代码-使用java解决JEESZ-Zookeeper集群安装的源代码 ——学习参考资料:仅用于个人学习使用!
有java连接zookeeper所需的基本jar包,共拥有9个jar包,例如常用的log4j.jar,junit.jar,还有必要的zookeeper.jar
5、zookeeper的java -Curator(服务注册与发现)...该示例会涉及到本专栏下的其他文章,比如:4、zookeeper的java三种客户端介绍-Curator(crud、事务操作、监听、分布式计数器、分布式锁) 等文章,都是在该专栏下的。
ZooInspector是一个java编写的zookeeper可视化工具,可以查看一些节点信息,使用简单,相当与远程连接到zookeeper,在定位一些相关问题时候特别实用
dubbo+zookeeper案例,dubbo和Zookeeper详解,Java源码
该项目通过zookeeper三个节点Node服务客户端代码,实现zookeeper集群管理与Master选举功能示例,项目结构如下图所示,其中依赖包包含:log4j-1.2.14.jar、slf4j-api-1.7.2.jar、slf4j-log4j12-1.7.2.jar、zookeeper-...
Dubbo+zookeeper调用java接口 简单的Demo 内有运行需要的jar包
ZooKeeper 客户端的使用(二).
通过java客户端创建zk节点,变更节点,利用zk的watcher机制测试zk集群下的数据一致性,事务锁等机制。
基于对Paxos 算法的实现,使该框架保证了分布式环境中数据的强一致性,也正是基于这样的特性,使得zookeeper 能够应用于很多场景。网上对zk的使用场景也有不少介绍,本文将结合作者身边的项目例子,系统的对zk 的...
NULL 博文链接:https://chengjianxiaoxue.iteye.com/blog/2277358
4. 使用伪代码简述mapreduce的流程和中间结果 其中input和output都是fileinputformat和fileoutputformat 5. 编写程序实现倒排索引 首先准备数据:1.txt,文件内容如下: The Apache Hadoop software library is a ...