尝试连接Zk

pom.xml

@@ -33,4 +33,41 @@
         <maven.compiler.target>${java.version}</maven.compiler.target>
     </properties>
 
+    <dependencies>
+        <!-- https://mvnrepository.com/artifact/com.alibaba.spring.boot/dubbo-spring-boot-starter -->
+        <dependency>
+            <groupId>com.alibaba.spring.boot</groupId>
+            <artifactId>dubbo-spring-boot-starter</artifactId>
+            <version>2.0.0</version>
+        </dependency>
+
+        <!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper -->
+        <dependency>
+            <groupId>org.apache.zookeeper</groupId>
+            <artifactId>zookeeper</artifactId>
+            <version>3.7.0</version>
+        </dependency>
+
+        <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
+        <dependency>
+            <groupId>com.github.sgroschupf</groupId>
+            <artifactId>zkclient</artifactId>
+            <version>0.1</version>
+        </dependency>
+
+        <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.76</version>
+        </dependency>
+
+        <!-- lombok https://mvnrepository.com/artifact/org.projectlombok/lombok -->
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+    </dependencies>
+
 </project>

server-beans/pom.xml

@@ -9,7 +9,7 @@
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
-    <artifactId>server-bean</artifactId>
+    <artifactId>server-beans</artifactId>
 
     <properties>
         <java.version>1.8</java.version>

server-beans/src/main/java/cn/minbb/server/beans/User.java

@@ -1,6 +1,17 @@
 package cn.minbb.server.beans;
 
 import cn.minbb.server.Base;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
 
+@AllArgsConstructor
+@Getter
+@Setter
+@NoArgsConstructor
 public class User extends Base {
+    private Integer id;
+    private String username;
+    private String password;
 }

server-dao/pom.xml

@@ -17,4 +17,13 @@
         <maven.compiler.target>${java.version}</maven.compiler.target>
     </properties>
 
+    <dependencies>
+        <dependency>
+            <groupId>cn.minbb</groupId>
+            <artifactId>server-beans</artifactId>
+            <version>1.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+
 </project>

server-dao/src/main/java/cn/minbb/server/dao/UserMapper.java

@@ -1,4 +1,9 @@
 package cn.minbb.server.dao;
 
+import cn.minbb.server.beans.User;
+
+import java.util.List;
+
 public interface UserMapper {
+    List<User> findAll();
 }

server-service-impl/pom.xml

@@ -9,8 +9,22 @@
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
-    <artifactId>server-impl</artifactId>
+    <artifactId>server-service-impl</artifactId>
+
+    <properties>
+        <java.version>1.8</java.version>
+        <maven.compiler.source>${java.version}</maven.compiler.source>
+        <maven.compiler.target>${java.version}</maven.compiler.target>
+    </properties>
+
     <dependencies>
+        <dependency>
+            <groupId>cn.minbb</groupId>
+            <artifactId>server-dao</artifactId>
+            <version>1.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
+
         <dependency>
             <groupId>cn.minbb</groupId>
             <artifactId>server-service</artifactId>
@@ -19,10 +33,4 @@
         </dependency>
     </dependencies>
 
-    <properties>
-        <java.version>1.8</java.version>
-        <maven.compiler.source>${java.version}</maven.compiler.source>
-        <maven.compiler.target>${java.version}</maven.compiler.target>
-    </properties>
-
 </project>

server-service-impl/src/main/java/cn/minbb/server/service/ServiceApplication.java

@@ -1,8 +1,14 @@
 package cn.minbb.server.service;
 
+import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
 
+@EnableDubbo
+@SpringBootApplication
 public class ServiceApplication {
 
     public static void main(String[] args) {
+        SpringApplication.run(ServiceApplication.class, args);
     }
-}
+}

server-service-impl/src/main/java/cn/minbb/server/service/impl/UserServiceImpl.java

@@ -1,6 +1,23 @@
 package cn.minbb.server.service.impl;
 
+import cn.minbb.server.beans.User;
 import cn.minbb.server.service.UserService;
+import com.alibaba.dubbo.config.annotation.Service;
 
+import java.util.ArrayList;
+import java.util.List;
+
+@Service
 public class UserServiceImpl implements UserService {
+
+//    @Autowired
+//    private UserMapper userMapper;
+
+    @Override
+    public List<User> findAll() {
+        List<User> userList = new ArrayList<>();
+        userList.add(new User(1, "111", "111111"));
+        userList.add(new User(2, "222", "222222"));
+        return userList;
+    }
 }

server-service-impl/src/main/resources/application.yml

@@ -0,0 +1,18 @@
+server:
+  port: 9002
+
+dubbo:
+  application:
+    name: server-provider
+  registry:
+    address: zookeeper://42.193.110.241:2181
+    protocol: zookeeper
+    check: false
+  protocol:
+    name: dubbo
+    port: 20881
+  monitor:
+    protocol: register
+  consumer:
+    check: false
+    timeout: 3000

server-service/pom.xml

@@ -17,4 +17,13 @@
         <maven.compiler.target>${java.version}</maven.compiler.target>
     </properties>
 
+    <dependencies>
+        <dependency>
+            <groupId>cn.minbb</groupId>
+            <artifactId>server-beans</artifactId>
+            <version>1.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+
 </project>

server-service/src/main/java/cn/minbb/server/service/UserService.java

@@ -1,4 +1,9 @@
 package cn.minbb.server.service;
 
+import cn.minbb.server.beans.User;
+
+import java.util.List;
+
 public interface UserService {
+    List<User> findAll();
 }

server-utils/pom.xml

@@ -9,7 +9,7 @@
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
-    <artifactId>server-util</artifactId>
+    <artifactId>server-utils</artifactId>
 
     <properties>
         <java.version>1.8</java.version>

server-web/pom.xml

@@ -18,6 +18,27 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>cn.minbb</groupId>
+            <artifactId>server-beans</artifactId>
+            <version>1.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>cn.minbb</groupId>
+            <artifactId>server-utils</artifactId>
+            <version>1.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>cn.minbb</groupId>
+            <artifactId>server-service</artifactId>
+            <version>1.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
+
         <!-- Web -->
         <dependency>
             <groupId>org.springframework.boot</groupId>

server-web/src/main/java/cn/minbb/server/WebApplication.java

@@ -1,8 +1,10 @@
 package cn.minbb.server;
 
+import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
+@EnableDubbo
 @SpringBootApplication
 public class WebApplication {
 

server-web/src/main/java/cn/minbb/server/controller/MainController.java

@@ -1,15 +1,28 @@
 package cn.minbb.server.controller;
 
+import cn.minbb.server.beans.User;
+import cn.minbb.server.service.UserService;
+import com.alibaba.dubbo.config.annotation.Reference;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.List;
+
 @RequestMapping
 @RestController
 public class MainController {
 
+    @Reference
+    private UserService userService;
+
     @GetMapping
     public String run() {
         return "server is running...";
     }
+
+    @GetMapping("users")
+    public List<User> users() {
+        return userService.findAll();
+    }
 }

server-web/src/main/resources/application.properties

@@ -1 +0,0 @@
-server.port=8001

server-web/src/main/resources/application.yml

@@ -0,0 +1,14 @@
+server:
+  port: 8001
+dubbo:
+  application:
+    name: server-consumer
+  registry:
+    address: zookeeper://42.193.110.241:2182
+    protocol: zookeeper
+    check: false
+  monitor:
+    protocol: register
+  consumer:
+    check: false
+    timeout: 3000