From b03eeef0f77696077c5d0e82b504f6c73073d808 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=A7=A6=E8=8B=B1=E6=9D=B0?= <327782001@qq.com> Date: Thu, 18 May 2023 11:36:40 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E6=B7=BB=E5=8A=A0=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E7=AB=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- dubbo-api/pom.xml | 52 +++++++++++++++++++ .../kwan/shuyu/config/ZookeeperConfig.java | 0 .../com/kwan/shuyu/service/UserService.java | 12 +++++ {dubbo-common-api => dubbo-client}/pom.xml | 10 +++- .../kwan/shuyu/DubboClientApplication.java | 13 +++++ .../kwan/shuyu/controller/UserController.java | 21 ++++++++ .../src/main/resources/application.yml | 11 ++++ dubbo-server/pom.xml | 5 +- .../kwan/shuyu/DubboServerApplication.java | 2 + .../shuyu/service/impl/UserServiceImpl.java | 17 ++++++ .../src/main/resources/application.yml | 13 +++-- pom.xml | 3 +- 12 files changed, 147 insertions(+), 12 deletions(-) create mode 100644 dubbo-api/pom.xml rename {dubbo-common-api => dubbo-api}/src/main/java/com/kwan/shuyu/config/ZookeeperConfig.java (100%) create mode 100644 dubbo-api/src/main/java/com/kwan/shuyu/service/UserService.java rename {dubbo-common-api => dubbo-client}/pom.xml (69%) create mode 100644 dubbo-client/src/main/java/com/kwan/shuyu/DubboClientApplication.java create mode 100644 dubbo-client/src/main/java/com/kwan/shuyu/controller/UserController.java create mode 100644 dubbo-client/src/main/resources/application.yml create mode 100644 dubbo-server/src/main/java/com/kwan/shuyu/service/impl/UserServiceImpl.java diff --git a/dubbo-api/pom.xml b/dubbo-api/pom.xml new file mode 100644 index 0000000..6daf7ee --- /dev/null +++ b/dubbo-api/pom.xml @@ -0,0 +1,52 @@ + + + + dubbo-demo + org.kwan.shuyu + 1.0-SNAPSHOT + + 4.0.0 + + dubbo-api + + + 8 + 8 + + + + + org.apache.curator + curator-framework + 2.8.0 + + + org.apache.curator + curator-recipes + 2.8.0 + + + com.101tec + zkclient + 0.10 + + + slf4j-log4j12 + org.slf4j + + + zookeeper + org.apache.zookeeper + + + + + com.alibaba.spring.boot + dubbo-spring-boot-starter + 2.0.0 + + + + \ No newline at end of file diff --git a/dubbo-common-api/src/main/java/com/kwan/shuyu/config/ZookeeperConfig.java b/dubbo-api/src/main/java/com/kwan/shuyu/config/ZookeeperConfig.java similarity index 100% rename from dubbo-common-api/src/main/java/com/kwan/shuyu/config/ZookeeperConfig.java rename to dubbo-api/src/main/java/com/kwan/shuyu/config/ZookeeperConfig.java diff --git a/dubbo-api/src/main/java/com/kwan/shuyu/service/UserService.java b/dubbo-api/src/main/java/com/kwan/shuyu/service/UserService.java new file mode 100644 index 0000000..c3b1641 --- /dev/null +++ b/dubbo-api/src/main/java/com/kwan/shuyu/service/UserService.java @@ -0,0 +1,12 @@ +package com.kwan.shuyu.service; + +/** + * 用户接口 + * + * @author : qinyingjie + * @version : 2.2.0 + * @date : 2023/5/18 11:21 + */ +public interface UserService { + int getCount();//获取当前网站在线人数 +} diff --git a/dubbo-common-api/pom.xml b/dubbo-client/pom.xml similarity index 69% rename from dubbo-common-api/pom.xml rename to dubbo-client/pom.xml index f257d3c..a3ce1ff 100644 --- a/dubbo-common-api/pom.xml +++ b/dubbo-client/pom.xml @@ -9,11 +9,17 @@ 4.0.0 - dubbo-common-api + dubbo-client 8 8 - + + + org.kwan.shuyu + dubbo-api + 1.0-SNAPSHOT + + \ No newline at end of file diff --git a/dubbo-client/src/main/java/com/kwan/shuyu/DubboClientApplication.java b/dubbo-client/src/main/java/com/kwan/shuyu/DubboClientApplication.java new file mode 100644 index 0000000..896bb75 --- /dev/null +++ b/dubbo-client/src/main/java/com/kwan/shuyu/DubboClientApplication.java @@ -0,0 +1,13 @@ +package com.kwan.shuyu; + +import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +@SpringBootApplication +@EnableDubboConfiguration //开启dubbo配置 +public class DubboClientApplication { + public static void main(String[] args) { + SpringApplication.run(DubboClientApplication.class, args); + } +} diff --git a/dubbo-client/src/main/java/com/kwan/shuyu/controller/UserController.java b/dubbo-client/src/main/java/com/kwan/shuyu/controller/UserController.java new file mode 100644 index 0000000..2749e26 --- /dev/null +++ b/dubbo-client/src/main/java/com/kwan/shuyu/controller/UserController.java @@ -0,0 +1,21 @@ +package com.kwan.shuyu.controller; + +import com.alibaba.dubbo.config.annotation.Reference; +import com.kwan.shuyu.service.UserService; +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.ResponseBody; + +@Controller +public class UserController { + + @Reference(interfaceClass = UserService.class, version = "2.6.0", check = false) + private UserService userService; + + @RequestMapping("/count") + @ResponseBody + public String getCount() { + int count = userService.getCount(); + return "当前在线的人数为:" + count; + } +} diff --git a/dubbo-client/src/main/resources/application.yml b/dubbo-client/src/main/resources/application.yml new file mode 100644 index 0000000..feeb701 --- /dev/null +++ b/dubbo-client/src/main/resources/application.yml @@ -0,0 +1,11 @@ +server: + port: 8083 +#kwan: +# zookeeper: +# hostlist: 120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183 #多个节点用逗号分隔 +# +spring: + application: + name: dobbo-client + dubbo: + registry: zookeeper://120.79.36.53:2181 \ No newline at end of file diff --git a/dubbo-server/pom.xml b/dubbo-server/pom.xml index 375aa42..daec06b 100644 --- a/dubbo-server/pom.xml +++ b/dubbo-server/pom.xml @@ -8,9 +8,7 @@ 1.0-SNAPSHOT 4.0.0 - dubbo-server - 8 8 @@ -18,9 +16,8 @@ org.kwan.shuyu - dubbo-common-api + dubbo-api 1.0-SNAPSHOT - \ No newline at end of file diff --git a/dubbo-server/src/main/java/com/kwan/shuyu/DubboServerApplication.java b/dubbo-server/src/main/java/com/kwan/shuyu/DubboServerApplication.java index 3a0f819..fd22251 100644 --- a/dubbo-server/src/main/java/com/kwan/shuyu/DubboServerApplication.java +++ b/dubbo-server/src/main/java/com/kwan/shuyu/DubboServerApplication.java @@ -1,9 +1,11 @@ package com.kwan.shuyu; +import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication +@EnableDubboConfiguration //开启dubbo配置 public class DubboServerApplication { public static void main(String[] args) { SpringApplication.run(DubboServerApplication.class, args); diff --git a/dubbo-server/src/main/java/com/kwan/shuyu/service/impl/UserServiceImpl.java b/dubbo-server/src/main/java/com/kwan/shuyu/service/impl/UserServiceImpl.java new file mode 100644 index 0000000..dbfd4f8 --- /dev/null +++ b/dubbo-server/src/main/java/com/kwan/shuyu/service/impl/UserServiceImpl.java @@ -0,0 +1,17 @@ +package com.kwan.shuyu.service.impl; + +import com.alibaba.dubbo.config.annotation.Service; +import com.kwan.shuyu.service.UserService; +import org.springframework.stereotype.Component; + +@Component +@Service(interfaceClass = UserService.class, version = "2.6.0", timeout = 15000) +public class UserServiceImpl implements UserService { + + @Override + public int getCount() { + //调用数据持久层 + return 1024; + } +} + diff --git a/dubbo-server/src/main/resources/application.yml b/dubbo-server/src/main/resources/application.yml index ba1f2bc..94f7f76 100644 --- a/dubbo-server/src/main/resources/application.yml +++ b/dubbo-server/src/main/resources/application.yml @@ -1,9 +1,12 @@ server: - port: 8001 - + port: 8081 +#kwan: +# zookeeper: +# hostlist: 120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183 #多个节点用逗号分隔 +# spring: application: name: dobbo-service -kwan: - zookeeper: - hostlist: 120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183 #多个节点用逗号分隔 \ No newline at end of file + dubbo: + server: true + registry: zookeeper://120.79.36.53:2181 \ No newline at end of file diff --git a/pom.xml b/pom.xml index 80ddcaf..4ebb7c6 100644 --- a/pom.xml +++ b/pom.xml @@ -9,8 +9,9 @@ pom 1.0-SNAPSHOT - dubbo-common-api + dubbo-api dubbo-server + dubbo-client 8 -- GitLab