zipkin-server

Author: caliven

trace-1/pom.xml

@@ -42,9 +42,17 @@
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-sleuth</artifactId>
         </dependency>
-        <dependency>
+        <!--<dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-sleuth-zipkin</artifactId>
+        </dependency>-->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-sleuth-stream</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
         </dependency>
 
         <dependency>

trace-1/src/main/resources/application.properties

@@ -11,4 +11,11 @@ eureka.client.serviceUrl.defaultZone=http://${user-password}@peer1:9001/eureka/,
 
 
 # \u914D\u7F6E\u5C06\u8DDF\u8E2A\u4FE1\u606F\u8F93\u51FA\u5230Zipkin Server\uFF08spring.zipkin.base-url\u9ED8\u8BA4\u503C\u5C31\u662Fhttp://localhost:9411\uFF0C\u5982\u679C\u670D\u52A1\u7AEF\u7AEF\u53E3\u4E3A9411\uFF0C\u8FD9\u91CC\u53EF\u4EE5\u4E0D\u914D\u7F6E\uFF09
-spring.zipkin.base-url=http://localhost:9411
+#spring.zipkin.base-url=http://localhost:9411
+
+# Spring Cloud Sleuth\u5728\u6574\u5408Zipkin\u65F6\uFF0C\u4E0D\u4EC5\u5B9E\u73B0\u4E86\u4EE5HTTP\u7684\u65B9\u5F0F\u6536\u96C6\u8DDF\u8E2A\u4FE1\u606F\uFF0C\u8FD8\u5B9E\u73B0\u4E86\u901A\u8FC7\u6D88\u606F\u4E2D\u95F4\u4EF6\u6765\u5BF9\u8DDF\u8E2A\u4FE1\u606F\u8FDB\u884C\u5F02\u6B65\u6536\u96C6\u7684\u5C01\u88C5\u3002
+# \u901A\u8FC7\u7ED3\u5408Spring Cloud Stream\uFF0C\u6211\u4EEC\u53EF\u4EE5\u975E\u5E38\u8F7B\u677E\u7684\u8BA9\u5E94\u7528\u5BA2\u6237\u7AEF\u5C06\u8DDF\u8E2A\u4FE1\u606F\u8F93\u51FA\u5230\u6D88\u606F\u4E2D\u95F4\u4EF6\u4E0A\uFF0C\u540C\u65F6Zipkin\u670D\u52A1\u7AEF\u4ECE\u6D88\u606F\u4E2D\u95F4\u4EF6\u4E0A\u5F02\u6B65\u5730\u6D88\u8D39\u8FD9\u4E9B\u8DDF\u8E2A\u4FE1\u606F\u3002
+spring.rabbitmq.host=localhost
+spring.rabbitmq.port=5672
+#spring.rabbitmq.username=springcloud
+#spring.rabbitmq.password=123456

trace-2/pom.xml

@@ -42,9 +42,17 @@
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-sleuth</artifactId>
         </dependency>
-        <dependency>
+        <!--<dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-sleuth-zipkin</artifactId>
+        </dependency>-->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-sleuth-stream</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
         </dependency>
 
         <dependency>

trace-2/src/main/resources/application.properties

@@ -15,4 +15,11 @@ eureka.client.serviceUrl.defaultZone=http://${user-password}@peer1:9001/eureka/,
 
 
 # \u914D\u7F6E\u5C06\u8DDF\u8E2A\u4FE1\u606F\u8F93\u51FA\u5230Zipkin Server\uFF08spring.zipkin.base-url\u9ED8\u8BA4\u503C\u5C31\u662Fhttp://localhost:9411\uFF0C\u5982\u679C\u670D\u52A1\u7AEF\u7AEF\u53E3\u4E3A9411\uFF0C\u8FD9\u91CC\u53EF\u4EE5\u4E0D\u914D\u7F6E\uFF09
-spring.zipkin.base-url=http://localhost:9411
+#spring.zipkin.base-url=http://localhost:9411
+
+# Spring Cloud Sleuth\u5728\u6574\u5408Zipkin\u65F6\uFF0C\u4E0D\u4EC5\u5B9E\u73B0\u4E86\u4EE5HTTP\u7684\u65B9\u5F0F\u6536\u96C6\u8DDF\u8E2A\u4FE1\u606F\uFF0C\u8FD8\u5B9E\u73B0\u4E86\u901A\u8FC7\u6D88\u606F\u4E2D\u95F4\u4EF6\u6765\u5BF9\u8DDF\u8E2A\u4FE1\u606F\u8FDB\u884C\u5F02\u6B65\u6536\u96C6\u7684\u5C01\u88C5\u3002
+# \u901A\u8FC7\u7ED3\u5408Spring Cloud Stream\uFF0C\u6211\u4EEC\u53EF\u4EE5\u975E\u5E38\u8F7B\u677E\u7684\u8BA9\u5E94\u7528\u5BA2\u6237\u7AEF\u5C06\u8DDF\u8E2A\u4FE1\u606F\u8F93\u51FA\u5230\u6D88\u606F\u4E2D\u95F4\u4EF6\u4E0A\uFF0C\u540C\u65F6Zipkin\u670D\u52A1\u7AEF\u4ECE\u6D88\u606F\u4E2D\u95F4\u4EF6\u4E0A\u5F02\u6B65\u5730\u6D88\u8D39\u8FD9\u4E9B\u8DDF\u8E2A\u4FE1\u606F\u3002
+spring.rabbitmq.host=localhost
+spring.rabbitmq.port=5672
+#spring.rabbitmq.username=springcloud
+#spring.rabbitmq.password=123456

zipkin-server/pom.xml

@@ -34,6 +34,14 @@
             <groupId>io.zipkin.java</groupId>
             <artifactId>zipkin-autoconfigure-ui</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-sleuth-zipkin-stream</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
+        </dependency>
 
         <dependency>
             <groupId>org.springframework.boot</groupId>

zipkin-server/src/main/java/com/caliven/zipkin/server/ZipkinServerApplication.java

@@ -2,9 +2,12 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import zipkin.server.internal.EnableZipkinServer;
+import org.springframework.cloud.sleuth.zipkin.stream.EnableZipkinStreamServer;
 
-@EnableZipkinServer
+// 以http方式启动
+// @EnableZipkinServer
+// 以 stream 结合 RabbitMQ方式启动服务
+@EnableZipkinStreamServer
 @SpringBootApplication
 public class ZipkinServerApplication {
 

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

@@ -1,3 +1,4 @@
 spring.application.name=zipkin-server
+
 # \u5BA2\u6237\u7AEF\u6574\u5408\u65F6\u5019\uFF0C\u81EA\u52A8\u5316\u914D\u7F6E\u4F1A\u8FDE\u63A59411\u7AEF\u53E3\uFF0C\u6240\u4EE5\u5728\u670D\u52A1\u7AEF\u8BBE\u7F6E\u4E86\u7AEF\u53E3\u4E3A9411\u7684\u8BDD\uFF0C\u5BA2\u6237\u7AEF\u53EF\u4EE5\u7701\u53BB\u8FD9\u4E2A\u914D\u7F6E
 server.port=9411