Dubbo SpringBoot

1、根 pom

  1. <properties>
  2.     <dubbo.version>3.0.5</dubbo.version>
  3. </properties>
  5. <dependencies>
  6.     <dependency>
  7.         <groupId>org.springframework.boot</groupId>
  8.         <artifactId>spring-boot-starter-web</artifactId>
  9.     </dependency>
  11.     <dependency>
  12.         <groupId>org.springframework.boot</groupId>
  13.         <artifactId>spring-boot-starter-test</artifactId>
  14.         <scope>test</scope>
  15.     </dependency>
  17.     <dependency>
  18.         <groupId>org.apache.dubbo</groupId>
  19.         <artifactId>dubbo-spring-boot-starter</artifactId>
  20.         <version>${dubbo.version}</version>
  21.     </dependency>
  23.     <dependency>
  24.         <groupId>org.apache.dubbo</groupId>
  25.         <artifactId>dubbo-dependencies-zookeeper</artifactId>
  26.         <version>${dubbo.version}</version>
  27.         <type>pom</type>
  28.     </dependency>
  29. </dependencies>

2、Api Module

maven 项目

2.1 RpcResult

  1. @Data
  2. public class RpcResult <T> implements Serializable {
  3.     /**
  4.      * 是否响应成功
  5.      */
  6.     private Boolean success;
  7.     /**
  8.      * 响应状态码
  9.      */
  10.     private Integer code;
  11.     /**
  12.      * 响应数据
  13.      */
  14.     private T data;
  15.     /**
  16.      * 错误信息
  17.      */
  18.     private String message;
  20.     private RpcResult() {
  21.         this.code = 200;
  22.         this.success = true;
  23.     }
  25.     private RpcResult(T obj) {
  26.         this.code = 200;
  27.         this.data = obj;
  28.         this.success = true;
  29.     }
  31.     private RpcResult(ResultCodeEnum resultCode) {
  32.         this.success = false;
  33.         this.code = resultCode.getCode();
  34.         this.message = resultCode.getMessage();
  35.     }
  37.     public static<T> RpcResult success(){
  38.         return new RpcResult();
  39.     }
  41.     public static<T> RpcResult<T> success(T data){
  42.         return new RpcResult<T>(data);
  43.     }
  45.     public static<T> RpcResult<T> failure(ResultCodeEnum resultCode){
  46.         return  new RpcResult<T>(resultCode);
  47.     }
  49.     @Override
  50.     public String toString() {
  51.         return "RpcResult{" +
  52.                 "success=" + success +
  53.                 ", code=" + code +
  54.                 ", data=" + data +
  55.                 ", message='" + message + '\'' +
  56.                 '}';
  57.     }
  58. }

2.2 ResultCodeEnum

  1. public enum ResultCodeEnum {
  2.     /** */
  3.     SUCCESS(200, "success"),
  4.     ORDER_NOT_FOUND(2000, "order not found");
  5.     /**
  6.      * 响应状态码
  7.      */
  8.     private Integer code;
  9.     /**
  10.      * 响应信息
  11.      */
  12.     private String message;
  14.     ResultCodeEnum(Integer code, String msg) {
  15.         this.code = code;
  16.         this.message = msg;
  17.     }
  19.     public Integer getCode() {
  20.         return code;
  21.     }
  23.     public String getMessage() {
  24.         return message;
  25.     }
  27.     public void setMessage(String message) {
  28.         this.message = message;
  29.     }
  30. }

2.3 OrderDubboService 接口

  1. public interface OrderDubboService {
  2.     RpcResult<Object> getOrder();
  3. }

3、 Provider Module

OrderDubboServiceImpl 实现接口

  1. @DubboService
  2. public class OrderDubboServiceImpl implements OrderDubboService {
  3.     @Override
  4.     public RpcResult<Object> getOrder() {
  5.         return RpcResult.success("provider --> " + LocalDateTime.now());
  6.     }
  7. }

application.yml

  1. server:
  2.   # 服务端口
  3.   port: 7777
  4. spring:
  5.   application:
  6.     name: order-provider
  7. # dubbo 相关配置(dubbo 的配置不再以 Spring 开头)
  8. dubbo:
  9.   application:
  10.     # 应用名称
  11.     name: order-provider
  12.   scan:
  13.     # 接口实现者（服务实现）包
  14.     base-packages: com.cug.provider.impl
  15.   # 注册中心信息
  16.   registry:
  17.     address: zookeeper://127.0.0.1:2181
  18.   protocol:
  19.     # 协议名称
  20.     name: dubbo
  21.     # 协议端口， dubbo-admin 占用 20880 端口
  22.     port: 20881

4、 Consumer Module

controller

  1. @RestController
  2. @RequestMapping("/order")
  3. public class TestController {
  5.     @DubboReference
  6.     private OrderDubboService orderDubboService;
  8.     @GetMapping("getOrder")
  9.     public RpcResult<Object> getOrder() {
  10.         return orderDubboService.getOrder();
  11.     }
  12. }

application.yml

  1. server:
  2.   port: 7000
  3. spring:
  4.   application:
  5.     name: order-consumer
  6. # dubbo 相关配置
  7. dubbo:
  8.   application:
  9.     name: order-consumer
  10.   registry:
  11.     address: zookeeper://127.0.0.1:2181

5、ZooKeeper

启动 zkServer.cmd

6、启动 dubbo-admin

编译源码

  1. ## 1、 下载代码:
  2. git clone https://github.com/apache/dubbo-admin.git
  3. ## 2、在 dubbo-admin-server/src/main/resources/application.properties 中指定注册中心地址
  4. ## 3、构建
  5. mvn clean package -Dmaven.test.skip=true
  6. ## 4、启动
  7.   ## 启动 dubbo-admin-server, 在 application.properties 中添加 server.port=8088
  8.   mvn --projects dubbo-admin-server spring-boot:run
  9.   ## 启动 dubbo-admin-ui， 修改 vue.config.js 中 proxy.target --> http://localhost:8088 
  10.   npm run dev ## 如果有 error , 则先 npm run build
  11. ## 5、访问
  12. http://localhost:8082
  14. ## 每次修改配置文件后，都需要重新构建，即：mvn clean package -Dmaven.test.skip=true

7、测试

1、启动 Provider Module 2、启动 Consumer Module 3、http://localhost:7000/order/getOrder