Dubbo 微服务应用开发

本地开发应用

前提条件

在使用 Spring Boot 开发 Dubbo 微服务应用前，请先完成以下工作：

TIP

Linux/Unix/Mac 系统：sh startup.sh -m standalone

Windows 系统：双击文件 startup.cmd

创建服务提供者

  1. 创建命名为 spring-boot-dubbo-provider 的 Maven 工程
  2. 在 pom.xml 文件中添加所需的依赖，这里以 Spring Boot 2.1.6.RELEASE 为例
  1.     <dependencyManagement>
  2.         <dependencies>
  3.             <dependency>
  4.                 <groupId>org.springframework.boot</groupId>
  5.                 <artifactId>spring-boot-dependencies</artifactId>
  6.                 <version>2.1.6.RELEASE</version>
  7.                 <type>pom</type>
  8.                 <scope>import</scope>
  9.             </dependency>
  10.         </dependencies>
  11.     </dependencyManagement>
  13.     <dependencies>
  14.         <dependency>
  15.             <groupId>org.springframework.boot</groupId>
  16.             <artifactId>spring-boot-starter-web</artifactId>
  17.         </dependency>
  18.         <dependency>
  19.             <groupId>io.terminus.boot.rpc</groupId>
  20.             <artifactId>dubbo-light-provider</artifactId>
  21.             <version>2.1.6-RELEASE</version>
  22.         </dependency>
  23.     </dependencies>
  1. 开发 Dubbo 服务提供者，Dubbo 中服务都是以接口的形式提供的。
  • 在 src/main/java 路径下创建一个 package： io.terminus.erda.trial.demo.hellodubbo
  • 在 io.terminus.erda.trial.demo.hellodubbo 下创建一个接口（interface)：EchoService，里面包含一个 echo 方法。
  1. package io.terminus.erda.trial.demo.hellodubbo;
  3. public interface EchoService {
  4.     String echo(String name);
  5. }
  • 在 io.terminus.erda.trial.demo.hellodubbo 下创建一个类 EchoServiceImpl ，实现此接口。
  1. package io.terminus.erda.trial.demo.hellodubbo;
  3. import org.apache.dubbo.config.annotation.Service;;
  6. import java.util.concurrent.TimeUnit;
  8. @Service
  9. public class EchoServiceImpl implements EchoService {
  11.     public String echo(String name) {
  12.         long start = System.currentTimeMillis();
  14.         try {
  15.             TimeUnit.SECONDS.sleep(1);
  16.         } catch (InterruptedException e) {
  17.         }
  19.         long end = System.currentTimeMillis();
  20.         return "\r\n\t" + start + " Provider received." +
  21.                 "\r\n\t\tProvider processed after sleep 1 second! Echo String: \"" + name + "\"" +
  22.                 "\r\n\t" + end + " Provider Return";
  24.     }
  25. }

TIP

这里的 Service 注解是 Dubbo 提供的一个注解类，类的全名称为：

org.apache.dubbo.config.annotation.Service

  1. 配置 Dubbo 服务
  • 在 src/main/resources 路径下创建 application.properties 或 application.yaml 文件并打开
  • 在 application.properties 或 application.yaml 中添加如下配置
  1. spring:
  2.   application.name: dubbo-spring-boot-provider
  3. dubbo:
  4.   application.name: dubbo-spring-boot-provider
  5.   protocol:
  6.     name: dubbo
  7.     port: 20880
  8.   registry:
  9.     address: nacos://${NACOS_ADDRESS:127.0.0.1:8848}?namespace=${NACOS_TENANT_ID:}
  10.   scan:
  11.     base-packages: io.terminus.erda.trial.demo.hellodubbo

TIP

  • 以上配置没有默认值，必须要给出具体的配置。
  • dubbo.registry.address 的值前缀必须以 nacos:// 开头，后面的 IP 地址和端口指的是 Nacos Server 的地址。代码示例中为本地地址，如果将 Nacos Server 部署在其它机器上，请修改为实际的 IP 地址。
  • dubbo.scan.base-packages 的值是开发的代码中需要暴露外部调用的，带 @Service 注解的类所在的包，有多个时用逗号进行分隔
  1. 开发并启动 Spring Boot 入口类 DubboProvider。
  1. package io.terminus.erda.trial.demo.hellodubbo;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. @SpringBootApplication
  7. public class DubboProvider {
  8.     public static void main(String[] args) {
  9.         SpringApplication.run(DubboProvider.class, args);
  10.     }
  11. }
  1. 登录 Nacos 控制台 http://127.0.0.1:8848，在左侧导航栏中单击服务列表 ，查看提供者列表。可以看到服务提供者里已经包含了io.terminus.erda.trial.demo.hellodubbo.EchoService，且可以查询该服务的服务分组和提供者 IP。

