From 525909b786828762e98dc2f3cb26a6ce2d1ff421 Mon Sep 17 00:00:00 2001 From: YunaiV <> Date: Sun, 1 Dec 2019 20:23:02 +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 --- lab-30/lab-29-dubbo-xml-demo/pom.xml | 3 +- .../user-rpc-service-api/pom.xml | 1 - .../lab30/rpc/api/DemoUserRpcService.java | 9 ---- .../lab30/rpc/api/UserRpcService.java | 9 ++++ .../dto/{DemoUserDTO.java => UserDTO.java} | 10 ++-- .../springboot/lab30/rpc/package-info.java | 1 - .../user-rpc-service-consumer/pom.xml | 54 +++++++++++++++++++ .../lab30/rpc/ConsumerApplication.java | 28 ++++++++++ .../src/main/resources/application.yaml | 12 +++++ .../src/main/resources/dubbo.xml | 14 +++++ .../user-rpc-service-provider/pom.xml | 54 +++++++++++++++++++ .../lab30/rpc/ProviderApplication.java | 16 ++++++ .../lab30/rpc/service/UserRpcServiceImpl.java | 17 ++++++ .../src/main/resources/application.yaml | 12 +++++ .../src/main/resources/dubbo.xml | 14 +++++ .../user-rpc-service/pom.xml | 22 -------- .../springboot/lab30/rpc/Application.java | 4 -- .../rpc/service/DemoUserRpcServiceImpl.java | 15 ------ 18 files changed, 238 insertions(+), 57 deletions(-) delete mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/api/DemoUserRpcService.java create mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/api/UserRpcService.java rename lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/dto/{DemoUserDTO.java => UserDTO.java} (73%) delete mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/package-info.java create mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/pom.xml create mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/src/main/java/cn/iocoder/springboot/lab30/rpc/ConsumerApplication.java create mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/src/main/resources/application.yaml create mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/src/main/resources/dubbo.xml create mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/pom.xml create mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/java/cn/iocoder/springboot/lab30/rpc/ProviderApplication.java create mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/java/cn/iocoder/springboot/lab30/rpc/service/UserRpcServiceImpl.java create mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/resources/application.yaml create mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/resources/dubbo.xml delete mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service/pom.xml delete mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service/src/main/java/cn/iocoder/springboot/lab30/rpc/Application.java delete mode 100644 lab-30/lab-29-dubbo-xml-demo/user-rpc-service/src/main/java/cn/iocoder/springboot/lab30/rpc/service/DemoUserRpcServiceImpl.java diff --git a/lab-30/lab-29-dubbo-xml-demo/pom.xml b/lab-30/lab-29-dubbo-xml-demo/pom.xml index f76344a2..59d91ac8 100644 --- a/lab-30/lab-29-dubbo-xml-demo/pom.xml +++ b/lab-30/lab-29-dubbo-xml-demo/pom.xml @@ -13,7 +13,8 @@ pom user-rpc-service-api - user-rpc-service + user-rpc-service-provider + user-rpc-service-consumer diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/pom.xml b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/pom.xml index a7fdee8b..404166cc 100644 --- a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/pom.xml +++ b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/pom.xml @@ -11,5 +11,4 @@ user-rpc-service-api - diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/api/DemoUserRpcService.java b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/api/DemoUserRpcService.java deleted file mode 100644 index b30aa2da..00000000 --- a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/api/DemoUserRpcService.java +++ /dev/null @@ -1,9 +0,0 @@ -package cn.iocoder.springboot.lab30.rpc.api; - -import cn.iocoder.springboot.lab30.rpc.dto.DemoUserDTO; - -public interface DemoUserRpcService { - - DemoUserDTO get(Integer id); - -} diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/api/UserRpcService.java b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/api/UserRpcService.java new file mode 100644 index 00000000..3dad11dd --- /dev/null +++ b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/api/UserRpcService.java @@ -0,0 +1,9 @@ +package cn.iocoder.springboot.lab30.rpc.api; + +import cn.iocoder.springboot.lab30.rpc.dto.UserDTO; + +public interface UserRpcService { + + UserDTO get(Integer id); + +} diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/dto/DemoUserDTO.java b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/dto/UserDTO.java similarity index 73% rename from lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/dto/DemoUserDTO.java rename to lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/dto/UserDTO.java index c58f4e39..5554932c 100644 --- a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/dto/DemoUserDTO.java +++ b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/dto/UserDTO.java @@ -1,6 +1,8 @@ package cn.iocoder.springboot.lab30.rpc.dto; -public class DemoUserDTO { +import java.io.Serializable; + +public class UserDTO implements Serializable { /** * 用户编号 @@ -19,7 +21,7 @@ public class DemoUserDTO { return id; } - public DemoUserDTO setId(Integer id) { + public UserDTO setId(Integer id) { this.id = id; return this; } @@ -28,7 +30,7 @@ public class DemoUserDTO { return name; } - public DemoUserDTO setName(String name) { + public UserDTO setName(String name) { this.name = name; return this; } @@ -37,7 +39,7 @@ public class DemoUserDTO { return gender; } - public DemoUserDTO setGender(Integer gender) { + public UserDTO setGender(Integer gender) { this.gender = gender; return this; } diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/package-info.java b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/package-info.java deleted file mode 100644 index 51acb1d3..00000000 --- a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-api/src/main/java/cn/iocoder/springboot/lab30/rpc/package-info.java +++ /dev/null @@ -1 +0,0 @@ -package cn.iocoder.springboot.lab30.rpc; diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/pom.xml b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/pom.xml new file mode 100644 index 00000000..36fc16d8 --- /dev/null +++ b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/pom.xml @@ -0,0 +1,54 @@ + + + + org.springframework.boot + spring-boot-starter-parent + 2.2.1.RELEASE + + + 4.0.0 + + user-rpc-service-consumer + + + + cn.iocoder.springboot.labs + user-rpc-service-api + 1.0-SNAPSHOT + + + + + org.springframework.boot + spring-boot-starter + + + + + org.apache.dubbo + dubbo + 2.7.4.1 + + + org.apache.dubbo + dubbo-spring-boot-starter + 2.7.4.1 + + + + + org.apache.curator + curator-framework + 2.13.0 + + + org.apache.curator + curator-recipes + 2.13.0 + + + + + diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/src/main/java/cn/iocoder/springboot/lab30/rpc/ConsumerApplication.java b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/src/main/java/cn/iocoder/springboot/lab30/rpc/ConsumerApplication.java new file mode 100644 index 00000000..47532f0d --- /dev/null +++ b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/src/main/java/cn/iocoder/springboot/lab30/rpc/ConsumerApplication.java @@ -0,0 +1,28 @@ +package cn.iocoder.springboot.lab30.rpc; + +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.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.context.ConfigurableApplicationContext; +import org.springframework.context.annotation.ImportResource; + +@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); + + // 获得 UserRpcService + UserRpcService service = context.getBean(UserRpcService.class); + UserDTO user = service.get(1); + LOGGER.info("[main][发起一次 Dubbo RPC 请求，获得用户为({})", user); + } + +} diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/src/main/resources/application.yaml b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/src/main/resources/application.yaml new file mode 100644 index 00000000..dd441122 --- /dev/null +++ b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/src/main/resources/application.yaml @@ -0,0 +1,12 @@ +# dubbo +dubbo: + application: + name: user-service + registry: + address: zookeeper://127.0.0.1:2181 + protocol: + port: -1 + name: dubbo + consumer: + UserRpcService: + version: 1.0.0 diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/src/main/resources/dubbo.xml b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/src/main/resources/dubbo.xml new file mode 100644 index 00000000..58fcb88c --- /dev/null +++ b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-consumer/src/main/resources/dubbo.xml @@ -0,0 +1,14 @@ + + + + + + + diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/pom.xml b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/pom.xml new file mode 100644 index 00000000..1a2ade28 --- /dev/null +++ b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/pom.xml @@ -0,0 +1,54 @@ + + + + org.springframework.boot + spring-boot-starter-parent + 2.2.1.RELEASE + + + 4.0.0 + + user-rpc-service + + + + cn.iocoder.springboot.labs + user-rpc-service-api + 1.0-SNAPSHOT + + + + + org.springframework.boot + spring-boot-starter + + + + + org.apache.dubbo + dubbo + 2.7.4.1 + + + org.apache.dubbo + dubbo-spring-boot-starter + 2.7.4.1 + + + + + org.apache.curator + curator-framework + 2.13.0 + + + org.apache.curator + curator-recipes + 2.13.0 + + + + + diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/java/cn/iocoder/springboot/lab30/rpc/ProviderApplication.java b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/java/cn/iocoder/springboot/lab30/rpc/ProviderApplication.java new file mode 100644 index 00000000..2a05007c --- /dev/null +++ b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/java/cn/iocoder/springboot/lab30/rpc/ProviderApplication.java @@ -0,0 +1,16 @@ +package cn.iocoder.springboot.lab30.rpc; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.context.annotation.ImportResource; + +@SpringBootApplication +@ImportResource("classpath:dubbo.xml") +public class ProviderApplication { + + public static void main(String[] args) { + // 启动 Spring Boot 应用 + SpringApplication.run(ProviderApplication.class, args); + } + +} diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/java/cn/iocoder/springboot/lab30/rpc/service/UserRpcServiceImpl.java b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/java/cn/iocoder/springboot/lab30/rpc/service/UserRpcServiceImpl.java new file mode 100644 index 00000000..cafb07cb --- /dev/null +++ b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/java/cn/iocoder/springboot/lab30/rpc/service/UserRpcServiceImpl.java @@ -0,0 +1,17 @@ +package cn.iocoder.springboot.lab30.rpc.service; + + +import cn.iocoder.springboot.lab30.rpc.api.UserRpcService; +import cn.iocoder.springboot.lab30.rpc.dto.UserDTO; +import org.springframework.stereotype.Service; + +@Service +public class UserRpcServiceImpl implements UserRpcService { + + public UserDTO get(Integer id) { + return new UserDTO().setId(id) + .setName("没有昵称：" + id) + .setGender(id % 2 + 1); // 1 - 男；2 - 女 + } + +} diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/resources/application.yaml b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/resources/application.yaml new file mode 100644 index 00000000..8bbe6930 --- /dev/null +++ b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/resources/application.yaml @@ -0,0 +1,12 @@ +# dubbo +dubbo: + application: + name: user-service + registry: + address: zookeeper://127.0.0.1:2181 + protocol: + port: -1 + name: dubbo + provider: + UserRpcService: + version: 1.0.0 diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/resources/dubbo.xml b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/resources/dubbo.xml new file mode 100644 index 00000000..4cbc8c50 --- /dev/null +++ b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service-provider/src/main/resources/dubbo.xml @@ -0,0 +1,14 @@ + + + + + + + diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service/pom.xml b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service/pom.xml deleted file mode 100644 index ed664c67..00000000 --- a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service/pom.xml +++ /dev/null @@ -1,22 +0,0 @@ - - - - lab-29-dubbo-xml-demo - cn.iocoder.springboot.labs - 1.0-SNAPSHOT - - 4.0.0 - - user-rpc-service - - - - cn.iocoder.springboot.labs - user-rpc-service-api - 1.0-SNAPSHOT - - - - diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service/src/main/java/cn/iocoder/springboot/lab30/rpc/Application.java b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service/src/main/java/cn/iocoder/springboot/lab30/rpc/Application.java deleted file mode 100644 index d74b7cc6..00000000 --- a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service/src/main/java/cn/iocoder/springboot/lab30/rpc/Application.java +++ /dev/null @@ -1,4 +0,0 @@ -package cn.iocoder.springboot.lab30.rpc; - -public class Application { -} diff --git a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service/src/main/java/cn/iocoder/springboot/lab30/rpc/service/DemoUserRpcServiceImpl.java b/lab-30/lab-29-dubbo-xml-demo/user-rpc-service/src/main/java/cn/iocoder/springboot/lab30/rpc/service/DemoUserRpcServiceImpl.java deleted file mode 100644 index c8a40841..00000000 --- a/lab-30/lab-29-dubbo-xml-demo/user-rpc-service/src/main/java/cn/iocoder/springboot/lab30/rpc/service/DemoUserRpcServiceImpl.java +++ /dev/null @@ -1,15 +0,0 @@ -package cn.iocoder.springboot.lab30.rpc.service; - - -import cn.iocoder.springboot.lab30.rpc.api.DemoUserRpcService; -import cn.iocoder.springboot.lab30.rpc.dto.DemoUserDTO; - -public class DemoUserRpcServiceImpl implements DemoUserRpcService { - - public DemoUserDTO get(Integer id) { - return new DemoUserDTO().setId(id) - .setName("没有昵称：" + id) - .setGender(id % 2 + 1); // 1 - 男；2 - 女 - } - -}