From e2ed04c1468c7a66cc89407e235606be99b41bd2 Mon Sep 17 00:00:00 2001 From: YunaiV <> Date: Sun, 1 Dec 2019 23:29:59 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=9D=E5=A7=8B=E5=8C=96=20dubbo=20xml=20?= =?UTF-8?q?=E7=A4=BA=E4=BE=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../META-INF/lab-29-async-demo.kotlin_module | Bin 16 -> 0 bytes .../user-rpc-service-api/pom.xml | 2 +- .../lab30/rpc/api/UserRpcService.java | 9 +++++++ .../springboot/lab30/rpc/dto/UserDTO.java | 3 +++ .../user-rpc-service-consumer/pom.xml | 1 + .../lab30/rpc/ConsumerApplication.java | 25 +++++++++++++----- .../src/main/resources/application.yaml | 13 ++++----- .../user-rpc-service-provider/pom.xml | 3 ++- .../lab30/rpc/service/UserRpcServiceImpl.java | 1 + .../src/main/resources/application.yaml | 15 +++++++---- 10 files changed, 53 insertions(+), 19 deletions(-) delete mode 100644 lab-29/lab-29-async-demo/target/classes/META-INF/lab-29-async-demo.kotlin_module diff --git a/lab-29/lab-29-async-demo/target/classes/META-INF/lab-29-async-demo.kotlin_module b/lab-29/lab-29-async-demo/target/classes/META-INF/lab-29-async-demo.kotlin_module deleted file mode 100644 index 2983af70661ad375cc499ebc4da5a68ca46c532e..0000000000000000000000000000000000000000 GIT binary patch literal 0 HcmV?d00001 literal 16 RcmZQzU|?ooU|@t|egFVe02KfL diff --git a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-api/pom.xml b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-api/pom.xml index 404166cc..46318235 100644 --- a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-api/pom.xml +++ b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-api/pom.xml @@ -3,7 +3,7 @@ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> - lab-29-dubbo-xml-demo + lab-30-dubbo-xml-demo cn.iocoder.springboot.labs 1.0-SNAPSHOT diff --git a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/api/UserRpcService.java b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/api/UserRpcService.java index 3dad11dd..d65cb1fd 100644 --- a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/api/UserRpcService.java +++ b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/api/UserRpcService.java @@ -2,8 +2,17 @@ package cn.iocoder.springboot.lab30.rpc.api; import cn.iocoder.springboot.lab30.rpc.dto.UserDTO; +/** + * 用户服务 RPC Service 接口 + */ public interface UserRpcService { + /** + * 根据指定用户编号，获得用户信息 + * + * @param id 用户编号 + * @return 用户信息 + */ UserDTO get(Integer id); } diff --git a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/dto/UserDTO.java b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/dto/UserDTO.java index 5554932c..806923fa 100644 --- a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/dto/UserDTO.java +++ b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/dto/UserDTO.java @@ -2,6 +2,9 @@ package cn.iocoder.springboot.lab30.rpc.dto; import java.io.Serializable; +/** + * 用户信息 DTO + */ public class UserDTO implements Serializable { /** diff --git a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-consumer/pom.xml b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-consumer/pom.xml index 36fc16d8..fdd28a6d 100644 --- a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-consumer/pom.xml +++ b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-consumer/pom.xml @@ -13,6 +13,7 @@ user-rpc-service-consumer + cn.iocoder.springboot.labs user-rpc-service-api diff --git a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-consumer/src/main/java/cn/iocoder/springboot/lab30/rpc/ConsumerApplication.java b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-consumer/src/main/java/cn/iocoder/springboot/lab30/rpc/ConsumerApplication.java index 47532f0d..09022756 100644 --- a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-consumer/src/main/java/cn/iocoder/springboot/lab30/rpc/ConsumerApplication.java +++ b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-consumer/src/main/java/cn/iocoder/springboot/lab30/rpc/ConsumerApplication.java @@ -4,25 +4,38 @@ import cn.iocoder.springboot.lab30.rpc.api.UserRpcService; import cn.iocoder.springboot.lab30.rpc.dto.UserDTO; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.springframework.boot.CommandLineRunner; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.ConfigurableApplicationContext; import org.springframework.context.annotation.ImportResource; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; @SpringBootApplication @ImportResource("classpath:dubbo.xml") public class ConsumerApplication { - private static final Logger LOGGER = LoggerFactory.getLogger(ConsumerApplication.class); - public static void main(String[] args) { // 启动 Spring Boot 应用 ConfigurableApplicationContext context = SpringApplication.run(ConsumerApplication.class, args); + } + + @Component + public class UserRpcServiceTest implements CommandLineRunner { + + private final Logger logger = LoggerFactory.getLogger(getClass()); + + @Resource + private UserRpcService userRpcService; + + @Override + public void run(String... args) throws Exception { + UserDTO user = userRpcService.get(1); + logger.info("[run][发起一次 Dubbo RPC 请求，获得用户为({})", user); + } - // 获得 UserRpcService - UserRpcService service = context.getBean(UserRpcService.class); - UserDTO user = service.get(1); - LOGGER.info("[main][发起一次 Dubbo RPC 请求，获得用户为({})", user); } } diff --git a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-consumer/src/main/resources/application.yaml b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-consumer/src/main/resources/application.yaml index dd441122..8596d202 100644 --- a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-consumer/src/main/resources/application.yaml +++ b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-consumer/src/main/resources/application.yaml @@ -1,12 +1,13 @@ -# dubbo +# dubbo 配置项，对应 DubboConfigurationProperties 配置类 dubbo: + # Dubbo 应用配置 application: - name: user-service + name: user-service-consumer # 应用名 + # Dubbo 注册中心配置 registry: - address: zookeeper://127.0.0.1:2181 - protocol: - port: -1 - name: dubbo + address: zookeeper://127.0.0.1:2181 # 注册中心地址。个鞥多注册中心，可见 http://dubbo.apache.org/zh-cn/docs/user/references/registry/introduction.html 文档。 + # Dubbo 消费者配置 consumer: + timeout: 1000 # 【重要】远程服务调用超时时间，单位：毫秒。默认为 1000 毫秒，胖友可以根据自己业务修改 UserRpcService: version: 1.0.0 diff --git a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-provider/pom.xml b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-provider/pom.xml index 1a2ade28..abe468bb 100644 --- a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-provider/pom.xml +++ b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-provider/pom.xml @@ -10,9 +10,10 @@ 4.0.0 - user-rpc-service + user-rpc-service-provider + cn.iocoder.springboot.labs user-rpc-service-api diff --git a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-provider/src/main/java/cn/iocoder/springboot/lab30/rpc/service/UserRpcServiceImpl.java b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-provider/src/main/java/cn/iocoder/springboot/lab30/rpc/service/UserRpcServiceImpl.java index cafb07cb..b768688c 100644 --- a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-provider/src/main/java/cn/iocoder/springboot/lab30/rpc/service/UserRpcServiceImpl.java +++ b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-provider/src/main/java/cn/iocoder/springboot/lab30/rpc/service/UserRpcServiceImpl.java @@ -8,6 +8,7 @@ import org.springframework.stereotype.Service; @Service public class UserRpcServiceImpl implements UserRpcService { + @Override public UserDTO get(Integer id) { return new UserDTO().setId(id) .setName("没有昵称：" + id) diff --git a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-provider/src/main/resources/application.yaml b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-provider/src/main/resources/application.yaml index 8bbe6930..5f6c1c4c 100644 --- a/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-provider/src/main/resources/application.yaml +++ b/lab-30/lab-30-dubbo-xml-demo/user-rpc-service-provider/src/main/resources/application.yaml @@ -1,12 +1,17 @@ -# dubbo +# dubbo 配置项，对应 DubboConfigurationProperties 配置类 dubbo: + # Dubbo 应用配置 application: - name: user-service + name: user-service-provider # 应用名 + # Dubbo 注册中心配 registry: - address: zookeeper://127.0.0.1:2181 + address: zookeeper://127.0.0.1:2181 # 注册中心地址。个鞥多注册中心，可见 http://dubbo.apache.org/zh-cn/docs/user/references/registry/introduction.html 文档。 + # Dubbo 服务提供者协议配置 protocol: - port: -1 - name: dubbo + port: -1 # 协议端口。使用 -1 表示随机端口。 + name: dubbo # 使用 `dubbo://` 协议。更多协议，可见 http://dubbo.apache.org/zh-cn/docs/user/references/protocol/introduction.html 文档 + # Dubbo 服务提供者配置 provider: + timeout: 1000 # 【重要】远程服务调用超时时间，单位：毫秒。默认为 1000 毫秒，胖友可以根据自己业务修改 UserRpcService: version: 1.0.0