增加 zipkin 对 dubbo 的链路追踪

huangroot · Mar 21, 2020 · 24ce2e0 · 24ce2e0
1 parent a6ecdf1
commit 24ce2e0
Show file tree

Hide file tree

Showing 14 changed files with 260 additions and 0 deletions.
diff --git a/README.md b/README.md
@@ -191,10 +191,19 @@
 
 # Dubbo 专栏
 
+## 基础入门
+
 * [《芋道 Spring Boot Dubbo 入门》](http://www.iocoder.cn/Spring-Boot/Dubbo/?github) 对应 [lab-30](https://github.com/YunaiV/SpringBoot-Labs/tree/master/lab-30)
 * [《芋道 Spring Cloud Alibaba 服务调用 Dubbo 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/Dubbo/?github) 对应 [labx-07](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-07)
 * [《性能测试 —— Dubbo 基准测试》](http://www.iocoder.cn/Performance-Testing/Dubbo-benchmark/?github)
 
+## 链路追踪
+
+* [《芋道 Spring Boot 链路追踪 SkyWalking 入门》](http://www.iocoder.cn/Spring-Boot/SkyWalking/?github) 对应 [lab-39](https://github.com/YunaiV/SpringBoot-Labs/tree/master/lab-39)
+* [《芋道 Spring Cloud 链路追踪 SkyWalking 入门》](http://www.iocoder.cn/Spring-Cloud/SkyWalking/?github)的[「TODO. Dubbo 示例」](#)小节
+* [《芋道 Spring Boot 链路追踪 Zipkin》](http://www.iocoder.cn/Spring-Cloud/Spring-Cloud-Sleuth/?github)的[「TODO. Dubbo 示例」](#)小节
+* [《芋道 Spring Cloud 链路追踪 Spring Cloud Sleuth》](http://www.iocoder.cn/Spring-Cloud/Spring-Cloud-Sleuth/?github)的[「7. Dubbo 示例」](#)小节
+
 # 消息队列 MQ 专栏
 
 ## RocketMQ

diff --git a/lab-40/lab-40-zipkin-dubbo/lab-40-zipkin-dubbo-api/pom.xml b/lab-40/lab-40-zipkin-dubbo/lab-40-zipkin-dubbo-api/pom.xml
@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>lab-40-zipkin-dubbo</artifactId>
+        <groupId>cn.iocoder.springboot.labs</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>lab-40-zipkin-dubbo-api</artifactId>
+
+
+</project>
diff --git a/...ipkin-dubbo-api/src/main/java/cn/iocoder/springboot/lab40/zipkindemo/api/UserService.java b/...ipkin-dubbo-api/src/main/java/cn/iocoder/springboot/lab40/zipkindemo/api/UserService.java
@@ -0,0 +1,16 @@
+package cn.iocoder.springboot.lab40.zipkindemo.api;
+
+/**
+ * 用户服务 RPC Service 接口
+ */
+public interface UserService {
+
+    /**
+     * 根据指定用户编号，获得用户信息
+     *
+     * @param id 用户编号
+     * @return 用户信息
+     */
+    String get(Integer id);
+
+}
diff --git a/...0-zipkin-dubbo-api/src/main/java/cn/iocoder/springboot/lab40/zipkindemo/package-info.java b/...0-zipkin-dubbo-api/src/main/java/cn/iocoder/springboot/lab40/zipkindemo/package-info.java
@@ -0,0 +1 @@
+package cn.iocoder.springcloud.labx13;
diff --git a/lab-40/lab-40-zipkin-dubbo/lab-40-zipkin-dubbo-consumer/pom.xml b/lab-40/lab-40-zipkin-dubbo/lab-40-zipkin-dubbo-consumer/pom.xml
@@ -0,0 +1,55 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.2.2.RELEASE</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>lab-40-zipkin-dubbo-consumer</artifactId>
+
+    <dependencies>
+        <!-- 引入定义的 Dubbo API 接口 -->
+        <dependency>
+            <groupId>cn.iocoder.springboot.labs</groupId>
+            <artifactId>lab-40-zipkin-dubbo-api</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+
+        <!-- 引入 SpringMVC 相关依赖，并实现对其的自动配置 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+
+        <!-- 实现对 Dubbo 的自动化配置 -->
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo</artifactId>
+            <version>2.7.4.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo-spring-boot-starter</artifactId>
+            <version>2.7.4.1</version>
+        </dependency>
+
+        <!-- 使用 Zookeeper 作为注册中心 -->
+        <dependency>
+            <groupId>org.apache.curator</groupId>
+            <artifactId>curator-framework</artifactId>
+            <version>2.13.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.curator</groupId>
+            <artifactId>curator-recipes</artifactId>
+            <version>2.13.0</version>
+        </dependency>
+
+    </dependencies>
+
+</project>
diff --git a/...src/main/java/cn/iocoder/springboot/lab40/zpkindemo/consumerdemo/ConsumerApplication.java b/...src/main/java/cn/iocoder/springboot/lab40/zpkindemo/consumerdemo/ConsumerApplication.java
@@ -0,0 +1,13 @@
+package cn.iocoder.springboot.lab40.zpkindemo.consumerdemo;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class ConsumerApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ConsumerApplication.class);
+    }
+
+}
diff --git a/...in/java/cn/iocoder/springboot/lab40/zpkindemo/consumerdemo/controller/UserController.java b/...in/java/cn/iocoder/springboot/lab40/zpkindemo/consumerdemo/controller/UserController.java
@@ -0,0 +1,22 @@
+package cn.iocoder.springboot.lab40.zpkindemo.consumerdemo.controller;
+
+import cn.iocoder.springboot.lab40.zipkindemo.api.UserService;
+import org.apache.dubbo.config.annotation.Reference;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/user")
+public class UserController {
+
+    @Reference(protocol = "dubbo", version = "1.0.0")
+    private UserService userService;
+
+    @GetMapping("/get")
+    public String  get(@RequestParam("id") Integer id) {
+        return userService.get(id);
+    }
+
+}
diff --git a/lab-40/lab-40-zipkin-dubbo/lab-40-zipkin-dubbo-consumer/src/main/resources/application.yaml b/lab-40/lab-40-zipkin-dubbo/lab-40-zipkin-dubbo-consumer/src/main/resources/application.yaml
@@ -0,0 +1,8 @@
+# dubbo 配置项，对应 DubboConfigurationProperties 配置类
+dubbo:
+  # Dubbo 应用配置
+  application:
+    name: user-service-consumer # 应用名
+  # Dubbo 注册中心配置
+  registry:
+    address: zookeeper://127.0.0.1:2181 # 注册中心地址。个鞥多注册中心，可见 http://dubbo.apache.org/zh-cn/docs/user/references/registry/introduction.html 文档。
diff --git a/lab-40/lab-40-zipkin-dubbo/lab-40-zipkin-dubbo-provider/pom.xml b/lab-40/lab-40-zipkin-dubbo/lab-40-zipkin-dubbo-provider/pom.xml
@@ -0,0 +1,55 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.2.2.RELEASE</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>lab-40-zipkin-dubbo-provider</artifactId>
+
+    <dependencies>
+        <!-- 引入定义的 Dubbo API 接口 -->
+        <dependency>
+            <groupId>cn.iocoder.springboot.labs</groupId>
+            <artifactId>lab-40-zipkin-dubbo-api</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+
+        <!-- 引入 Spring Boot 依赖 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
+        </dependency>
+
+        <!-- 实现对 Dubbo 的自动化配置 -->
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo</artifactId>
+            <version>2.7.4.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo-spring-boot-starter</artifactId>
+            <version>2.7.4.1</version>
+        </dependency>
+
+        <!-- 使用 Zookeeper 作为注册中心 -->
+        <dependency>
+            <groupId>org.apache.curator</groupId>
+            <artifactId>curator-framework</artifactId>
+            <version>2.13.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.curator</groupId>
+            <artifactId>curator-recipes</artifactId>
+            <version>2.13.0</version>
+        </dependency>
+
+    </dependencies>
+
+</project>
diff --git a/...rc/main/java/cn/iocoder/springboot/lab40/zipkindemo/providerdemo/ProviderApplication.java b/...rc/main/java/cn/iocoder/springboot/lab40/zipkindemo/providerdemo/ProviderApplication.java
@@ -0,0 +1,13 @@
+package cn.iocoder.springboot.lab40.zipkindemo.providerdemo;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class ProviderApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ProviderApplication.class);
+    }
+
+}
diff --git a/...ain/java/cn/iocoder/springboot/lab40/zipkindemo/providerdemo/service/UserServiceImpl.java b/...ain/java/cn/iocoder/springboot/lab40/zipkindemo/providerdemo/service/UserServiceImpl.java
@@ -0,0 +1,13 @@
+package cn.iocoder.springboot.lab40.zipkindemo.providerdemo.service;
+
+import cn.iocoder.springboot.lab40.zipkindemo.api.UserService;
+
+@org.apache.dubbo.config.annotation.Service(version = "1.0.0")
+public class UserServiceImpl implements UserService {
+
+    @Override
+    public String get(Integer id) {
+        return "user:" + id;
+    }
+
+}
diff --git a/lab-40/lab-40-zipkin-dubbo/lab-40-zipkin-dubbo-provider/src/main/resources/application.yaml b/lab-40/lab-40-zipkin-dubbo/lab-40-zipkin-dubbo-provider/src/main/resources/application.yaml
@@ -0,0 +1,15 @@
+# dubbo 配置项，对应 DubboConfigurationProperties 配置类
+dubbo:
+  # Dubbo 应用配置
+  application:
+    name: user-service-provider # 应用名
+  # Dubbo 注册中心配
+  registry:
+    address: zookeeper://127.0.0.1:2181 # 注册中心地址。个鞥多注册中心，可见 http://dubbo.apache.org/zh-cn/docs/user/references/registry/introduction.html 文档。
+  # Dubbo 服务提供者协议配置
+  protocol:
+    port: -1 # 协议端口。使用 -1 表示随机端口。
+    name: dubbo # 使用 `dubbo://` 协议。更多协议，可见 http://dubbo.apache.org/zh-cn/docs/user/references/protocol/introduction.html 文档
+  # 配置扫描 Dubbo 自定义的 @Service 注解，暴露成 Dubbo 服务提供者
+  scan:
+    base-packages: cn.iocoder.springboot.lab40.zipkindemo.providerdemo.service
diff --git a/lab-40/lab-40-zipkin-dubbo/pom.xml b/lab-40/lab-40-zipkin-dubbo/pom.xml
@@ -0,0 +1,21 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>labx-13</artifactId>
+        <groupId>cn.iocoder.springboot.labs</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>lab-40-zipkin-dubbo</artifactId>
+    <packaging>pom</packaging>
+    <modules>
+        <module>lab-40-zipkin-dubbo-api</module>
+        <module>lab-40-zipkin-dubbo-provider</module>
+        <module>lab-40-zipkin-dubbo-consumer</module>
+    </modules>
+
+
+</project>
diff --git a/lab-40/pom.xml b/lab-40/pom.xml
@@ -14,6 +14,8 @@
     <modules>
         <module>lab-40-demo</module>
         <module>lab-40-springmvc</module>
+        <module>lab-40-zipkin-dubbo</module>
+
         <module>lab-40-mysql</module>
         <module>lab-40-redis</module>
         <module>lab-40-mongodb</module>
@@ -22,8 +24,10 @@
         <module>lab-40-kafka</module>
         <module>lab-40-rabbitmq</module>
         <module>lab-40-activemq</module>
+
         <module>lab-40-logback</module>
         <module>lab-40-opentracing</module>
+
     </modules>