创建服务消费者

  1. 创建一个 Maven 工程，命名为spring-boot-dubbo-consumer
  2. 在 pom.xml 文件中添加相关依赖。这里以 Spring Boot 2.1.6.RELEASE 为例
  1.     <dependencyManagement>
  2.         <dependencies>
  3.             <dependency>
  4.                 <groupId>org.springframework.boot</groupId>
  5.                 <artifactId>spring-boot-dependencies</artifactId>
  6.                 <version>2.1.6.RELEASE</version>
  7.                 <type>pom</type>
  8.                 <scope>import</scope>
  9.             </dependency>
  10.         </dependencies>
  11.     </dependencyManagement>
  13.     <dependencies>
  14.         <dependency>
  15.             <groupId>org.springframework.boot</groupId>
  16.             <artifactId>spring-boot-starter-web</artifactId>
  17.         </dependency>
  18.         <dependency>
  19.             <groupId>io.terminus.boot.rpc</groupId>
  20.             <artifactId>dubbo-light-consumer</artifactId>
  21.             <version>2.1.6-RELEASE</version>
  22.         </dependency>
  23.     </dependencies>
  1. 开发 Dubbo 消费者
  • 在 src/main/java 路径下创建 package：io.terminus.erda.trial.demo.hellodubbo
  • 在 io.terminus.erda.trial.demo.hellodubbo 下创建一个接口（interface)：EchoService，里面包含一个 echo 方法。
  1. package io.terminus.erda.trial.demo.hellodubbo;
  3. public interface EchoService {
  4.     String echo(String name);
  5. }
  • 开发 Dubbo 服务调用。例如需要在 Controller 中调用一次远程 Dubbo 服务，开发的代码如下所示。
  1. package io.terminus.erda.trial.demo.hellodubbo;
  3. import org.apache.dubbo.config.annotation.Reference;
  4. import org.springframework.web.bind.annotation.PathVariable;
  5. import org.springframework.web.bind.annotation.RequestMapping;
  6. import org.springframework.web.bind.annotation.RequestMethod;
  7. import org.springframework.web.bind.annotation.RestController;
  9. @RestController
  10. public class DemoConsumerController {
  11.     @Reference
  12.     private EchoService demoService;
  14.     @RequestMapping(value = "/ping", method = RequestMethod.GET)
  15.     public Boolean ping() {
  16.         try {
  17.             String pong = demoService.echo("ping");
  19.             System.out.println("Service returned: " + pong);
  20.             return pong.contains("ping");
  21.         } catch (Throwable t) {
  22.             t.printStackTrace();
  23.             return false;
  24.         }
  25.     }
  26.     @RequestMapping(value = "/consumer-echo/{str}", method = RequestMethod.GET)
  27.     public String feign1(@PathVariable String str) {
  28.         long start = System.currentTimeMillis();
  30.         String result = demoService.echo(str);
  32.         long end = System.currentTimeMillis();
  33.         return "" + start + " Consumer received." +
  34.                 "\t" + result +
  35.                 "\r\n" + end + " Consumer Return";
  36.     }
  37. }

TIP

这里的 Reference 注解是 org.apache.dubbo.config.annotation.Reference;。

  1. 在 application.properties/application.yaml 配置文件中新增以下配置。
  1. spring:
  2.   application.name: dubbo-spring-boot-consumer
  3. dubbo:
  4.   application.name: dubbo-spring-boot-consumer
  5.   registry:
  6.     address: nacos://${NACOS_ADDRESS:127.0.0.1:8848}?namespace=${NACOS_TENANT_ID:}

TIP

  • 以上配置没有默认值，必须要给出具体的配置。
  • dubbo.registry.address 的值前缀必须以 nacos:// 开头，后面的 IP 地址和端口为 Nacos Server 的地址。代码示例中为本地地址，如果将 Nacos Server 部署在其它机器上，请修改为实际的 IP 地址。
  1. 开发并启动 Spring Boot 入口类 DubboConsumer。
  1. package io.terminus.erda.trial.demo.hellodubbo;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. @SpringBootApplication
  7. public class DubboConsumer {
  8.     public static void main(String[] args) {
  9.         SpringApplication.run(DubboConsumer.class, args);
  10.     }
  11. }
  1. 登录 Nacos 控制台 http://127.0.0.1:8848，在左侧导航栏中单击服务列表，再在服务列表页面单击调用者列表页签，查看调用者列表。可以看到包含了 io.terminus.erda.trial.demo.hellodubbo.EchoService，且可以查看该服务的服务分组和调用者 IP。

结果验证

  1. `curl http://localhost:8088/ping`
  2. true

将应用部署到 Erda

将应用部署到 Erda，注意 Erda 会注入下面两份 application.yml 中的变量

  1. spring:
  2.   application.name: dubbo-spring-boot-provider
  3. dubbo:
  4.   application.name: dubbo-spring-boot-provider
  5.   protocol:
  6.     name: dubbo
  7.     port: 20880
  8.   registry:
  9.     address: nacos://${NACOS_ADDRESS:127.0.0.1:8848}?namespace=${NACOS_TENANT_ID:}
  10.   scan:
  11.     base-packages: io.terminus.erda.trial.demo.hellodubbo
  1. spring:
  2.   application.name: dubbo-spring-boot-consumer
  3. dubbo:
  4.   application.name: dubbo-spring-boot-consumer
  5.   registry:
  6.     address: nacos://${NACOS_ADDRESS:127.0.0.1:8848}?namespace=${NACOS_TENANT_ID:}

修改 dice.yml，添加注册中心 v2.0 的依赖：

Dubbo 微服务应用开发 - 图3

这样，服务部署成功后，Erda 会自动注入两个环境变量：

  • NACOS_ADDRESS
  • NACOS_TENANT_ID

Dubbo 微服务应用开发 - 图4

点击注册中心，可以看到注册上来的服务。

本地连线上注册中心

使用 Nacos 时，需要配置以下环境变量:

  • NACOS_ADDRESS
  • NACOS_TENANT_ID

使用 ZooKeeper 时，需要配置以下环境变量:

  • ZOOKEEPER_DUBBO
  • DUBBO_TENANT_ID

具体取值，可以通过点击部署详情中的注册中心卡片，进入微服务治理页面，点击组件信息->注册中心进行查看