supported dubbo-go v3.0.2 (#49)

.github/workflows/ci.yaml

@@ -39,7 +39,7 @@ jobs:
           - { name: 'resty', plugin_dir: 'resty', go_version: '1.13' }
           - { name: 'go-restful', plugin_dir: 'go-restful', go_version: '1.13' }
           - { name: 'logrus', plugin_dir: 'logrus', go_version: '1.13' }
-          - { name: 'dubbo-go', plugin_dir: 'dubbo-go', go_version: '1.14' }
+          - { name: 'dubbo-go', plugin_dir: 'dubbo-go', go_version: '1.15' }
           - { name: 'grom', plugin_dir: 'grom', go_version: '1.16' }
           - { name: 'kafka-reporter', plugin_dir: 'kafkareporter',  go_version: '1.16' }
           - { name: 'kratos', plugin_dir: 'kratos', go_version: '1.16' }

Makefile

@@ -27,7 +27,7 @@ deps:
 
 LINTER := bin/golangci-lint
 $(LINTER):
-	curl -L https://install.goreleaser.com/github.com/golangci/golangci-lint.sh | sh -s v1.45.2
+	curl -L https://raw.githubusercontent.com/golangci/golangci-lint/master/install.sh | sh -s v1.45.2
 
 .PHONY: lint
 lint: $(LINTER)

dubbo-go/README.md

@@ -3,7 +3,7 @@
 ##### Installation
 
 ```
-go get -u github.com/SkyAMP/go2sky-plugins/dubbo-go
+go get -u github.com/SkyAPM/go2sky-plugins/dubbo-go
 ```
 
 ##### Usage
@@ -12,17 +12,11 @@ Server:
 
 ```go
 import (
-    _ "dubbo.apache.org/dubbo-go/v3/cluster/cluster_impl"
-	_ "dubbo.apache.org/dubbo-go/v3/cluster/loadbalance"
 	"dubbo.apache.org/dubbo-go/v3/common/logger"
-	_ "dubbo.apache.org/dubbo-go/v3/common/proxy/proxy_factory"
 	"dubbo.apache.org/dubbo-go/v3/config"
-	_ "dubbo.apache.org/dubbo-go/v3/filter/filter_impl"
-	_ "dubbo.apache.org/dubbo-go/v3/protocol/dubbo"
-	_ "dubbo.apache.org/dubbo-go/v3/registry/protocol"
-	_ "dubbo.apache.org/dubbo-go/v3/registry/zookeeper"
 	"github.com/SkyAPM/go2sky"
 	"github.com/SkyAPM/go2sky/reporter"
+	_ "dubbo.apache.org/dubbo-go/v3/imports"
 	hessian "github.com/apache/dubbo-go-hessian2"
 
 	dubbo_go "github.com/SkyAPM/go2sky-plugins/dubbo-go"
@@ -58,14 +52,8 @@ Client:
 
 ```go
 import (
-	_ "dubbo.apache.org/dubbo-go/v3/cluster/cluster_impl"
-	_ "dubbo.apache.org/dubbo-go/v3/cluster/loadbalance"
-	_ "dubbo.apache.org/dubbo-go/v3/common/proxy/proxy_factory"
 	"dubbo.apache.org/dubbo-go/v3/config"
-	_ "dubbo.apache.org/dubbo-go/v3/filter/filter_impl"
-	_ "dubbo.apache.org/dubbo-go/v3/protocol/dubbo"
-	_ "dubbo.apache.org/dubbo-go/v3/registry/protocol"
-	_ "dubbo.apache.org/dubbo-go/v3/registry/zookeeper"
+	_ "dubbo.apache.org/dubbo-go/v3/imports"
 	"github.com/SkyAPM/go2sky"
 	"github.com/SkyAPM/go2sky/reporter"
 	hessian "github.com/apache/dubbo-go-hessian2"

dubbo-go/dubbo-go.go

@@ -125,15 +125,18 @@ func (cf tracingFilter) Invoke(ctx context.Context, invoker protocol.Invoker, in
 
 	if cf.side == clientSide {
 		span, _ = cf.tracer.CreateExitSpan(ctx, operationName, invoker.GetURL().Location, func(key, value string) error {
-			invocation.SetAttachments(key, value)
+			invocation.SetAttachment(key, value)
 			return nil
 		})
 
 		span.SetComponent(componentID)
 	} else {
 		// componentIDGo2SkyServer
 		span, ctx, _ = cf.tracer.CreateEntrySpan(ctx, operationName, func(key string) (string, error) {
-			return invocation.AttachmentsByKey(key, ""), nil
+			if attachment, ok := invocation.GetAttachment(key); ok {
+				return attachment, nil
+			}
+			return "", nil
 		})
 
 		span.SetComponent(componentID)

dubbo-go/go.mod

@@ -1,11 +1,11 @@
 module github.com/SkyAPM/go2sky-plugins/dubbo-go
 
-go 1.14
+go 1.15
 
 require (
-	dubbo.apache.org/dubbo-go/v3 v3.0.0-rc2
+	dubbo.apache.org/dubbo-go/v3 v3.0.2
 	github.com/SkyAPM/go2sky v1.4.1
-	github.com/apache/dubbo-go-hessian2 v1.9.3
-	github.com/dubbogo/gost v1.11.17
+	github.com/apache/dubbo-go-hessian2 v1.11.0
+	github.com/dubbogo/gost v1.11.25
 	skywalking.apache.org/repo/goapi v0.0.0-20220401015832-2c9eee9481eb
 )

dubbo-go/test/client/cmd/client.go

@@ -22,14 +22,8 @@ import (
 	"net/http"
 	"time"
 
-	_ "dubbo.apache.org/dubbo-go/v3/cluster/cluster_impl"
-	_ "dubbo.apache.org/dubbo-go/v3/cluster/loadbalance"
-	_ "dubbo.apache.org/dubbo-go/v3/common/proxy/proxy_factory"
 	"dubbo.apache.org/dubbo-go/v3/config"
-	_ "dubbo.apache.org/dubbo-go/v3/filter/filter_impl"
-	_ "dubbo.apache.org/dubbo-go/v3/protocol/dubbo"
-	_ "dubbo.apache.org/dubbo-go/v3/registry/protocol"
-	_ "dubbo.apache.org/dubbo-go/v3/registry/zookeeper"
+	_ "dubbo.apache.org/dubbo-go/v3/imports"
 	"github.com/SkyAPM/go2sky"
 	"github.com/SkyAPM/go2sky/reporter"
 	hessian "github.com/apache/dubbo-go-hessian2"
@@ -51,10 +45,13 @@ const (
 	serviceName = "dubbo-go-client"
 )
 
-// need to setup environment variable "CONF_CONSUMER_FILE_PATH" to "conf/client.yml" before run
+// need to setup environment variable "DUBBO_GO_CONFIG_PATH" to "conf/client.yml" before run
 func main() {
 	hessian.RegisterPOJO(&pkg.User{})
-	config.Load()
+	err := config.Load()
+	if err != nil {
+		log.Fatalf("load config error: %v \n", err)
+	}
 	time.Sleep(3 * time.Second)
 
 	report, err := reporter.NewGRPCReporter(oap)
@@ -78,8 +75,9 @@ func main() {
 	route := http.NewServeMux()
 
 	route.HandleFunc("/hello", func(writer http.ResponseWriter, req *http.Request) {
-		user := &pkg.User{}
-		err1 := userProvider.GetUser(req.Context(), []interface{}{"A001"}, user)
+		var user *pkg.User
+		var err1 error
+		user, err1 = userProvider.GetUser(req.Context(), []interface{}{"A001"})
 		if err1 != nil {
 			writer.WriteHeader(http.StatusInternalServerError)
 			_, _ = writer.Write([]byte(fmt.Sprintf("call service err %v \n", err1)))

dubbo-go/test/client/conf/client.yml

@@ -15,63 +15,59 @@
 #
 # 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: "zookeeper:2181"
-    username: ""
-    password: ""
+dubbo:
+  application:
+    organization: "dubbo.io"
+    name: "UserInfoClient"
+    module: "dubbo-go user-info client"
+    version: "0.0.1"
+    environment: "dev"
 
-# filter config
-filter: "go2sky-tracing-client"
+  # registry config
+  registries:
+    demoZk:
+      protocol: "zookeeper"
+      timeout: "3s"
+      address: "zookeeper:2181"
+      username: ""
+      password: ""
 
-# reference config
-references:
-  "UserProvider":
-    registry: "demoZk"
-    protocol : "dubbo"
-    interface : "org.apache.dubbo.UserProvider"
-    cluster: "failover"
-    methods :
-    - name: "GetUser"
-      retries: 3
+  # reference config
+  consumer:
+    check: true
+    references:
+      "UserProvider":
+        protocol: "dubbo"
+        interface: "org.apache.dubbo.UserProvider"
+        # filter config
+        filter: "go2sky-tracing-client"
+        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"
+  # protocol config
+  protocols:
+    "dubbo":
+      params:
+        "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
+            tcp_read_timeout: "1s"
+            tcp_write_timeout: "5s"
+            wait_timeout: "1s"
+            max_msg_len: 1024000
+            session_name: "client"

dubbo-go/test/client/pkg/user.go

@@ -31,7 +31,7 @@ type User struct {
 
 // UserProvider user provider service
 type UserProvider struct {
-	GetUser func(ctx context.Context, req []interface{}, rsp *User) error
+	GetUser func(ctx context.Context, req []interface{}) (*User, error)
 }
 
 // Reference rpc service id or reference id

dubbo-go/test/docker/Dockerfile.client

@@ -14,13 +14,13 @@
 # limitations under the License.
 #
 
-FROM golang:1.14
+FROM golang:1.15
 
 ADD ./dubbo-go /dubbo-go
 WORKDIR /dubbo-go
 
 ENV APP_LOG_CONF_FILE /dubbo-go/test/client/conf/log.yml
-ENV CONF_CONSUMER_FILE_PATH /dubbo-go/test/client/conf/client.yml
+ENV DUBBO_GO_CONFIG_PATH /dubbo-go/test/client/conf/client.yml
 
 EXPOSE 8080
 

dubbo-go/test/docker/Dockerfile.server

@@ -16,13 +16,13 @@
 
 
 
-FROM golang:1.14
+FROM golang:1.15
 
 ADD ./dubbo-go /dubbo-go
 WORKDIR /dubbo-go
 
 ENV APP_LOG_CONF_FILE /dubbo-go/test/server/conf/log.yml
-ENV CONF_PROVIDER_FILE_PATH /dubbo-go/test/server/conf/server.yml
+ENV DUBBO_GO_CONFIG_PATH /dubbo-go/test/server/conf/server.yml
 
 EXPOSE 20000
 

dubbo-go/test/expected.data.yml

@@ -16,14 +16,49 @@
 
 segmentItems:
   {{- contains .segmentItems }}
+  - serviceName: dubbo-go-server
+    segmentSize: {{ gt .segmentSize 0 }}
+    segments:
+    {{- contains .segments }}
+    - segmentId: {{ notEmpty .segmentId }}
+      spans:
+      {{- contains .spans}}
+      - operationName: org.apache.dubbo.UserProvider:0.0.1#GetUser
+        parentSpanId: -1
+        spanId: 0
+        spanLayer: RPCFramework
+        startTime: {{ gt .startTime 0 }}
+        endTime: {{ gt .endTime 0 }}
+        componentId: 3
+        isError: false
+        spanType: Entry
+        peer: ''
+        skipAnalysis: false
+        tags:
+          - {key: extra-tags, value: server}
+          - {key: release, value: dubbo-golang-3.0.0}
+          - {key: organization, value: dubbo.io}
+        refs:
+          {{- contains .refs }}
+          - parentEndpoint: /GET/hello
+            networkAddress: {{ notEmpty .networkAddress }}
+            refType: CrossProcess
+            parentSpanId: {{ ge .parentSpanId 0 }}
+            parentTraceSegmentId: {{ notEmpty .parentTraceSegmentId }}
+            parentServiceInstance: {{ notEmpty .parentServiceInstance }}
+            parentService: dubbo-go-client
+            traceId: {{ notEmpty .traceId }}
+          {{- end}}
+      {{- end}}
+    {{- end}}
   - serviceName: dubbo-go-client
     segmentSize: {{ gt .segmentSize 0 }}
     segments:
     {{- contains .segments }}
     - segmentId: {{ notEmpty .segmentId }}
       spans:
       {{- contains .spans }}
-      - operationName: org.apache.dubbo.UserProvider#GetUser
+      - operationName: org.apache.dubbo.UserProvider:0.0.1#GetUser
         parentSpanId: 0
         spanId: 1
         spanLayer: RPCFramework
@@ -60,40 +95,5 @@ segmentItems:
         {{- end }}
       {{- end}}
     {{- end}}
-  - serviceName: dubbo-go-server
-    segmentSize: {{ gt .segmentSize 0 }}
-    segments:
-    {{- contains .segments }}
-    - segmentId: {{ notEmpty .segmentId }}
-      spans:
-      {{- contains .spans}}
-      - operationName: org.apache.dubbo.UserProvider#GetUser
-        parentSpanId: -1
-        spanId: 0
-        spanLayer: RPCFramework
-        startTime: {{ gt .startTime 0 }}
-        endTime: {{ gt .endTime 0 }}
-        componentId: 3
-        isError: false
-        spanType: Entry
-        peer: ''
-        skipAnalysis: false
-        tags:
-          - {key: extra-tags, value: server}
-          - {key: release, value: dubbo-golang-3.0.0}
-          - {key: organization, value: dubbo.io}
-        refs:
-          {{- contains .refs }}
-          - parentEndpoint: /GET/hello
-            networkAddress: {{ notEmpty .networkAddress }}
-            refType: CrossProcess
-            parentSpanId: {{ ge .parentSpanId 0 }}
-            parentTraceSegmentId: {{ notEmpty .parentTraceSegmentId }}
-            parentServiceInstance: {{ notEmpty .parentServiceInstance }}
-            parentService: dubbo-go-client
-            traceId: {{ notEmpty .traceId }}
-          {{- end}}
-      {{- end}}
-    {{- end}}
   {{- end}}
 meterItems: []