首先在application.properties添加配置
# 重试次数
curator.retryCount=5
# 重试间隔
curator.elapsedTimeMs=5000
# zookeeper地址
curator.connectString=127.0.0.1:2181
# session超时时间
curator.sessionTimeoutMs=60000
# 连接超时时间
curator.connectionTimeoutMs=5000
创建WrapperZK来读取配置文件
@Data
@Component
@ConfigurationProperties(prefix = "curator")
public class WrapperZK {
private int retryCount;
private int elapsedTimeMs;
private String connectString;
private int sessionTimeoutMs;
private int connectionTimeoutMs;
}
注意 curator，就是配置文件的前缀，然后会发现idea会提示未配置Srping Boot 配置注解处理器
解决办法:在pom文件中添加下面的依赖即可
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-configuration-processor</artifactId>
<optional>true</optional>
</dependency>
使用
@Configuration
public class CuratorConfig {
@Autowired
private WrapperZK wrapperZK;
@Bean
public CuratorFramework curatorFramework(){
return CuratorFrameworkFactory.newClient(wrapperZK.getConnectString(),
wrapperZK.getSessionTimeoutMs(),
wrapperZK.getConnectionTimeoutMs(),
new RetryNTimes(wrapperZK.getRetryCount(), wrapperZK.getElapsedTimeMs()));
}
}
测试
@Autowired
private CuratorFramework curatorFramework;
/**
* 创建节点
*/
@Test
public void createNode(){
try {
//start()开始连接，没有此会报错
//java.lang.IllegalStateException: Expected state [STARTED] was [LATENT]
curatorFramework.start();
// 阻塞直到连接成功
curatorFramework.blockUntilConnected();
//添加持久节点
String path = curatorFramework.create(). forPath("/node1");
// 添加临时序号节点
String path2 = curatorFramework.create().withMode(CreateMode.EPHEMERAL_SEQUENTIAL).forPath("/node2", "node2".getBytes());
System.out.println(String.format("path:%s,path2:%s,successful",path,path2));
//让系统在这里阻塞不退出
System.in.read();
} catch (Exception e) {
throw new RuntimeException(e);
}
}
