feat: add address param

Author: wardseptember

trpc-core/src/test/java/com/tencent/trpc/core/common/config/ProtocolConfigTest.java

@@ -14,9 +14,11 @@
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
 import static org.junit.Assert.assertSame;
 import static org.junit.Assert.assertTrue;
 
+import java.net.InetSocketAddress;
 import com.google.common.collect.ImmutableMap;
 import com.tencent.trpc.core.common.Constants;
 import org.junit.Test;
@@ -129,4 +131,43 @@ public void testConfig() {
         assertTrue(config.isSetDefault());
         assertSame(serviceConfig, config.getServiceConfig());
     }
+
+    @Test
+    public void testSocketAddress() {
+        ProtocolConfig config = new ProtocolConfig();
+        config.setIp("127.0.0.1");
+        config.setPort(8080);
+        config.setDefault();
+        InetSocketAddress socketAddress = config.toInetSocketAddress();
+        assertNotNull(socketAddress);
+        assertEquals("127.0.0.1", socketAddress.getHostString());
+        assertEquals(8080, socketAddress.getPort());
+    }
+
+    @Test
+    public void testSocketAddressNull() {
+        ProtocolConfig config = new ProtocolConfig();
+        config.setIp("192.168.1.1");
+        config.setPort(9090);
+        InetSocketAddress addr = config.toInetSocketAddress();
+        assertNotNull(addr);
+        assertEquals("192.168.1.1", addr.getHostString());
+        assertEquals(9090, addr.getPort());
+    }
+
+    @Test
+    public void testIpBlank() {
+        ProtocolConfig config = new ProtocolConfig();
+        assertNull(config.toInetSocketAddress());
+    }
+
+    @Test
+    public void testToString() {
+        ProtocolConfig config = new ProtocolConfig();
+        config.setIp("127.0.0.1");
+        config.setPort(8080);
+        config.setDefault();
+        String str = config.toString();
+        assertTrue(str.contains("socketAddress="));
+    }
 }

trpc-core/src/test/java/com/tencent/trpc/core/common/config/ServiceConfigTest.java

@@ -236,4 +236,17 @@ public byte[] invoke(RpcClientContext context, byte[] body) {
         config.register();
         config.unRegister();
     }
+
+    @Test
+    public void testToStringContainsAddress() {
+        ServiceConfig config = new ServiceConfig();
+        config.setName("name");
+        config.setIp("127.0.0.1");
+        config.setPort(8080);
+        config.setAddress("127.0.0.1:9092?topics=quickstart-events&group=quickstart-group");
+        config.setDefault();
+        String str = config.toString();
+        assertTrue(str.contains("address="));
+        assertTrue(str.contains("127.0.0.1:9092?topics=quickstart-events&group=quickstart-group"));
+    }
 }