lxy/zhub-client
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

新增：1、ZhubClient 构造方法，支持 new 的方式初始化实例（一般在测试时使用）2、initClient 方法逻辑微调，确保实例完成初始化在执行队列数据处理

Browse Source
This commit is contained in:
梁显优 2023-05-25 17:53:37 +08:00
parent 8316fce151
commit 318a8ff299
2 changed files with 19 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/com/zdemo/cachex/RedisTest.java
View File

@ -3,8 +3,6 @@ package com.zdemo.cachex;
import org.redkale.convert.json.JsonFactory; import org.redkale.convert.json.JsonFactory;
import org.redkale.util.AnyValue; import org.redkale.util.AnyValue;
import java.util.Map;
public class RedisTest { public class RedisTest {
static MyRedisCacheSource<String> source = new MyRedisCacheSource(); static MyRedisCacheSource<String> source = new MyRedisCacheSource();
@ -115,9 +113,14 @@ public class RedisTest {
System.out.println(source.getCollectionSize("sk")); // 2*/ System.out.println(source.getCollectionSize("sk")); // 2*/
Map<String, String> hms = source.getHms("supportusers", "5-kfeu0f", "xxxx", "3-0kbt7u8t", "95q- "); /*Map<String, String> hms = source.getHms("supportusers", "5-kfeu0f", "xxxx", "3-0kbt7u8t", "95q- ");
hms.forEach((k, v) -> { hms.forEach((k, v) -> {
System.out.println(k + " : " + v); System.out.println(k + " : " + v);
});*/
source.queryKeysStartsWith("ywb:").forEach(x -> {
System.out.println(x);
source.remove(x);
}); });

22
src/com/zdemo/zhub/ZHubClient.java
View File

@ -30,7 +30,6 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
private String auth = ""; private String auth = "";
private String groupid = ""; private String groupid = "";
//private ReentrantLock lock = new ReentrantLock();
private Socket client; private Socket client;
private OutputStream writer; private OutputStream writer;
private BufferedReader reader; private BufferedReader reader;
@ -41,16 +40,21 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
private final LinkedBlockingQueue<Event<String>> rpcCallQueue = new LinkedBlockingQueue<>(); // RPC CALL MSG private final LinkedBlockingQueue<Event<String>> rpcCallQueue = new LinkedBlockingQueue<>(); // RPC CALL MSG
private final LinkedBlockingQueue<String> sendMsgQueue = new LinkedBlockingQueue<>(); // SEND MSG private final LinkedBlockingQueue<String> sendMsgQueue = new LinkedBlockingQueue<>(); // SEND MSG
/*private BiConsumer<Runnable, Integer> threadBuilder = (r, n) -> {
for (int i = 0; i < n; i++) {
new Thread(() -> r.run()).start();
}
};*/
/*private static boolean isFirst = true;
private boolean isMain = false;*/
private static Map<String, ZHubClient> mainHub = new HashMap<>(); // 127.0.0.1:1216 - ZHubClient private static Map<String, ZHubClient> mainHub = new HashMap<>(); // 127.0.0.1:1216 - ZHubClient
public ZHubClient() {
}
public ZHubClient(String name, Map<String, String> attr) {
this.APP_NAME = name;
this.addr = attr.get("addr");
this.groupid = attr.get("groupid");
this.auth = attr.get("auth");
this.init(null);
}
@Override @Override
public void init(AnyValue config) { public void init(AnyValue config) {
if (!preInit()) { if (!preInit()) {