tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-08-07 04:24:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf[orm]: 简化测试用例

Browse Source
This commit is contained in:
jaysunxiao
2021-07-10 11:49:27 +08:00
parent 2be46dfce9
commit 835f5cfec0
3 changed files with 50 additions and 134 deletions
Download Patch File Download Diff File Expand all files Collapse all files
net/src/test/java/com/zfoo/net/zookeeper/curator/cache/CuratorCacheTest.java
Vendored
+50
View File
@@ -0,0 +1,50 @@
package com.zfoo.net.zookeeper.curator.cache;
import com.zfoo.util.ThreadUtils;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.cache.ChildData;
import org.apache.curator.framework.recipes.cache.CuratorCache;
import org.apache.curator.framework.recipes.cache.CuratorCacheListener;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.junit.Ignore;
import org.junit.Test;
/**
* @author jaysunxiao
* @version 1.0
* @since 2019-08-25 09:43
*/
@Ignore
public class CuratorCacheTest {
private static CuratorFramework curator = CuratorFrameworkFactory.builder()
.connectString("localhost:2181")
.sessionTimeoutMs(5000)
.retryPolicy(new ExponentialBackoffRetry(1000, 3))
// .retryPolicy(new RetryNTimes(1, 1000))
.build();
@Test
public void test() {
curator.start();
var curatorCache = CuratorCache.builder(curator, "/test")
.withExceptionHandler(e -> e.printStackTrace())
.build();
curatorCache.start();
//节点变化的监听器
curatorCache.listenable().addListener(new CuratorCacheListener() {
@Override
public void event(Type type, ChildData oldData, ChildData data) {
System.out.println("pathCache ------ Type:" + type + ",");
System.out.println(data);
}
});
ThreadUtils.sleep(Long.MAX_VALUE);
}
}
net/src/test/java/com/zfoo/net/zookeeper/curator/cache/PathCacheTest.java
Vendored
-63
View File
@@ -1,63 +0,0 @@
package com.zfoo.net.zookeeper.curator.cache;
import com.zfoo.util.ThreadUtils;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.cache.PathChildrenCache;
import org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent;
import org.apache.curator.framework.recipes.cache.PathChildrenCacheListener;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.junit.Ignore;
import org.junit.Test;
/**
* @author jaysunxiao
* @version 1.0
* @since 2019-08-25 09:43
*/
@Ignore
public class PathCacheTest {
private static CuratorFramework curator = CuratorFrameworkFactory.builder()
.connectString("localhost:2181")
.sessionTimeoutMs(5000)
.retryPolicy(new ExponentialBackoffRetry(1000, 3))
// .retryPolicy(new RetryNTimes(1, 1000))
.build();
@Test
public void test() {
curator.start();
PathChildrenCache pathCache = new PathChildrenCache(curator, "/test", true);
try {
pathCache.start();
} catch (Exception e) {
e.printStackTrace();
}
//节点变化的监听器
pathCache.getListenable().addListener(new PathChildrenCacheListener() {
@Override
public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception {
System.out.println("pathCache ------ Type:" + event.getType() + ",");
System.out.println(event.getData().getPath());
}
});
while (true) {
ThreadUtils.sleep(3000);
try {
pathCache.getCurrentData().stream()
.forEach(it -> System.out.println(it.getPath() + "->" + it.getData()));
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
net/src/test/java/com/zfoo/net/zookeeper/curator/cache/TreeCacheTest.java
Vendored
-71
View File
@@ -1,71 +0,0 @@
package com.zfoo.net.zookeeper.curator.cache;
import com.zfoo.util.ThreadUtils;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.api.UnhandledErrorListener;
import org.apache.curator.framework.recipes.cache.TreeCache;
import org.apache.curator.framework.recipes.cache.TreeCacheEvent;
import org.apache.curator.framework.recipes.cache.TreeCacheListener;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.junit.Ignore;
import org.junit.Test;
/**
* @author jaysunxiao
* @version 1.0
* @since 2019-08-25 09:43
*/
@Ignore
public class TreeCacheTest {
private static CuratorFramework curator = CuratorFrameworkFactory.builder()
.connectString("localhost:2181")
.sessionTimeoutMs(5000)
.retryPolicy(new ExponentialBackoffRetry(1000, 3))
// .retryPolicy(new RetryNTimes(1, 1000))
.build();
@Test
public void test() {
curator.start();
TreeCache treeCache = new TreeCache(curator, "/test");
try {
treeCache.start();
} catch (Exception e) {
e.printStackTrace();
}
//添加错误监听器
treeCache.getUnhandledErrorListenable().addListener(new UnhandledErrorListener() {
public void unhandledError(String s, Throwable throwable) {
System.out.println(".错误原因：" + throwable.getMessage() + "\n==============\n");
}
});
//节点变化的监听器
treeCache.getListenable().addListener(new TreeCacheListener() {
public void childEvent(CuratorFramework curatorFramework, TreeCacheEvent treeCacheEvent) throws Exception {
System.out.println("treeCache ------ Type:" + treeCacheEvent.getType() + ",");
System.out.println(treeCacheEvent.getData().getPath());
}
});
while (true) {
ThreadUtils.sleep(3000);
try {
System.out.println("-------->" + treeCache.getCurrentData("/test/a"));
treeCache.getCurrentChildren("/test").entrySet().stream()
.forEach(it -> System.out.println(it.getKey() + "->" + it.getValue()));
} catch (Exception e) {
e.printStackTrace();
}
}
}
}