diff --git a/src/main/java/com/jmfy/controller/MsgController.java b/src/main/java/com/jmfy/controller/MsgController.java index 1ab9af0..7fe6801 100644 --- a/src/main/java/com/jmfy/controller/MsgController.java +++ b/src/main/java/com/jmfy/controller/MsgController.java @@ -57,7 +57,7 @@ public class MsgController { throw new Exception("serverAddress not exist"); } String thriftIp = rpcString.split(":")[0]; - String thriftPort = String.valueOf(7901); + String thriftPort = rpcString.split(":")[1]; if (thriftIp == null || thriftIp.isEmpty() || null == thriftPort || thriftPort.isEmpty()) { return -1; } else { diff --git a/src/main/java/com/jmfy/handler/GMHandler.java b/src/main/java/com/jmfy/handler/GMHandler.java index d481f5b..2a8a136 100644 --- a/src/main/java/com/jmfy/handler/GMHandler.java +++ b/src/main/java/com/jmfy/handler/GMHandler.java @@ -114,7 +114,7 @@ public class GMHandler extends BaseHandler { continue; } String thriftIp = rpcString.split(":")[0]; - String thriftPort = String.valueOf(7901); + String thriftPort = rpcString.split(":")[1]; if (thriftIp == null || thriftIp.isEmpty() || null == thriftPort || thriftPort.isEmpty()) { continue; } else { @@ -142,7 +142,7 @@ public class GMHandler extends BaseHandler { throw new Exception("serverAddress not exist"); } String thriftIp = rpcString.split(":")[0]; - String thriftPort = String.valueOf(7900 + 1); + String thriftPort = rpcString.split(":")[1]; if (thriftIp == null || thriftIp.isEmpty() || null == thriftPort || thriftPort.isEmpty()) { throw new Exception("serverAddress not exist"); } else {