“Java 操作 ZooKeeper”的版本间的差异

来自姬鸿昌的知识库
跳到导航 跳到搜索
（页面内容被替换为“=== Java 连接 ZooKeeper ===”）
第1行： 第1行：
 
=== Java 连接 ZooKeeper ===
 
=== Java 连接 ZooKeeper ===
−
 
−
==== 创建 Maven 工程 ====
 
−
 
−
==== 导入依赖 ====
 
−
<syntaxhighlight lang="xml">
 
−
    <dependencies>
 
−
 
−
        <dependency>
 
−
            <groupId>org.apache.zookeeper</groupId>
 
−
            <artifactId>zookeeper</artifactId>
 
−
            <version>3.6.0</version>
 
−
        </dependency>
 
−
 
−
        <dependency>
 
−
            <groupId>org.apache.curator</groupId>
 
−
            <artifactId>curator-recipes</artifactId>
 
−
            <version>4.0.1</version>
 
−
        </dependency>
 
−
 
−
        <dependency>
 
−
            <groupId>junit</groupId>
 
−
            <artifactId>junit</artifactId>
 
−
            <version>4.12</version>
 
−
            <scope>test</scope>
 
−
        </dependency>
 
−
    </dependencies>
 
−
</syntaxhighlight>
 
−
 
−
 
−
==== 编写连接 ZooKeeper 集群的工具类 ====
 
−
<syntaxhighlight lang="java">
 
−
package org.example;
 
−
 
−
import org.apache.curator.RetryPolicy;
 
−
import org.apache.curator.framework.CuratorFramework;
 
−
import org.apache.curator.framework.CuratorFrameworkFactory;
 
−
import org.apache.curator.retry.ExponentialBackoffRetry;
 
−
 
−
public class ZkUtil {
 
−
 
−
    public static CuratorFramework cf() {
 
−
 
−
        //间隔 3 秒，重试2次之后失败报错
 
−
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 2);
 
−
 
−
        CuratorFramework cf = CuratorFrameworkFactory.builder()
 
−
                .connectString("192.168.137.200:2181,192.168.137.200:2182,192.168.137.200:2183")
 
−
                .retryPolicy(retryPolicy)
 
−
                .build();
 
−
        cf.start();
 
−
        return cf;
 
−
    }
 
−
 
−
}
 
−
 
−
</syntaxhighlight>
 
−
 
−
 
−
==== 测试 ====
 
−
<syntaxhighlight lang="java">
 
−
package org.example;
 
−
 
−
import org.apache.curator.framework.CuratorFramework;
 
−
import org.junit.Test;
 
−
 
−
public class Demo1 {
 
−
 
−
    @Test
 
−
    public void connect() {
 
−
        CuratorFramework cf = ZkUtil.cf();
 
−
    }
 
−
}
 
−
 
−
</syntaxhighlight>
 
−
[[文件:ZooKeeper测试.png|无|缩略图|700x700像素]]
 

2022年8月17日 (三) 11:05的版本

Java 连接 ZooKeeper

取自“https://www.jihongchang.top/index.php?title=Java_操作_ZooKeeper&oldid=766”