diff --git a/src/main/java/cn/bugstack/dev/tech/dubbo/consumer/config/RPCProxyBeanFactory.java b/src/main/java/cn/bugstack/dev/tech/dubbo/consumer/config/RPCProxyBeanFactory.java index 62ba4cd5bff5726fa1a60f92405cc5b1c6b0b077..ca431c1d1398a6738f728c99e7753c33de37d336 100644 --- a/src/main/java/cn/bugstack/dev/tech/dubbo/consumer/config/RPCProxyBeanFactory.java +++ b/src/main/java/cn/bugstack/dev/tech/dubbo/consumer/config/RPCProxyBeanFactory.java @@ -31,8 +31,8 @@ public class RPCProxyBeanFactory implements FactoryBean, Runnable public RPCProxyBeanFactory() throws InterruptedException { new Thread(this).start(); while (null == channel) { - Thread.sleep(150); - log.info("Rpc Socket 链接等待..."); + Thread.sleep(550); + log.info("Rpc Socket 链接等待,需要启动 xfg-dev-tech-dubbo 默认提供 127.0.0.1:22881 链接地址..."); } } diff --git a/src/test/java/cn/bugstack/dev/tech/dubbo/consumer/test/ApiTest.java b/src/test/java/cn/bugstack/dev/tech/dubbo/consumer/test/ApiTest.java index 6d68fb10f8a0258dde8d4b7430b0819a081e82a6..b10807072bc7c18e3bb80f9bc2b82d624658929a 100644 --- a/src/test/java/cn/bugstack/dev/tech/dubbo/consumer/test/ApiTest.java +++ b/src/test/java/cn/bugstack/dev/tech/dubbo/consumer/test/ApiTest.java @@ -19,9 +19,10 @@ import javax.annotation.Resource; @SpringBootTest public class ApiTest { - // 直连模式; - @DubboReference(interfaceClass = IUserService.class, url = "dubbo://127.0.0.1:20881", version = "1.0.0") -// @DubboReference(interfaceClass = IUserService.class, version = "1.0.0") + // 测试使用直连模式; + // @DubboReference(interfaceClass = IUserService.class, url = "dubbo://127.0.0.1:20881", version = "1.0.0") + // 测试注册中心模式;需要配置 Zookeeper + @DubboReference(interfaceClass = IUserService.class, version = "1.0.0") private IUserService userService; @Resource(name = "rpcProxyBeanFactory")