com.xjeffrose.xio.core.ZkClient.fromExhibitor()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(1.6k)|赞(0)|评价(0)|浏览(188)

本文整理了Java中com.xjeffrose.xio.core.ZkClient.fromExhibitor()方法的一些代码示例,展示了ZkClient.fromExhibitor()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkClient.fromExhibitor()方法的具体详情如下:
包路径:com.xjeffrose.xio.core.ZkClient
类名称:ZkClient
方法名:fromExhibitor

ZkClient.fromExhibitor介绍

暂无

代码示例

代码示例来源:origin: xjdr/xio

  1. public static ZkClient buildZkClient(ApplicationConfig applicationConfig) {
  2. String zookeeperCluster = applicationConfig.getZookeeperCluster();
  3. ZkClient zkClient;
  4. if (zookeeperCluster.isEmpty()) {
  5. zkClient = new NullZkClient();
  6. } else {
  7. if (zookeeperCluster.startsWith("exhibitor:")) {
  8. String[] values = zookeeperCluster.replace("exhibitor:", "").split(":");
  9. int restPort = Integer.parseInt(values[0]);
  10. Collection<String> serverSet = Arrays.asList(values[1].split(","));
  11. zkClient = ZkClient.fromExhibitor(serverSet, restPort);
  12. } else {
  13. zkClient = new ZkClient(zookeeperCluster);
  14. }
  15. }
  16. return zkClient;
  17. }

代码示例来源:origin: xjdr/xio

  1. @Test
  2. public void testFromExhibitor() throws Exception {
  3. MockWebServer server = new MockWebServer();
  4. server.enqueue(
  5. new MockResponse()
  6. .setBody(
  7. "count=5&server0=10.10.1.1&server1=10.10.1.2&server2=10.10.1.3&server3=10.10.1.4&server4=10.10.1.5&port=2181")
  8. .setHeader("Content-Type", "application/x-www-form-urlencoded"));
  9. server.start();
  10. ZkClient client = ZkClient.fromExhibitor(Arrays.asList("127.0.0.1"), server.getPort());
  11. assertEquals(
  12. "10.10.1.1:2181,10.10.1.2:2181,10.10.1.3:2181,10.10.1.4:2181,10.10.1.5:2181",
  13. client.getConnectionString());
  14. server.shutdown();
  15. }

相关文章