You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by zh...@apache.org on 2021/09/04 15:57:37 UTC
[dubbo-go-samples] 05/12: Feature/openzipkin (#119)
This is an automated email from the ASF dual-hosted git repository.
zhaoyunxing pushed a commit to branch compress
in repository https://gitbox.apache.org/repos/asf/dubbo-go-samples.git
commit c178568f70d25a984fae1d502391cc5f70947aa3
Author: phil <ph...@foxmail.com>
AuthorDate: Mon May 24 10:05:16 2021 +0800
Feature/openzipkin (#119)
* update: add opentrace example use zipkin & prometheus
* update: add zipkin & prometheus in dubbo-go example
* update: readme
* update: update readme, and add more implementations
* update: README
---
.run/openzipkin/zipkin-go-client.run.xml | 15 ++
.run/openzipkin/zipkin-go-server-a.run.xml | 16 ++
.run/openzipkin/zipkin-go-server-b.run.xml | 15 ++
go.mod | 5 +-
go.sum | 17 ++
openzipkin/README.md | 174 ++++++++++++++++++++
openzipkin/README_zh.md | 179 +++++++++++++++++++++
openzipkin/doc/app_dependency.png | Bin 0 -> 32882 bytes
openzipkin/doc/zipkin_trace.png | Bin 0 -> 319434 bytes
openzipkin/docker-compose.yml | 58 +++++++
openzipkin/go-client/cmd/client.go | 155 ++++++++++++++++++
openzipkin/go-client/conf/client.yml | 67 ++++++++
openzipkin/go-client/conf/log.yml | 27 ++++
openzipkin/go-client/pkg/user.go | 50 ++++++
openzipkin/go-server-a/cmd/server.go | 109 +++++++++++++
openzipkin/go-server-a/conf/client.yml | 59 +++++++
openzipkin/go-server-a/conf/log.yml | 27 ++++
openzipkin/go-server-a/conf/server.yml | 67 ++++++++
openzipkin/go-server-a/docker/docker-compose.yml | 9 ++
openzipkin/go-server-a/pkg/user.go | 88 ++++++++++
.../go-server-a/tests/integration/main_test.go | 71 ++++++++
.../tests/integration/userprovider_test.go | 38 +++++
openzipkin/go-server-b/cmd/server.go | 107 ++++++++++++
openzipkin/go-server-b/conf/client.yml | 60 +++++++
openzipkin/go-server-b/conf/log.yml | 27 ++++
openzipkin/go-server-b/conf/server.yml | 57 +++++++
openzipkin/go-server-b/docker/docker-compose.yml | 9 ++
openzipkin/go-server-b/pkg/user.go | 62 +++++++
.../go-server-b/tests/integration/main_test.go | 71 ++++++++
.../tests/integration/userprovider_test.go | 39 +++++
.../prometheus/create-datasource-and-dashboard.sh | 33 ++++
openzipkin/prometheus/prometheus.yml | 13 ++
32 files changed, 1722 insertions(+), 2 deletions(-)
diff --git a/.run/openzipkin/zipkin-go-client.run.xml b/.run/openzipkin/zipkin-go-client.run.xml
new file mode 100644
index 0000000..8538c26
--- /dev/null
+++ b/.run/openzipkin/zipkin-go-client.run.xml
@@ -0,0 +1,15 @@
+<component name="ProjectRunConfigurationManager">
+ <configuration default="false" name="openzipkin-go-client" type="GoApplicationRunConfiguration" factoryName="Go Application" folderName="openzipkin">
+ <module name="dubbo-go-samples" />
+ <working_directory value="$PROJECT_DIR$" />
+ <envs>
+ <env name="APP_LOG_CONF_FILE" value="$PROJECT_DIR$/openzipkin/go-client/conf/log.yml" />
+ <env name="CONF_CONSUMER_FILE_PATH" value="$PROJECT_DIR$/openzipkin/go-client/conf/client.yml" />
+ </envs>
+ <kind value="PACKAGE" />
+ <filePath value="$PROJECT_DIR$/openzipkin/go-client/cmd/client.go" />
+ <package value="github.com/apache/dubbo-go-samples/openzipkin/go-client/cmd" />
+ <directory value="$PROJECT_DIR$" />
+ <method v="2" />
+ </configuration>
+</component>
\ No newline at end of file
diff --git a/.run/openzipkin/zipkin-go-server-a.run.xml b/.run/openzipkin/zipkin-go-server-a.run.xml
new file mode 100644
index 0000000..268acbc
--- /dev/null
+++ b/.run/openzipkin/zipkin-go-server-a.run.xml
@@ -0,0 +1,16 @@
+<component name="ProjectRunConfigurationManager">
+ <configuration default="false" name="openzipkin-go-server-a" type="GoApplicationRunConfiguration" factoryName="Go Application" folderName="openzipkin">
+ <module name="dubbo-go-samples" />
+ <working_directory value="$PROJECT_DIR$" />
+ <envs>
+ <env name="APP_LOG_CONF_FILE" value="$PROJECT_DIR$/openzipkin/go-server-a/conf/log.yml" />
+ <env name="CONF_PROVIDER_FILE_PATH" value="$PROJECT_DIR$/openzipkin/go-server-a/conf/server.yml" />
+ <env name="CONF_CONSUMER_FILE_PATH" value="$PROJECT_DIR$/openzipkin/go-server-a/conf/client.yml" />
+ </envs>
+ <kind value="PACKAGE" />
+ <filePath value="$PROJECT_DIR$/openzipkin/go-server-a/cmd/server.go" />
+ <package value="github.com/apache/dubbo-go-samples/openzipkin/go-server-a/cmd" />
+ <directory value="$PROJECT_DIR$" />
+ <method v="2" />
+ </configuration>
+</component>
\ No newline at end of file
diff --git a/.run/openzipkin/zipkin-go-server-b.run.xml b/.run/openzipkin/zipkin-go-server-b.run.xml
new file mode 100644
index 0000000..b6137d9
--- /dev/null
+++ b/.run/openzipkin/zipkin-go-server-b.run.xml
@@ -0,0 +1,15 @@
+<component name="ProjectRunConfigurationManager">
+ <configuration default="false" name="openzipkin-go-server-b" type="GoApplicationRunConfiguration" factoryName="Go Application" folderName="openzipkin">
+ <module name="dubbo-go-samples" />
+ <working_directory value="$PROJECT_DIR$" />
+ <envs>
+ <env name="APP_LOG_CONF_FILE" value="$PROJECT_DIR$/openzipkin/go-server-b/conf/log.yml" />
+ <env name="CONF_PROVIDER_FILE_PATH" value="$PROJECT_DIR$/openzipkin/go-server-b/conf/server.yml" />
+ </envs>
+ <kind value="PACKAGE" />
+ <filePath value="$PROJECT_DIR$/openzipkin/go-server-b/cmd/server.go" />
+ <package value="github.com/apache/dubbo-go-samples/openzipkin/go-server-b/cmd" />
+ <directory value="$PROJECT_DIR$" />
+ <method v="2" />
+ </configuration>
+</component>
\ No newline at end of file
diff --git a/go.mod b/go.mod
index 3885d92..629c7f9 100644
--- a/go.mod
+++ b/go.mod
@@ -2,6 +2,7 @@ module github.com/apache/dubbo-go-samples
require (
cloud.google.com/go v0.50.0 // indirect
+ contrib.go.opencensus.io/exporter/prometheus v0.3.0
github.com/Microsoft/go-winio v0.4.15-0.20190919025122-fc70bd9a86b5 // indirect
github.com/alibaba/sentinel-golang v1.0.2
github.com/apache/dubbo-getty v1.4.3
@@ -13,7 +14,6 @@ require (
github.com/emicklei/go-restful/v3 v3.4.0
github.com/golang/protobuf v1.4.3
github.com/gophercloud/gophercloud v0.3.0 // indirect
- github.com/hashicorp/golang-lru v0.5.3 // indirect
github.com/imdario/mergo v0.3.9 // indirect
github.com/linode/linodego v0.10.0 // indirect
github.com/miekg/dns v1.1.27 // indirect
@@ -28,7 +28,8 @@ require (
github.com/transaction-wg/seata-golang v0.2.1-alpha
github.com/uber/jaeger-client-go v2.22.1+incompatible
github.com/uber/jaeger-lib v2.2.0+incompatible // indirect
- google.golang.org/grpc v1.33.1
+ go.opencensus.io v0.23.0
+ google.golang.org/grpc v1.33.2
google.golang.org/grpc/examples v0.0.0-20210322221411-d26af8e39165 // indirect
)
diff --git a/go.sum b/go.sum
index 6f9977b..96d650d 100644
--- a/go.sum
+++ b/go.sum
@@ -13,6 +13,8 @@ cloud.google.com/go/datastore v1.0.0/go.mod h1:LXYbyblFSglQ5pkeyhO+Qmw7ukd3C+pD7
cloud.google.com/go/firestore v1.1.0/go.mod h1:ulACoGHTpvq5r8rxGJ4ddJZBZqakUQqClKRT5SZwBmk=
cloud.google.com/go/pubsub v1.0.1/go.mod h1:R0Gpsv3s54REJCy4fxDixWD93lHJMoZTyQ2kNxGRt3I=
cloud.google.com/go/storage v1.0.0/go.mod h1:IhtSnM/ZTZV8YYJWCY8RULGVqBDmpoyjwiyrjsg+URw=
+contrib.go.opencensus.io/exporter/prometheus v0.3.0 h1:08FMdJYpItzsknogU6PiiNo7XQZg/25GjH236+YCwD0=
+contrib.go.opencensus.io/exporter/prometheus v0.3.0/go.mod h1:rpCPVQKhiyH8oomWgm34ZmgIdZa8OVYO5WAIygPbBBE=
dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU=
github.com/Azure/azure-sdk-for-go v40.3.0+incompatible h1:NthZg3psrLxvQLN6rVm07pZ9mv2wvGNaBNGQ3fnPvLE=
github.com/Azure/azure-sdk-for-go v40.3.0+incompatible/go.mod h1:9XXNKU+eRnpl9moKnB4QOLf1HestfXbmab5FXxiDBjc=
@@ -77,9 +79,11 @@ github.com/abdullin/seq v0.0.0-20160510034733-d5467c17e7af/go.mod h1:5Jv4cbFiHJM
github.com/afex/hystrix-go v0.0.0-20180502004556-fa1af6a1f4f5 h1:rFw4nCn9iMW+Vajsk51NtYIcwSTkXr+JGrMd36kTDJw=
github.com/afex/hystrix-go v0.0.0-20180502004556-fa1af6a1f4f5/go.mod h1:SkGFH1ia65gfNATL8TAiHDNxPzPdmEL5uirI2Uyuz6c=
github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
+github.com/alecthomas/template v0.0.0-20190718012654-fb15b899a751 h1:JYp7IbQjafoB+tBA3gMyHYHrpOtNuDiK/uB5uXxq5wM=
github.com/alecthomas/template v0.0.0-20190718012654-fb15b899a751/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
github.com/alecthomas/units v0.0.0-20190717042225-c3de453c63f4/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
+github.com/alecthomas/units v0.0.0-20190924025748-f65c72e2690d h1:UQZhZ2O0vMHr2cI+DC1Mbh0TJxzA3RcLoMsFw+aXw7E=
github.com/alecthomas/units v0.0.0-20190924025748-f65c72e2690d/go.mod h1:rBZYJk541a8SKzHPHnH3zbiI+7dagKZ0cgpgrD7Fyho=
github.com/alibaba/sentinel-golang v1.0.2 h1:Acopq74hOtZN4MV1v811MQ6QcqPFLDSczTrRXv9zpIg=
github.com/alibaba/sentinel-golang v1.0.2/go.mod h1:QsB99f/z35D2AiMrAWwgWE85kDTkBUIkcmPrRt+61NI=
@@ -355,6 +359,8 @@ github.com/google/go-cmp v0.5.0 h1:/QaMHBdZ26BB3SSst0Iwl10Epc+xhTquomWX0oZEB6w=
github.com/google/go-cmp v0.5.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
github.com/google/go-cmp v0.5.2 h1:X2ev0eStA3AbceY54o37/0PQ/UWqKEiiO2dKL5OPaFM=
github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.3/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
github.com/google/go-querystring v0.0.0-20170111101155-53e6ce116135/go.mod h1:odCYkC5MyYFN7vkCjXpyrEuKhc/BUO6wN/zVPAxq5ck=
github.com/google/go-querystring v1.0.0 h1:Xkwi/a1rcvNg1PPYe5vI8GbeBY/jrVuDX5ASuANWTrk=
github.com/google/go-querystring v1.0.0/go.mod h1:odCYkC5MyYFN7vkCjXpyrEuKhc/BUO6wN/zVPAxq5ck=
@@ -480,6 +486,7 @@ github.com/hashicorp/golang-lru v0.5.0/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ
github.com/hashicorp/golang-lru v0.5.1/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8=
github.com/hashicorp/golang-lru v0.5.3 h1:YPkqC67at8FYaadspW/6uE0COsBxS2656RLEr8Bppgk=
github.com/hashicorp/golang-lru v0.5.3/go.mod h1:iADmTwqILo4mZ8BN3D2Q6+9jd8WM5uGBxy+E8yxSoD4=
+github.com/hashicorp/golang-lru v0.5.4/go.mod h1:iADmTwqILo4mZ8BN3D2Q6+9jd8WM5uGBxy+E8yxSoD4=
github.com/hashicorp/hcl v1.0.0 h1:0Anlzjpi4vEasTeNFn2mLJgTSwt0+6sfsiTG8qcWGx4=
github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ=
github.com/hashicorp/hil v0.0.0-20160711231837-1e86c6b523c5 h1:uk280DXEbQiCOZgCOI3elFSeNxf8YIZiNsbr2pQLYD0=
@@ -762,6 +769,7 @@ github.com/prometheus/client_golang v0.9.3-0.20190127221311-3c4408c8b829/go.mod
github.com/prometheus/client_golang v0.9.3/go.mod h1:/TN21ttK/J9q6uSwhBd54HahCDft0ttaMvbicHlPoso=
github.com/prometheus/client_golang v1.0.0/go.mod h1:db9x61etRT2tGnBNRi70OPL5FsnadC4Ky3P0J6CfImo=
github.com/prometheus/client_golang v1.3.0/go.mod h1:hJaj2vgQTGQmVCsAACORcieXFeDPbaTKGT+JTgUa3og=
+github.com/prometheus/client_golang v1.6.0/go.mod h1:ZLOG9ck3JLRdB5MgO8f+lLTe83AXG6ro35rLTxvnIl4=
github.com/prometheus/client_golang v1.7.1/go.mod h1:PY5Wy2awLA44sXw4AOSfFBetzPP4j5+D6mVACh+pe2M=
github.com/prometheus/client_golang v1.8.0 h1:zvJNkoCFAnYFNC24FV8nW4JdRJ3GIFcLbg65lL/JDcw=
github.com/prometheus/client_golang v1.8.0/go.mod h1:O9VU6huf47PktckDQfMTX0Y8tY0/7TSWwj+ITvv0TnM=
@@ -779,6 +787,7 @@ github.com/prometheus/common v0.2.0/go.mod h1:TNfzLD0ON7rHzMJeJkieUDPYmFC7Snx/y8
github.com/prometheus/common v0.4.0/go.mod h1:TNfzLD0ON7rHzMJeJkieUDPYmFC7Snx/y86RQel1bk4=
github.com/prometheus/common v0.4.1/go.mod h1:TNfzLD0ON7rHzMJeJkieUDPYmFC7Snx/y86RQel1bk4=
github.com/prometheus/common v0.7.0/go.mod h1:DjGbpBbp5NYNiECxcL/VnbXCCaQpKd3tt26CguLLsqA=
+github.com/prometheus/common v0.9.1/go.mod h1:yhUN8i9wzaXS3w1O07YhxHEBxD+W35wd8bs7vj7HSQ4=
github.com/prometheus/common v0.10.0/go.mod h1:Tlit/dnDKsSWFlCLTWaA1cyBgKHSMdTB80sz/V91rCo=
github.com/prometheus/common v0.14.0 h1:RHRyE8UocrbjU+6UvRzwi6HjiDfxrrBU91TtbKzkGp4=
github.com/prometheus/common v0.14.0/go.mod h1:U+gB1OBLb1lF3O42bTCL+FK18tX9Oar16Clt/msog/s=
@@ -790,9 +799,12 @@ github.com/prometheus/procfs v0.0.0-20190117184657-bf6a532e95b1/go.mod h1:c3At6R
github.com/prometheus/procfs v0.0.0-20190507164030-5867b95ac084/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA=
github.com/prometheus/procfs v0.0.2/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA=
github.com/prometheus/procfs v0.0.8/go.mod h1:7Qr8sr6344vo1JqZ6HhLceV9o3AJ1Ff+GxbHq6oeK9A=
+github.com/prometheus/procfs v0.0.11/go.mod h1:lV6e/gmhEcM9IjHGsFOCxxuZ+z1YqCvr4OA4YeYWdaU=
github.com/prometheus/procfs v0.1.3/go.mod h1:lV6e/gmhEcM9IjHGsFOCxxuZ+z1YqCvr4OA4YeYWdaU=
github.com/prometheus/procfs v0.2.0 h1:wH4vA7pcjKuZzjF7lM8awk4fnuJO6idemZXoKnULUx4=
github.com/prometheus/procfs v0.2.0/go.mod h1:lV6e/gmhEcM9IjHGsFOCxxuZ+z1YqCvr4OA4YeYWdaU=
+github.com/prometheus/statsd_exporter v0.20.0 h1:M0hQphnq2WyWKS5CefQL8PqWwBOBPhiAkyLo5l4ZYvE=
+github.com/prometheus/statsd_exporter v0.20.0/go.mod h1:YL3FWCG8JBBtaUSxAg4Gz2ZYu22bS84XM89ZQXXTWmQ=
github.com/prometheus/tsdb v0.7.1/go.mod h1:qhTCs0VvXwvX/y3TZrWD7rabWM+ijKTux40TwIPHuXU=
github.com/rboyer/safeio v0.2.1/go.mod h1:Cq/cEPK+YXFn622lsQ0K4KsPZSPtaptHHEldsy7Fmig=
github.com/rcrowley/go-metrics v0.0.0-20181016184325-3113b8401b8a/go.mod h1:bCqnVzQkZxMG4s8nGwiZ5l3QUCyqpo9Y+/ZMZ9VjZe4=
@@ -940,6 +952,8 @@ go.opencensus.io v0.21.0/go.mod h1:mSImk1erAIZhrmZN+AvHh14ztQfjbGwt4TtuofqLduU=
go.opencensus.io v0.22.0/go.mod h1:+kGneAE2xo2IficOXnaByMWTGM9T73dGwxeWcUqIpI8=
go.opencensus.io v0.22.2 h1:75k/FF0Q2YM8QYo07VPddOLBslDt1MZOdEslOHvmzAs=
go.opencensus.io v0.22.2/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
+go.opencensus.io v0.23.0 h1:gqCw0LfLxScz8irSi8exQc7fyQ0fKQU/qnC/X8+V/1M=
+go.opencensus.io v0.23.0/go.mod h1:XItmlyltB5F7CS4xOC1DcqMoFqwtC6OG2xF7mCv7P7E=
go.uber.org/atomic v1.3.2/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
go.uber.org/atomic v1.5.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
@@ -1036,6 +1050,7 @@ golang.org/x/net v0.0.0-20200822124328-c89045814202 h1:VvcQYSHwXgi7W+TpUR6A9g6Up
golang.org/x/net v0.0.0-20200822124328-c89045814202/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA=
golang.org/x/net v0.0.0-20201021035429-f5854403a974 h1:IX6qOQeG5uLjB/hjjwjedwfjND0hgjPMMyO1RoIXQNI=
golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=
+golang.org/x/net v0.0.0-20201110031124-69a78807bb2b/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=
golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45 h1:SVwTIAaPC2U/AvvLNZ2a7OVsmBpC8L5BlwK1whH3hm0=
@@ -1095,6 +1110,7 @@ golang.org/x/sys v0.0.0-20200202164722-d101bd2416d5/go.mod h1:h1NjWce9XRLGQEsW7w
golang.org/x/sys v0.0.0-20200223170610-d5e6a3e2c0ae/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200420163511-1957bb5e6d1f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200523222454-059865788121/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200615200032-f1bc736245b1/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200625212154-ddb9806d33ae/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -1238,6 +1254,7 @@ google.golang.org/protobuf v1.24.0/go.mod h1:r/3tXBNzIEhYS9I1OUVjXDlt8tc493IdKGj
google.golang.org/protobuf v1.25.0 h1:Ejskq+SyPohKW+1uil0JJMtmHCgJPJ/qWTxr8qp+R4c=
google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c=
gopkg.in/airbrake/gobrake.v2 v2.0.9/go.mod h1:/h5ZAUhDkGaJfjzjKLSjv6zCL6O0LLBxU4K+aSYdM/U=
+gopkg.in/alecthomas/kingpin.v2 v2.2.6 h1:jMFz6MfLP0/4fUyZle81rXUoxOBFi19VUFKVDOQfozc=
gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw=
gopkg.in/asn1-ber.v1 v1.0.0-20181015200546-f715ec2f112d/go.mod h1:cuepJuh7vyXfUyUwEgHQXw849cJrilpS5NeIjOWESAw=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
diff --git a/openzipkin/README.md b/openzipkin/README.md
new file mode 100644
index 0000000..54ef3db
--- /dev/null
+++ b/openzipkin/README.md
@@ -0,0 +1,174 @@
+# Zipkin in Dubbo-go Example
+
+## Backend
+
+**Zipkin** is a distributed tracing system. It helps **Dubbo-go** gathering timing data which is used to troubleshoot latency problems in service architectures.
+
+## Introduction
+
+```markdown
+.
+├── README.md
+├── README_zh.md
+├── docker-compose.yml
+├── go-client
+├── go-server-a
+├── go-server-b
+└── prometheus
+```
+
+- go-client ：The Service Consumer
+- go-server-a ：The Service Provider A
+- go-server-b ：The Service Provider B
+
+Client calls ProviderA , and then calls ProviderB,
+ProviderA also makes a request to ProviderB！
+
+dependencies :
+
+
+## Code
+
+register Zipkin. Reporter，Endpoint，Tracer，default sample `AlwaysSample`
+
+```go
+func registerZipkin() {
+ // set up a span reporter
+ reporter := zipkinhttp.NewReporter("http://localhost:9411/api/v2/spans")
+
+ // create our local service endpoint
+ endpoint, err := zipkin.NewEndpoint("go-server-a", "localhost:80")
+ if err != nil {
+ gxlog.CError("unable to create local endpoint: %+v\n", err)
+ }
+
+ // set sampler , default AlwaysSample
+ // sampler := zipkin.NewModuloSampler(1)
+
+ // initialize our tracer
+ // nativeTracer, err := zipkin.NewTracer(reporter, zipkin.WithLocalEndpoint(endpoint), zipkin.WithSampler(sampler))
+ nativeTracer, err := zipkin.NewTracer(reporter, zipkin.WithLocalEndpoint(endpoint))
+ if err != nil {
+ gxlog.CError("unable to create tracer: %+v\n", err)
+ }
+
+ // use zipkin-go-opentracing to wrap our tracer
+ tracer := zipkinot.Wrap(nativeTracer)
+
+ // optionally set as Global OpenTracing tracer instance
+ opentracing.SetGlobalTracer(tracer)
+}
+```
+
+## Config
+
+Provider config filter：
+
+```yaml
+
+services:
+ ...
+filter: "tracing"
+
+```
+
+## Filter
+
+Dubbo-go supports `opentrace filter`
+
+```go
+func (tf *tracingFilter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result {
+ var (
+ spanCtx context.Context
+ span opentracing.Span
+ )
+ operationName := invoker.GetUrl().ServiceKey() + "#" + invocation.MethodName()
+
+ wiredCtx := ctx.Value(constant.TRACING_REMOTE_SPAN_CTX)
+ preSpan := opentracing.SpanFromContext(ctx)
+
+ if preSpan != nil {
+ // it means that someone already create a span to trace, so we use the span to be the parent span
+ span = opentracing.StartSpan(operationName, opentracing.ChildOf(preSpan.Context()))
+ spanCtx = opentracing.ContextWithSpan(ctx, span)
+
+ } else if wiredCtx != nil {
+
+ // it means that there has a remote span, usually from client side. so we use this as the parent
+ span = opentracing.StartSpan(operationName, opentracing.ChildOf(wiredCtx.(opentracing.SpanContext)))
+ spanCtx = opentracing.ContextWithSpan(ctx, span)
+ } else {
+ // it means that there is not any span, so we create a span as the root span.
+ span, spanCtx = opentracing.StartSpanFromContext(ctx, operationName)
+ }
+
+ defer func() {
+ span.Finish()
+ }()
+
+ result := invoker.Invoke(spanCtx, invocation)
+ span.SetTag(successKey, result.Error() == nil)
+ if result.Error() != nil {
+ span.LogFields(log.String(errorKey, result.Error().Error()))
+ }
+ return result
+}
+```
+
+## Install Zipkin
+
+First Way:
+
+Follow [Zipkin's quick start](https://zipkin.io/pages/quickstart.html) to install zipkin.
+
+```bash
+curl -sSL https://zipkin.io/quickstart.sh | bash -s
+```
+
+Zipkin supports various backend storages including Cassandra, ElasticSearch and MySQL. Here we use the simplest storage - in-memory for demo purpose.
+
+```bash
+java -jar zipkin.jar
+```
+
+Once the process starts, you can verify zipkin server works by access http://localhost:9411
+
+Or Use Docker:
+
+See [/dubbo-go-sample/zipkin/docker/docker-compose.yml](docker-compose.yml)
+
+```dockerfile
+services:
+ # The zipkin process services the UI, and also exposes a POST endpoint that
+ # instrumentation can send trace data to.
+ zipkin:
+ image: ghcr.io/openzipkin/zipkin-slim:${TAG:-latest}
+ container_name: zipkin
+ # Environment settings are defined here https://github.com/openzipkin/zipkin/blob/master/zipkin-server/README.md#environment-variables
+ environment:
+ - STORAGE_TYPE=mem
+ # Point the zipkin at the storage backend
+ - MYSQL_HOST=mysql
+ # Uncomment to enable self-tracing
+ # - SELF_TRACING_ENABLED=true
+ # Uncomment to increase heap size
+ # - JAVA_OPTS=-Xms128m -Xmx128m -XX:+ExitOnOutOfMemoryError
+ ports:
+ # Port used for the Zipkin UI and HTTP Api
+ - 9411:9411
+ # Uncomment to enable debug logging
+ # command: --logging.level.zipkin2=DEBUG
+```
+
+```bash
+docker-compose -f docker/docker-compose.yml up -d zipkin
+```
+
+### How To Run
+
+Refer to [HOWTO.md](../HOWTO_zh.md) under the root directory to run this sample.
+
+## The End
+
+Trace ：
+
diff --git a/openzipkin/README_zh.md b/openzipkin/README_zh.md
new file mode 100644
index 0000000..72d8ec3
--- /dev/null
+++ b/openzipkin/README_zh.md
@@ -0,0 +1,179 @@
+# Zipkin 在 Dubbo-go 应用示例
+
+# 背景
+
+Zipkin是一个分布式跟踪系统。它有助于收集解决 Dubbo-go 服务中的延迟问题所需的时序数据。
+包括该数据的收集和查找。
+
+# 介绍
+
+本示例演示了 Zipkin 在 Dubbo-go 应用程序中的基本用法。
+
+```markdown
+.
+├── README.md
+├── README_zh.md
+├── docker-compose.yml
+├── go-client
+├── go-server-a
+├── go-server-b
+└── prometheus
+```
+
+- go-client ：服务消费者
+- go-server-a ：服务提供者 A
+- go-server-b ：服务提供者 B
+
+为了演示效果，示例中 Client 会同时对 ProviderA 与 ProviderB 发起请求，
+ProviderA 内部也会对 ProviderB 发起请求！
+
+依赖关系：
+
+
+
+## 代码说明
+
+服务启动时注册 Zipkin，包括 Reporter，Endpoint，Tracer，默认采样比例全采样 `AlwaysSample` ，可自行配置
+
+```go
+func registerZipkin() {
+ // set up a span reporter
+ reporter := zipkinhttp.NewReporter("http://localhost:9411/api/v2/spans")
+
+ // create our local service endpoint
+ endpoint, err := zipkin.NewEndpoint("go-server-a", "localhost:80")
+ if err != nil {
+ gxlog.CError("unable to create local endpoint: %+v\n", err)
+ }
+
+ // set sampler , default AlwaysSample
+ // sampler := zipkin.NewModuloSampler(1)
+
+ // initialize our tracer
+ // nativeTracer, err := zipkin.NewTracer(reporter, zipkin.WithLocalEndpoint(endpoint), zipkin.WithSampler(sampler))
+ nativeTracer, err := zipkin.NewTracer(reporter, zipkin.WithLocalEndpoint(endpoint))
+ if err != nil {
+ gxlog.CError("unable to create tracer: %+v\n", err)
+ }
+
+ // use zipkin-go-opentracing to wrap our tracer
+ tracer := zipkinot.Wrap(nativeTracer)
+
+ // optionally set as Global OpenTracing tracer instance
+ opentracing.SetGlobalTracer(tracer)
+}
+```
+
+## 配置
+
+服务提供者配置过滤器：
+
+```yaml
+
+services:
+ ...
+filter: "tracing"
+
+```
+
+## 过滤器
+
+Dubbo-go 提供 opentrace filter 实现，基于简单配置即可
+
+```go
+func (tf *tracingFilter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result {
+ var (
+ spanCtx context.Context
+ span opentracing.Span
+ )
+ operationName := invoker.GetUrl().ServiceKey() + "#" + invocation.MethodName()
+
+ wiredCtx := ctx.Value(constant.TRACING_REMOTE_SPAN_CTX)
+ preSpan := opentracing.SpanFromContext(ctx)
+
+ if preSpan != nil {
+ // it means that someone already create a span to trace, so we use the span to be the parent span
+ span = opentracing.StartSpan(operationName, opentracing.ChildOf(preSpan.Context()))
+ spanCtx = opentracing.ContextWithSpan(ctx, span)
+
+ } else if wiredCtx != nil {
+
+ // it means that there has a remote span, usually from client side. so we use this as the parent
+ span = opentracing.StartSpan(operationName, opentracing.ChildOf(wiredCtx.(opentracing.SpanContext)))
+ spanCtx = opentracing.ContextWithSpan(ctx, span)
+ } else {
+ // it means that there is not any span, so we create a span as the root span.
+ span, spanCtx = opentracing.StartSpanFromContext(ctx, operationName)
+ }
+
+ defer func() {
+ span.Finish()
+ }()
+
+ result := invoker.Invoke(spanCtx, invocation)
+ span.SetTag(successKey, result.Error() == nil)
+ if result.Error() != nil {
+ span.LogFields(log.String(errorKey, result.Error().Error()))
+ }
+ return result
+}
+```
+
+
+## 安装 Zipkin
+
+第一种：
+
+参考 [Zipkin's quick start](https://zipkin.io/pages/quickstart.html) 安装 Zopkin
+
+Follow [Zipkin's quick start](https://zipkin.io/pages/quickstart.html) to install zipkin.
+
+```bash
+curl -sSL https://zipkin.io/quickstart.sh | bash -s
+```
+
+Zipkin支持多种后端存储，包括Cassandra, ElasticSearch和MySQL。这里我们使用最简单的内存存储作为演示目的。
+
+
+```bash
+java -jar zipkin.jar
+```
+
+您可以通过访问 http://localhost:9411 验证安装效果
+
+或者使用 Docker :
+
+See [/dubbo-go-sample/zipkin/docker/docker-compose.yml](docker-compose.yml)
+
+```dockerfile
+version: '2.4'
+
+services:
+ # The zipkin process services the UI, and also exposes a POST endpoint that
+ # instrumentation can send trace data to.
+ zipkin:
+ image: ghcr.io/openzipkin/zipkin-slim:${TAG:-latest}
+ container_name: zipkin
+ # Environment settings are defined here https://github.com/openzipkin/zipkin/blob/master/zipkin-server/README.md#environment-variables
+ environment:
+ - STORAGE_TYPE=mem
+ # Point the zipkin at the storage backend
+ - MYSQL_HOST=mysql
+ # Uncomment to enable self-tracing
+ # - SELF_TRACING_ENABLED=true
+ # Uncomment to increase heap size
+ # - JAVA_OPTS=-Xms128m -Xmx128m -XX:+ExitOnOutOfMemoryError
+ ports:
+ # Port used for the Zipkin UI and HTTP Api
+ - 9411:9411
+ # Uncomment to enable debug logging
+ # command: --logging.level.zipkin2=DEBUG
+```
+
+## 如何运行
+请参阅根目录中的 [HOWTO.md](../HOWTO_zh.md) 来运行本例。
+
+## 效果
+
+链路：
+
diff --git a/openzipkin/doc/app_dependency.png b/openzipkin/doc/app_dependency.png
new file mode 100644
index 0000000..473387d
Binary files /dev/null and b/openzipkin/doc/app_dependency.png differ
diff --git a/openzipkin/doc/zipkin_trace.png b/openzipkin/doc/zipkin_trace.png
new file mode 100644
index 0000000..a43531a
Binary files /dev/null and b/openzipkin/doc/zipkin_trace.png differ
diff --git a/openzipkin/docker-compose.yml b/openzipkin/docker-compose.yml
new file mode 100644
index 0000000..5ee5798
--- /dev/null
+++ b/openzipkin/docker-compose.yml
@@ -0,0 +1,58 @@
+version: '2.4'
+
+services:
+ zipkin:
+ image: ghcr.io/openzipkin/zipkin-slim:${TAG:-latest}
+ container_name: zipkin
+ # Environment settings are defined here https://github.com/openzipkin/zipkin/blob/master/zipkin-server/README.md#environment-variables
+ environment:
+ - STORAGE_TYPE=mem
+ # Point the zipkin at the storage backend
+ - MYSQL_HOST=mysql
+ # Uncomment to enable self-tracing
+ # - SELF_TRACING_ENABLED=true
+ # Uncomment to increase heap size
+ # - JAVA_OPTS=-Xms128m -Xmx128m -XX:+ExitOnOutOfMemoryError
+ ports:
+ # Port used for the Zipkin UI and HTTP Api
+ - 9411:9411
+ # Uncomment to enable debug logging
+ # command: --logging.level.zipkin2=DEBUG
+ prometheus:
+ # Use a quay.io mirror to prevent build outages due to Docker Hub pull quotas
+ # Use latest from https://quay.io/repository/prometheus/prometheus?tab=tags
+ image: quay.io/prometheus/prometheus:latest
+ container_name: prometheus
+ ports:
+ - 9090:9090
+ depends_on:
+ - zipkin
+ volumes:
+ - ./prometheus/prometheus.yml:/etc/prometheus/prometheus.yml
+
+ grafana:
+ # Use a quay.io mirror to prevent build outages due to Docker Hub pull quotas
+ # Use latest from https://quay.io/repository/app-sre/grafana?tab=tags
+ image: quay.io/app-sre/grafana:7.3.4
+# image: quay.io/opencloudio/ibm-monitoring-grafana-operator:1.12.0
+ container_name: grafana
+ ports:
+ - 3000:3000
+ depends_on:
+ - prometheus
+ environment:
+ - GF_AUTH_ANONYMOUS_ENABLED=true
+ - GF_AUTH_ANONYMOUS_ORG_ROLE=Admin
+
+ setup_grafana_datasource:
+ # This is an arbitrary small image that has curl installed
+ # Use a quay.io mirror to prevent build outages due to Docker Hub pull quotas
+ # Use latest from https://quay.io/repository/quay.io/rackspace/curl?tab=tags
+ image: quay.io/rackspace/curl:7.70.0
+ container_name: setup_grafana_datasource
+ depends_on:
+ - grafana
+ volumes:
+ - ./prometheus/create-datasource-and-dashboard.sh:/tmp/create.sh:ro
+ working_dir: /tmp
+ entrypoint: /tmp/create.sh
\ No newline at end of file
diff --git a/openzipkin/go-client/cmd/client.go b/openzipkin/go-client/cmd/client.go
new file mode 100644
index 0000000..872ef8c
--- /dev/null
+++ b/openzipkin/go-client/cmd/client.go
@@ -0,0 +1,155 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package main
+
+import (
+ "context"
+ "contrib.go.opencensus.io/exporter/prometheus"
+ "go.opencensus.io/stats/view"
+ "math/rand"
+ "os"
+ "time"
+)
+
+import (
+ hessian "github.com/apache/dubbo-go-hessian2"
+ _ "github.com/apache/dubbo-go/cluster/cluster_impl"
+ _ "github.com/apache/dubbo-go/cluster/loadbalance"
+ _ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
+ "github.com/apache/dubbo-go/config"
+ _ "github.com/apache/dubbo-go/filter/filter_impl"
+ _ "github.com/apache/dubbo-go/protocol/dubbo"
+ _ "github.com/apache/dubbo-go/registry/protocol"
+ _ "github.com/apache/dubbo-go/registry/zookeeper"
+ "github.com/dubbogo/gost/log"
+ // tracing zipkin & prometheus
+ "github.com/opentracing/opentracing-go"
+ zipkinot "github.com/openzipkin-contrib/zipkin-go-opentracing"
+ "github.com/openzipkin/zipkin-go"
+ zipkinhttp "github.com/openzipkin/zipkin-go/reporter/http"
+)
+
+import (
+ "github.com/apache/dubbo-go-samples/openzipkin/go-client/pkg"
+)
+
+var userProviderA = new(pkg.UserProviderA)
+var userProviderB = new(pkg.UserProviderB)
+
+func init() {
+ config.SetConsumerService(userProviderA)
+ config.SetConsumerService(userProviderB)
+ hessian.RegisterPOJO(&pkg.User{})
+}
+
+// need to setup environment variable "CONF_CONSUMER_FILE_PATH" to "conf/client.yml" before run
+func main() {
+
+ config.Load()
+
+ // register zipkin & prometheus exporter
+ registerZipkin()
+ registerPrometheus()
+
+ time.Sleep(3 * time.Second)
+
+ gxlog.CInfo("\n\n\nstart to test dubbo")
+
+ getUserAll(context.Background())
+}
+
+func getUserAll(ctx context.Context) {
+ span, ctx := opentracing.StartSpanFromContext(ctx, "getUserAll")
+
+ getUserA(ctx)
+ span.Finish()
+
+ getUserB(ctx)
+ span.Finish()
+
+ getUserA(ctx)
+ span.Finish()
+
+ getUserB(ctx)
+ span.Finish()
+}
+
+func getUserA(ctx context.Context) {
+
+ time.Sleep(time.Duration(rand.Intn(977)+300) * time.Millisecond)
+ user := &pkg.User{}
+ err := userProviderA.GetUser(ctx, []interface{}{"A001"}, user)
+ if err != nil {
+ gxlog.CError("error: %v\n", err)
+ os.Exit(1)
+ return
+ }
+ gxlog.CInfo("response result: %v\n", user)
+
+}
+func getUserB(ctx context.Context) {
+
+ time.Sleep(time.Duration(rand.Intn(977)+300) * time.Millisecond)
+ user := &pkg.User{}
+ err := userProviderB.GetUser(ctx, []interface{}{"A001"}, user)
+ if err != nil {
+ gxlog.CError("error: %v\n", err)
+ os.Exit(1)
+ return
+ }
+ gxlog.CInfo("response result: %v\n", user)
+}
+
+// zipkin / opentracing specific stuff
+func registerZipkin() {
+ // set up a span reporter
+ reporter := zipkinhttp.NewReporter("http://localhost:9411/api/v2/spans")
+
+ // create our local service endpoint
+ endpoint, err := zipkin.NewEndpoint("go-client", "localhost:80")
+ if err != nil {
+ gxlog.CError("unable to create local endpoint: %+v\n", err)
+ }
+
+ // set sampler , default AlwaysSample
+ //sampler := zipkin.NewModuloSampler(1)
+
+ // initialize our tracer
+ //nativeTracer, err := zipkin.NewTracer(reporter, zipkin.WithLocalEndpoint(endpoint), zipkin.WithSampler(sampler))
+ nativeTracer, err := zipkin.NewTracer(reporter, zipkin.WithLocalEndpoint(endpoint))
+
+ if err != nil {
+ gxlog.CError("unable to create tracer: %+v\n", err)
+ }
+
+ // use zipkin-go-opentracing to wrap our tracer
+ tracer := zipkinot.Wrap(nativeTracer)
+
+ // optionally set as Global OpenTracing tracer instance
+ opentracing.SetGlobalTracer(tracer)
+}
+
+// register prometheus exporter for zipkin
+func registerPrometheus() *prometheus.Exporter {
+ pe, err := prometheus.NewExporter(prometheus.Options{Namespace: "go-client"})
+ if err != nil {
+ gxlog.CError("Failed to create Prometheus exporter: %v", err)
+ }
+ view.RegisterExporter(pe)
+ return pe
+}
diff --git a/openzipkin/go-client/conf/client.yml b/openzipkin/go-client/conf/client.yml
new file mode 100644
index 0000000..79bd4ad
--- /dev/null
+++ b/openzipkin/go-client/conf/client.yml
@@ -0,0 +1,67 @@
+# dubbo client yaml configure file
+
+check: true
+# client
+request_timeout: "3s"
+# connect timeout
+connect_timeout: "3s"
+
+# application config
+application:
+ organization: "dubbo.io"
+ name: "UserInfoClient"
+ module: "dubbo-go user-info client"
+ version: "0.0.1"
+ environment: "dev"
+
+# registry config
+registries:
+ "demoZk":
+ protocol: "zookeeper"
+ timeout: "3s"
+ address: "127.0.0.1:2181"
+ username: ""
+ password: ""
+
+# reference config
+references:
+ "UserProviderA":
+ registry: "demoZk"
+ protocol: "dubbo"
+ interface: "org.apache.dubbo.UserProviderA"
+ cluster: "failover"
+ methods:
+ - name: "GetUser"
+ retries: 1
+ "UserProviderB":
+ registry: "demoZk"
+ protocol: "dubbo"
+ interface: "org.apache.dubbo.UserProviderB"
+ cluster: "failover"
+ methods:
+ - name: "GetUser"
+ retries: 1
+
+# protocol config
+protocol_conf:
+ dubbo:
+ reconnect_interval: 0
+ connection_number: 1
+ heartbeat_period: "5s"
+ session_timeout: "180s"
+ pool_size: 64
+ pool_ttl: 600
+ getty_session_param:
+ compress_encoding: false
+ tcp_no_delay: true
+ tcp_keep_alive: true
+ keep_alive_period: "120s"
+ tcp_r_buf_size: 262144
+ tcp_w_buf_size: 65536
+ pkg_rq_size: 1024
+ pkg_wq_size: 512
+ tcp_read_timeout: "1s"
+ tcp_write_timeout: "5s"
+ wait_timeout: "1s"
+ max_msg_len: 1024000
+ session_name: "client"
diff --git a/openzipkin/go-client/conf/log.yml b/openzipkin/go-client/conf/log.yml
new file mode 100644
index 0000000..2b6e93a
--- /dev/null
+++ b/openzipkin/go-client/conf/log.yml
@@ -0,0 +1,27 @@
+level: "debug"
+development: true
+disableCaller: false
+disableStacktrace: false
+sampling:
+encoding: "console"
+
+# encoder
+encoderConfig:
+ messageKey: "message"
+ levelKey: "level"
+ timeKey: "time"
+ nameKey: "logger"
+ callerKey: "caller"
+ stacktraceKey: "stacktrace"
+ lineEnding: ""
+ levelEncoder: "capital"
+ timeEncoder: "iso8601"
+ durationEncoder: "seconds"
+ callerEncoder: "short"
+ nameEncoder: ""
+
+outputPaths:
+ - "stderr"
+errorOutputPaths:
+ - "stderr"
+initialFields:
diff --git a/openzipkin/go-client/pkg/user.go b/openzipkin/go-client/pkg/user.go
new file mode 100644
index 0000000..47261a8
--- /dev/null
+++ b/openzipkin/go-client/pkg/user.go
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package pkg
+
+import (
+ "context"
+ "time"
+)
+
+type User struct {
+ ID string
+ Name string
+ Age int32
+ Time time.Time
+}
+
+type UserProviderA struct {
+ GetUser func(ctx context.Context, req []interface{}, rsp *User) error
+}
+
+func (u *UserProviderA) Reference() string {
+ return "UserProviderA"
+}
+
+type UserProviderB struct {
+ GetUser func(ctx context.Context, req []interface{}, rsp *User) error
+}
+
+func (u *UserProviderB) Reference() string {
+ return "UserProviderB"
+}
+
+func (User) JavaClassName() string {
+ return "org.apache.dubbo.User"
+}
diff --git a/openzipkin/go-server-a/cmd/server.go b/openzipkin/go-server-a/cmd/server.go
new file mode 100644
index 0000000..fc06874
--- /dev/null
+++ b/openzipkin/go-server-a/cmd/server.go
@@ -0,0 +1,109 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package main
+
+import (
+ "fmt"
+ "os"
+ "os/signal"
+ "syscall"
+ "time"
+)
+
+import (
+ hessian "github.com/apache/dubbo-go-hessian2"
+ _ "github.com/apache/dubbo-go/cluster/cluster_impl"
+ _ "github.com/apache/dubbo-go/cluster/loadbalance"
+ "github.com/apache/dubbo-go/common/logger"
+ _ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
+ "github.com/apache/dubbo-go/config"
+ _ "github.com/apache/dubbo-go/filter/filter_impl"
+ _ "github.com/apache/dubbo-go/protocol/dubbo"
+ _ "github.com/apache/dubbo-go/registry/protocol"
+ _ "github.com/apache/dubbo-go/registry/zookeeper"
+ gxlog "github.com/dubbogo/gost/log"
+
+ // tracing
+ "github.com/opentracing/opentracing-go"
+ zipkinot "github.com/openzipkin-contrib/zipkin-go-opentracing"
+ "github.com/openzipkin/zipkin-go"
+ zipkinhttp "github.com/openzipkin/zipkin-go/reporter/http"
+)
+
+import (
+ "github.com/apache/dubbo-go-samples/openzipkin/go-server-a/pkg"
+)
+
+var (
+ survivalTimeout = int(3e9)
+)
+
+// need to setup environment variable "CONF_PROVIDER_FILE_PATH" to "conf/server.yml" before run
+func main() {
+
+ hessian.RegisterPOJO(&pkg.User{})
+ config.Load()
+ registerZipkin()
+
+ initSignal()
+}
+
+func initSignal() {
+ signals := make(chan os.Signal, 1)
+ // It is not possible to block SIGKILL or syscall.SIGSTOP
+ signal.Notify(signals, os.Interrupt, os.Kill, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT)
+ for {
+ sig := <-signals
+ logger.Infof("get signal %s", sig.String())
+ switch sig {
+ case syscall.SIGHUP:
+ // reload()
+ default:
+ time.AfterFunc(time.Duration(survivalTimeout), func() {
+ logger.Warnf("app exit now by force...")
+ os.Exit(1)
+ })
+
+ // The program exits normally or timeout forcibly exits.
+ fmt.Println("provider app exit now...")
+ return
+ }
+ }
+}
+func registerZipkin() {
+ // set up a span reporter
+ reporter := zipkinhttp.NewReporter("http://localhost:9411/api/v2/spans")
+
+ // create our local service endpoint
+ endpoint, err := zipkin.NewEndpoint("go-server-a", "localhost:80")
+ if err != nil {
+ gxlog.CError("unable to create local endpoint: %+v\n", err)
+ }
+
+ // initialize our tracer
+ nativeTracer, err := zipkin.NewTracer(reporter, zipkin.WithLocalEndpoint(endpoint))
+ if err != nil {
+ gxlog.CError("unable to create tracer: %+v\n", err)
+ }
+
+ // use zipkin-go-opentracing to wrap our tracer
+ tracer := zipkinot.Wrap(nativeTracer)
+
+ // optionally set as Global OpenTracing tracer instance
+ opentracing.SetGlobalTracer(tracer)
+}
diff --git a/openzipkin/go-server-a/conf/client.yml b/openzipkin/go-server-a/conf/client.yml
new file mode 100644
index 0000000..78c96f6
--- /dev/null
+++ b/openzipkin/go-server-a/conf/client.yml
@@ -0,0 +1,59 @@
+# dubbo client yaml configure file
+
+check: true
+# client
+request_timeout: "3s"
+# connect timeout
+connect_timeout: "3s"
+
+# application config
+application:
+ organization: "dubbo.io"
+ name: "UserInfoTest"
+ module: "dubbo-go user-info client"
+ version: "0.0.1"
+ environment: "dev"
+
+# registry config
+registries:
+ "demoZk":
+ protocol: "zookeeper"
+ timeout: "3s"
+ address: "127.0.0.1:2181"
+ username: ""
+ password: ""
+
+# reference config
+references:
+ "UserProviderB":
+ registry: "demoZk"
+ protocol: "dubbo"
+ interface: "org.apache.dubbo.UserProviderB"
+ cluster: "failover"
+ methods:
+ - name: "GetUser"
+ retries: 3
+
+# protocol config
+protocol_conf:
+ dubbo:
+ reconnect_interval: 0
+ connection_number: 1
+ heartbeat_period: "5s"
+ session_timeout: "180s"
+ pool_size: 64
+ pool_ttl: 600
+ getty_session_param:
+ compress_encoding: false
+ tcp_no_delay: true
+ tcp_keep_alive: true
+ keep_alive_period: "120s"
+ tcp_r_buf_size: 262144
+ tcp_w_buf_size: 65536
+ pkg_rq_size: 1024
+ pkg_wq_size: 512
+ tcp_read_timeout: "1s"
+ tcp_write_timeout: "5s"
+ wait_timeout: "1s"
+ max_msg_len: 1024000
+ session_name: "client"
diff --git a/openzipkin/go-server-a/conf/log.yml b/openzipkin/go-server-a/conf/log.yml
new file mode 100644
index 0000000..8c3f700
--- /dev/null
+++ b/openzipkin/go-server-a/conf/log.yml
@@ -0,0 +1,27 @@
+level: "info"
+development: true
+disableCaller: false
+disableStacktrace: false
+sampling:
+encoding: "console"
+
+# encoder
+encoderConfig:
+ messageKey: "message"
+ levelKey: "level"
+ timeKey: "time"
+ nameKey: "logger"
+ callerKey: "caller"
+ stacktraceKey: "stacktrace"
+ lineEnding: ""
+ levelEncoder: "capital"
+ timeEncoder: "iso8601"
+ durationEncoder: "seconds"
+ callerEncoder: "short"
+ nameEncoder: ""
+
+outputPaths:
+ - "stderr"
+errorOutputPaths:
+ - "stderr"
+initialFields:
diff --git a/openzipkin/go-server-a/conf/server.yml b/openzipkin/go-server-a/conf/server.yml
new file mode 100644
index 0000000..e5c965c
--- /dev/null
+++ b/openzipkin/go-server-a/conf/server.yml
@@ -0,0 +1,67 @@
+# dubbo server yaml configure file
+
+# application config
+application:
+ organization: "dubbo.io"
+ name: "UserInfoServer"
+ module: "dubbo-go user-info server"
+ version: "0.0.1"
+ environment: "dev"
+
+# registry config
+registries:
+ "demoZk":
+ protocol: "zookeeper"
+ timeout: "3s"
+ address: "127.0.0.1:2181"
+
+# service config
+services:
+ "UserProviderA":
+ registry: "demoZk"
+ protocol: "dubbo"
+ interface: "org.apache.dubbo.UserProviderA"
+ loadbalance: "random"
+ warmup: "100"
+ cluster: "failover"
+ methods:
+ - name: "GetUser"
+ retries: 1
+ loadbalance: "random"
+
+# reference config
+references:
+ "UserProviderB":
+ registry: "demoZk"
+ protocol: "dubbo"
+ interface: "org.apache.dubbo.UserProviderB"
+ cluster: "failover"
+ methods:
+ - name: "GetUser"
+ retries: 3
+
+filter: "tracing"
+
+# protocol config
+protocols:
+ "dubbo":
+ name: "dubbo"
+
+protocol_conf:
+ dubbo:
+ session_number: 700
+ session_timeout: "180s"
+ getty_session_param:
+ compress_encoding: false
+ tcp_no_delay: true
+ tcp_keep_alive: true
+ keep_alive_period: "120s"
+ tcp_r_buf_size: 262144
+ tcp_w_buf_size: 65536
+ pkg_rq_size: 1024
+ pkg_wq_size: 512
+ tcp_read_timeout: "1s"
+ tcp_write_timeout: "5s"
+ wait_timeout: "1s"
+ max_msg_len: 1024000
+ session_name: "server"
diff --git a/openzipkin/go-server-a/docker/docker-compose.yml b/openzipkin/go-server-a/docker/docker-compose.yml
new file mode 100644
index 0000000..8724179
--- /dev/null
+++ b/openzipkin/go-server-a/docker/docker-compose.yml
@@ -0,0 +1,9 @@
+version: '3'
+
+services:
+ zookeeper:
+ image: zookeeper
+ ports:
+ - 2181:2181
+ restart: on-failure
+
diff --git a/openzipkin/go-server-a/pkg/user.go b/openzipkin/go-server-a/pkg/user.go
new file mode 100644
index 0000000..d0ca328
--- /dev/null
+++ b/openzipkin/go-server-a/pkg/user.go
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package pkg
+
+import (
+ "context"
+ "math/rand"
+ "time"
+)
+
+import (
+ hessian "github.com/apache/dubbo-go-hessian2"
+ "github.com/apache/dubbo-go/config"
+ "github.com/dubbogo/gost/log"
+)
+
+var userProviderB = new(UserProviderB)
+
+func init() {
+ config.SetProviderService(new(UserProvider))
+ config.SetConsumerService(userProviderB)
+ hessian.RegisterPOJO(&User{})
+}
+
+type User struct {
+ ID string
+ Name string
+ Age int32
+ Time time.Time
+}
+
+type UserProvider struct {
+}
+
+func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
+ gxlog.CInfo("req:%#v", req)
+ time.Sleep(time.Duration(rand.Intn(977)+300) * time.Millisecond)
+ rsp := User{"A001", "Alex Stocks In Group A", 18, time.Now()}
+ gxlog.CInfo("rsp:%#v", rsp)
+
+ gxlog.CInfo("request provider B , req:%#v", req)
+ getUserB(ctx)
+
+ return &rsp, nil
+}
+
+func getUserB(ctx context.Context) {
+
+ time.Sleep(time.Duration(rand.Intn(977)+300) * time.Millisecond)
+ user := &User{}
+ err := userProviderB.GetUser(ctx, []interface{}{"A001"}, user)
+ if err != nil {
+ gxlog.CError("error: %v\n", err)
+ return
+ }
+ gxlog.CInfo("response result: %v\n", user)
+}
+
+func (u *UserProvider) Reference() string {
+ return "UserProviderA"
+}
+
+func (u User) JavaClassName() string {
+ return "org.apache.dubbo.User"
+}
+
+type UserProviderB struct {
+ GetUser func(ctx context.Context, req []interface{}, rsp *User) error
+}
+
+func (u *UserProviderB) Reference() string {
+ return "UserProviderB"
+}
diff --git a/openzipkin/go-server-a/tests/integration/main_test.go b/openzipkin/go-server-a/tests/integration/main_test.go
new file mode 100644
index 0000000..4a75f7a
--- /dev/null
+++ b/openzipkin/go-server-a/tests/integration/main_test.go
@@ -0,0 +1,71 @@
+// +build integration
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package integration
+
+import (
+ "context"
+ "os"
+ "testing"
+ "time"
+)
+
+import (
+ hessian "github.com/apache/dubbo-go-hessian2"
+ "github.com/apache/dubbo-go/config"
+
+ _ "github.com/apache/dubbo-go/cluster/cluster_impl"
+ _ "github.com/apache/dubbo-go/cluster/loadbalance"
+ _ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
+ _ "github.com/apache/dubbo-go/filter/filter_impl"
+ _ "github.com/apache/dubbo-go/metadata/service/inmemory"
+ _ "github.com/apache/dubbo-go/protocol/dubbo"
+ _ "github.com/apache/dubbo-go/registry/protocol"
+ _ "github.com/apache/dubbo-go/registry/zookeeper"
+)
+
+var userProvider = new(UserProvider)
+
+func TestMain(m *testing.M) {
+ config.SetConsumerService(userProvider)
+ hessian.RegisterPOJO(&User{})
+ config.Load()
+ time.Sleep(3 * time.Second)
+
+ os.Exit(m.Run())
+}
+
+type User struct {
+ ID string
+ Name string
+ Age int32
+ Time time.Time
+}
+
+type UserProvider struct {
+ GetUser func(ctx context.Context, req []interface{}, rsp *User) error
+}
+
+func (u *UserProvider) Reference() string {
+ return "UserProvider"
+}
+
+func (User) JavaClassName() string {
+ return "org.apache.dubbo.User"
+}
diff --git a/openzipkin/go-server-a/tests/integration/userprovider_test.go b/openzipkin/go-server-a/tests/integration/userprovider_test.go
new file mode 100644
index 0000000..3c4661a
--- /dev/null
+++ b/openzipkin/go-server-a/tests/integration/userprovider_test.go
@@ -0,0 +1,38 @@
+// +build integration
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package integration
+
+import (
+ "context"
+ "testing"
+)
+import (
+ "github.com/stretchr/testify/assert"
+)
+
+func TestGetUser(t *testing.T) {
+ user := &User{}
+ err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
+ assert.Nil(t, err)
+ assert.Equal(t, "A001", user.ID)
+ assert.Equal(t, "Alex Stocks In Group A", user.Name)
+ assert.Equal(t, int32(18), user.Age)
+ assert.NotNil(t, user.Time)
+}
diff --git a/openzipkin/go-server-b/cmd/server.go b/openzipkin/go-server-b/cmd/server.go
new file mode 100644
index 0000000..17dfc6c
--- /dev/null
+++ b/openzipkin/go-server-b/cmd/server.go
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package main
+
+import (
+ "fmt"
+ "os"
+ "os/signal"
+ "syscall"
+ "time"
+)
+
+import (
+ hessian "github.com/apache/dubbo-go-hessian2"
+ _ "github.com/apache/dubbo-go/cluster/cluster_impl"
+ _ "github.com/apache/dubbo-go/cluster/loadbalance"
+ "github.com/apache/dubbo-go/common/logger"
+ _ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
+ "github.com/apache/dubbo-go/config"
+ _ "github.com/apache/dubbo-go/filter/filter_impl"
+ _ "github.com/apache/dubbo-go/protocol/dubbo"
+ _ "github.com/apache/dubbo-go/registry/protocol"
+ _ "github.com/apache/dubbo-go/registry/zookeeper"
+ gxlog "github.com/dubbogo/gost/log"
+ // trace: zipkin
+ "github.com/opentracing/opentracing-go"
+ zipkinot "github.com/openzipkin-contrib/zipkin-go-opentracing"
+ "github.com/openzipkin/zipkin-go"
+ zipkinhttp "github.com/openzipkin/zipkin-go/reporter/http"
+)
+
+import (
+ "github.com/apache/dubbo-go-samples/openzipkin/go-server-b/pkg"
+)
+
+var (
+ survivalTimeout = int(3e9)
+)
+
+// need to setup environment variable "CONF_PROVIDER_FILE_PATH" to "conf/server.yml" before run
+func main() {
+ hessian.RegisterPOJO(&pkg.User{})
+ config.Load()
+ registerZipkin()
+
+ initSignal()
+}
+
+func initSignal() {
+ signals := make(chan os.Signal, 1)
+ // It is not possible to block SIGKILL or syscall.SIGSTOP
+ signal.Notify(signals, os.Interrupt, os.Kill, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT)
+ for {
+ sig := <-signals
+ logger.Infof("get signal %s", sig.String())
+ switch sig {
+ case syscall.SIGHUP:
+ // reload()
+ default:
+ time.AfterFunc(time.Duration(survivalTimeout), func() {
+ logger.Warnf("app exit now by force...")
+ os.Exit(1)
+ })
+
+ // The program exits normally or timeout forcibly exits.
+ fmt.Println("provider app exit now...")
+ return
+ }
+ }
+}
+func registerZipkin() {
+ // set up a span reporter
+ reporter := zipkinhttp.NewReporter("http://localhost:9411/api/v2/spans")
+
+ // create our local service endpoint
+ endpoint, err := zipkin.NewEndpoint("go-server-b", "localhost:80")
+ if err != nil {
+ gxlog.CError("unable to create local endpoint: %+v\n", err)
+ }
+
+ // initialize our tracer
+ nativeTracer, err := zipkin.NewTracer(reporter, zipkin.WithLocalEndpoint(endpoint))
+ if err != nil {
+ gxlog.CError("unable to create tracer: %+v\n", err)
+ }
+
+ // use zipkin-go-opentracing to wrap our tracer
+ tracer := zipkinot.Wrap(nativeTracer)
+
+ // optionally set as Global OpenTracing tracer instance
+ opentracing.SetGlobalTracer(tracer)
+}
diff --git a/openzipkin/go-server-b/conf/client.yml b/openzipkin/go-server-b/conf/client.yml
new file mode 100644
index 0000000..735fb03
--- /dev/null
+++ b/openzipkin/go-server-b/conf/client.yml
@@ -0,0 +1,60 @@
+# dubbo client yaml configure file
+
+check: true
+# client
+request_timeout: "3s"
+# connect timeout
+connect_timeout: "3s"
+
+# application config
+application:
+ organization: "dubbo.io"
+ name: "UserInfoTest"
+ module: "dubbo-go user-info client"
+ version: "0.0.1"
+ environment: "dev"
+
+# registry config
+registries:
+ "demoZk":
+ protocol: "zookeeper"
+ timeout: "3s"
+ address: "127.0.0.1:2181"
+ username: ""
+ password: ""
+
+# reference config
+references:
+ "UserProvider":
+ registry: "demoZk"
+ protocol: "dubbo"
+ interface: "org.apache.dubbo.UserProvider"
+ group: "GroupB"
+ cluster: "failover"
+ methods:
+ - name: "GetUser"
+ retries: 3
+
+# protocol config
+protocol_conf:
+ dubbo:
+ reconnect_interval: 0
+ connection_number: 1
+ heartbeat_period: "5s"
+ session_timeout: "180s"
+ pool_size: 64
+ pool_ttl: 600
+ getty_session_param:
+ compress_encoding: false
+ tcp_no_delay: true
+ tcp_keep_alive: true
+ keep_alive_period: "120s"
+ tcp_r_buf_size: 262144
+ tcp_w_buf_size: 65536
+ pkg_rq_size: 1024
+ pkg_wq_size: 512
+ tcp_read_timeout: "1s"
+ tcp_write_timeout: "5s"
+ wait_timeout: "1s"
+ max_msg_len: 1024000
+ session_name: "client"
diff --git a/openzipkin/go-server-b/conf/log.yml b/openzipkin/go-server-b/conf/log.yml
new file mode 100644
index 0000000..970d988
--- /dev/null
+++ b/openzipkin/go-server-b/conf/log.yml
@@ -0,0 +1,27 @@
+level: "error"
+development: true
+disableCaller: false
+disableStacktrace: false
+sampling:
+encoding: "console"
+
+# encoder
+encoderConfig:
+ messageKey: "message"
+ levelKey: "level"
+ timeKey: "time"
+ nameKey: "logger"
+ callerKey: "caller"
+ stacktraceKey: "stacktrace"
+ lineEnding: ""
+ levelEncoder: "capital"
+ timeEncoder: "iso8601"
+ durationEncoder: "seconds"
+ callerEncoder: "short"
+ nameEncoder: ""
+
+outputPaths:
+ - "stderr"
+errorOutputPaths:
+ - "stderr"
+initialFields:
diff --git a/openzipkin/go-server-b/conf/server.yml b/openzipkin/go-server-b/conf/server.yml
new file mode 100644
index 0000000..c96d38a
--- /dev/null
+++ b/openzipkin/go-server-b/conf/server.yml
@@ -0,0 +1,57 @@
+# dubbo server yaml configure file
+
+# application config
+application:
+ organization: "dubbo.io"
+ name: "UserInfoServer"
+ module: "dubbo-go user-info server"
+ version: "0.0.1"
+ environment: "dev"
+
+# registry config
+registries:
+ "demoZk":
+ protocol: "zookeeper"
+ timeout: "3s"
+ address: "127.0.0.1:2181"
+
+# service config
+services:
+ "UserProviderB":
+ registry: "demoZk"
+ protocol: "dubbo"
+ interface: "org.apache.dubbo.UserProviderB"
+ loadbalance: "random"
+ warmup: "100"
+ cluster: "failover"
+ methods:
+ - name: "GetUser"
+ retries: 1
+ loadbalance: "random"
+
+#filter: "zipkin"
+filter: "tracing"
+
+# protocol config
+protocols:
+ "dubbo":
+ name: "dubbo"
+
+protocol_conf:
+ dubbo:
+ session_number: 700
+ session_timeout: "180s"
+ getty_session_param:
+ compress_encoding: false
+ tcp_no_delay: true
+ tcp_keep_alive: true
+ keep_alive_period: "120s"
+ tcp_r_buf_size: 262144
+ tcp_w_buf_size: 65536
+ pkg_rq_size: 1024
+ pkg_wq_size: 512
+ tcp_read_timeout: "1s"
+ tcp_write_timeout: "5s"
+ wait_timeout: "1s"
+ max_msg_len: 1024000
+ session_name: "server"
diff --git a/openzipkin/go-server-b/docker/docker-compose.yml b/openzipkin/go-server-b/docker/docker-compose.yml
new file mode 100644
index 0000000..8724179
--- /dev/null
+++ b/openzipkin/go-server-b/docker/docker-compose.yml
@@ -0,0 +1,9 @@
+version: '3'
+
+services:
+ zookeeper:
+ image: zookeeper
+ ports:
+ - 2181:2181
+ restart: on-failure
+
diff --git a/openzipkin/go-server-b/pkg/user.go b/openzipkin/go-server-b/pkg/user.go
new file mode 100644
index 0000000..aee528a
--- /dev/null
+++ b/openzipkin/go-server-b/pkg/user.go
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package pkg
+
+import (
+ "context"
+ "math/rand"
+ "time"
+)
+
+import (
+ hessian "github.com/apache/dubbo-go-hessian2"
+ "github.com/apache/dubbo-go/config"
+ "github.com/dubbogo/gost/log"
+)
+
+func init() {
+ config.SetProviderService(new(UserProvider))
+ // ------for hessian2------
+ hessian.RegisterPOJO(&User{})
+}
+
+type User struct {
+ ID string
+ Name string
+ Age int32
+ Time time.Time
+}
+
+type UserProvider struct {
+}
+
+func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
+ gxlog.CInfo("req:%#v", req)
+ time.Sleep(time.Duration(rand.Intn(977)+300) * time.Millisecond)
+ rsp := User{"A001", "Alex Stocks In Provider B", 18, time.Now()}
+ gxlog.CInfo("rsp:%#v", rsp)
+ return &rsp, nil
+}
+
+func (u *UserProvider) Reference() string {
+ return "UserProviderB"
+}
+
+func (u User) JavaClassName() string {
+ return "org.apache.dubbo.User"
+}
diff --git a/openzipkin/go-server-b/tests/integration/main_test.go b/openzipkin/go-server-b/tests/integration/main_test.go
new file mode 100644
index 0000000..4a75f7a
--- /dev/null
+++ b/openzipkin/go-server-b/tests/integration/main_test.go
@@ -0,0 +1,71 @@
+// +build integration
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package integration
+
+import (
+ "context"
+ "os"
+ "testing"
+ "time"
+)
+
+import (
+ hessian "github.com/apache/dubbo-go-hessian2"
+ "github.com/apache/dubbo-go/config"
+
+ _ "github.com/apache/dubbo-go/cluster/cluster_impl"
+ _ "github.com/apache/dubbo-go/cluster/loadbalance"
+ _ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
+ _ "github.com/apache/dubbo-go/filter/filter_impl"
+ _ "github.com/apache/dubbo-go/metadata/service/inmemory"
+ _ "github.com/apache/dubbo-go/protocol/dubbo"
+ _ "github.com/apache/dubbo-go/registry/protocol"
+ _ "github.com/apache/dubbo-go/registry/zookeeper"
+)
+
+var userProvider = new(UserProvider)
+
+func TestMain(m *testing.M) {
+ config.SetConsumerService(userProvider)
+ hessian.RegisterPOJO(&User{})
+ config.Load()
+ time.Sleep(3 * time.Second)
+
+ os.Exit(m.Run())
+}
+
+type User struct {
+ ID string
+ Name string
+ Age int32
+ Time time.Time
+}
+
+type UserProvider struct {
+ GetUser func(ctx context.Context, req []interface{}, rsp *User) error
+}
+
+func (u *UserProvider) Reference() string {
+ return "UserProvider"
+}
+
+func (User) JavaClassName() string {
+ return "org.apache.dubbo.User"
+}
diff --git a/openzipkin/go-server-b/tests/integration/userprovider_test.go b/openzipkin/go-server-b/tests/integration/userprovider_test.go
new file mode 100644
index 0000000..3726251
--- /dev/null
+++ b/openzipkin/go-server-b/tests/integration/userprovider_test.go
@@ -0,0 +1,39 @@
+// +build integration
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package integration
+
+import (
+ "context"
+ "testing"
+)
+
+import (
+ "github.com/stretchr/testify/assert"
+)
+
+func TestGetUser(t *testing.T) {
+ user := &User{}
+ err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
+ assert.Nil(t, err)
+ assert.Equal(t, "A001", user.ID)
+ assert.Equal(t, "Alex Stocks In Group B", user.Name)
+ assert.Equal(t, int32(18), user.Age)
+ assert.NotNil(t, user.Time)
+}
diff --git a/openzipkin/prometheus/create-datasource-and-dashboard.sh b/openzipkin/prometheus/create-datasource-and-dashboard.sh
new file mode 100644
index 0000000..76b88cc
--- /dev/null
+++ b/openzipkin/prometheus/create-datasource-and-dashboard.sh
@@ -0,0 +1,33 @@
+#!/bin/sh
+#
+# Copyright 2015-2020 The OpenZipkin Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+# in compliance with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software distributed under the License
+# is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+# or implied. See the License for the specific language governing permissions and limitations under
+# the License.
+#
+
+set -xeuo pipefail
+
+if ! curl --retry 5 --retry-connrefused --retry-delay 0 -sf http://grafana:3000/api/datasources/name/prom; then
+ curl -sf -X POST -H "Content-Type: application/json" \
+ --data-binary '{"name":"prom","type":"prometheus","url":"http://prometheus:9090","access":"proxy","isDefault":true}' \
+ http://grafana:3000/api/datasources
+fi
+
+dashboard_id=1598
+last_revision=$(curl -sf https://grafana.com/api/dashboards/${dashboard_id}/revisions | grep '"revision":' | sed 's/ *"revision": \([0-9]*\),/\1/' | sort -n | tail -1)
+
+echo '{"dashboard": ' > data.json
+curl -s https://grafana.com/api/dashboards/${dashboard_id}/revisions/${last_revision}/download >> data.json
+echo ', "inputs": [{"name": "DS_PROMETHEUS", "pluginId": "prometheus", "type": "datasource", "value": "prom"}], "overwrite": false}' >> data.json
+curl --retry-connrefused --retry 5 --retry-delay 0 -sf \
+ -X POST -H "Content-Type: application/json" \
+ --data-binary @data.json \
+ http://grafana:3000/api/dashboards/import
diff --git a/openzipkin/prometheus/prometheus.yml b/openzipkin/prometheus/prometheus.yml
new file mode 100644
index 0000000..3c0c1bc
--- /dev/null
+++ b/openzipkin/prometheus/prometheus.yml
@@ -0,0 +1,13 @@
+global:
+ scrape_interval: 15s # Set the scrape interval to every 15 seconds. Default is every 1 minute.
+ evaluation_interval: 15s # Evaluate rules every 15 seconds. The default is every 1 minute.
+
+scrape_configs:
+ - job_name: 'prometheus'
+ static_configs:
+ - targets: ['localhost:9090']
+ - job_name: 'zipkin'
+ scrape_interval: 5s
+ metrics_path: '/prometheus'
+ static_configs:
+ - targets: ['zipkin:9411']
\ No newline at end of file