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

新增：zhub 验权处理

Browse Source
This commit is contained in:
梁显优 2022-06-23 19:41:21 +08:00
parent dd0521a983
commit 1171304a04
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
conf/application.xml
View File

@ -4,7 +4,7 @@
<zhubs>
<!--<zhub name="zhub" addr="47.111.150.118" port="6066" groupid="group-zhub"/>-->
<zhub name="zhub" addr="127.0.0.1:1216" groupid="group-zhub"/>
<zhub name="zhub" addr="127.0.0.1:1216" groupid="group-zhub" auth="zchd@123456"/>
</zhubs>
<resources>

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

@ -33,7 +33,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
public Logger logger = Logger.getLogger(ZHubClient.class.getSimpleName());
private String addr = "127.0.0.1:1216";
//private String password = "";
private String auth = "";
private String groupid = "";
//private ReentrantLock lock = new ReentrantLock();
@ -73,6 +73,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
addr = addr + ":" + port;
}
auth = config.getOrDefault("auth", auth);
groupid = config.getValue("groupid", groupid);
}
@ -169,7 +170,10 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
String topic = reader.readLine(); // name
timerQueue.add(timerMap.get(topic));
continue;
}
logger.finest(readLine);
} catch (IOException e) {
if (e instanceof SocketException) {
initSocket(Integer.MAX_VALUE);
@ -344,6 +348,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
if (groupid == null || groupid.isEmpty()) {
throw new RuntimeException("ZHubClient groupid can not is empty");
}
send("auth", auth);
send("groupid " + groupid);
StringBuffer buf = new StringBuffer("subscribe lock");