From 8c3ffd0b0bcd2703d89b624b2f7f7aca4b2b1b42 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B0=8F=E5=82=85=E5=93=A5?= <184172133@qq.com> Date: Mon, 9 Oct 2023 21:10:35 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=A8=A1=E6=8B=9FRPC=E8=AF=B7=E6=B1=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../tech/dubbo/consumer/config/RPCProxyBeanFactory.java | 4 ++-- .../cn/bugstack/dev/tech/dubbo/consumer/test/ApiTest.java | 7 ++++--- 2 files changed, 6 insertions(+), 5 deletions(-) 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 62ba4cd..ca431c1 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 6d68fb1..b108070 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") -- GitLab