Skip to content

B
byit-myth-job
Commit c303fc0a by huangfusuper
Options

修正注册key

parent fe63e138
Showing with 12 additions and 3 deletions
byit-myth-rpc/src/main/java/com/byit/rpc/remoting/provider/RpcProviderFactory.java
...@@ -153,10 +153,10 @@ public class RpcProviderFactory { ...@@ -153,10 +153,10 @@ public class RpcProviderFactory {
Matcher matcher = PATTERN_SERVER_NANE_REG.matcher(entry.getKey()); Matcher matcher = PATTERN_SERVER_NANE_REG.matcher(entry.getKey());
//提供http请求还是rpc服务 //提供http请求还是rpc服务
if(matcher.find()) { if(matcher.find()) {
if(!Boolean.parseBoolean(matcher.group(1))){ if(!Boolean.parseBoolean(matcher.group(2))){
keyServerAddress.put(matcher.group(0), serviceAddress); keyServerAddress.put(matcher.group(1), serviceAddress);
}else { }else {
keyServerAddress.put(matcher.group(0),httpServiceAddress); keyServerAddress.put(matcher.group(1),httpServiceAddress);
} }
}else{ }else{
logger.error("-----------{},注册失败-----",entry); logger.error("-----------{},注册失败-----",entry);
...@@ -184,6 +184,15 @@ public class RpcProviderFactory { ...@@ -184,6 +184,15 @@ public class RpcProviderFactory {
server.start(this); server.start(this);
} }
public static void main(String[] args) {
Matcher matcher = PATTERN_SERVER_NANE_REG.matcher("huangfu[true]");
if (matcher.find()) {
System.out.println(matcher.group(0));
System.out.println(matcher.group(1));
System.out.println(matcher.group(2));
}
}
public void stop() throws Exception { public void stop() throws Exception {
// stop server // stop server
server.stop(); server.stop();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment