You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by xi...@apache.org on 2019/08/09 11:10:51 UTC

[dubbo-go] 01/01: Mod:merge from develop

This is an automated email from the ASF dual-hosted git repository.

xinminghe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git

commit bac7c65d468a05954386919743d87a87f0409194
Merge: f169566 63e0369
Author: vito.he <hx...@163.com>
AuthorDate: Fri Aug 9 19:08:26 2019 +0800

    Mod:merge from develop

 .gitignore                                         |   1 +
 README.md                                          |  11 +
 README_CN.md                                       |  13 +
 cluster/cluster_impl/failover_cluster_test.go      |   3 +-
 cluster/loadbalance/least_active_test.go           |   3 +-
 cluster/loadbalance/random_test.go                 |   6 +-
 common/constant/default.go                         |   2 +
 common/constant/key.go                             |   2 +
 common/logger/logger.go                            |   9 +-
 common/proxy/proxy.go                              |   4 +-
 common/proxy/proxy_test.go                         |  10 +-
 common/rpc_service.go                              |  15 +-
 common/rpc_service_test.go                         |  17 +-
 common/url.go                                      |   5 +
 config/base_config.go                              |  40 +--
 config/base_config_test.go                         |  23 +-
 config/config_loader.go                            |  36 ++-
 config/config_loader_test.go                       |  19 +-
 config/consumer_config.go                          |   3 +-
 .../app/version.go => config/generic_service.go    |  16 +-
 config/mock_rpcservice.go                          |   6 +-
 config/provider_config.go                          |   2 +-
 config/reference_config.go                         |  58 ++--
 config/reference_config_test.go                    |   7 +-
 config/registry_config.go                          |  27 +-
 .../registry_config_test.go                        |  51 ++--
 config/service.go                                  |   4 +-
 config/service_config.go                           |  41 +--
 config/service_config_test.go                      |   2 +-
 config/testdata/consumer_config.yml                |  15 +-
 .../testdata/consumer_config_with_configcenter.yml |   4 +-
 config/testdata/provider_config.yml                |  10 +-
 .../with-configcenter-go-client/app/client.go      |   0
 .../dubbo/with-configcenter-go-client/app/user.go  |   8 +-
 .../with-configcenter-go-client}/app/version.go    |   0
 .../assembly/bin/load.sh                           |   0
 .../assembly/common/app.properties                 |   0
 .../assembly/common/build.sh                       |   0
 .../assembly/linux/dev.sh                          |   0
 .../assembly/linux/release.sh                      |   0
 .../assembly/linux/test.sh                         |   0
 .../assembly/mac/dev.sh                            |   0
 .../assembly/mac/release.sh                        |   0
 .../assembly/mac/test.sh                           |   0
 .../assembly/windows/dev.sh                        |   0
 .../assembly/windows/release.sh                    |   0
 .../assembly/windows/test.sh                       |   0
 .../profiles/dev/client.yml                        |   2 -
 .../profiles/dev/log.yml                           |   0
 .../profiles/release/client.yml                    |   2 -
 .../profiles/release/log.yml                       |   0
 .../profiles/test/client.yml                       |   2 -
 .../profiles/test/log.yml                          |   0
 .../with-configcenter-go-server/app/server.go      |   0
 .../dubbo/with-configcenter-go-server/app/user.go  |  12 +-
 .../with-configcenter-go-server}/app/version.go    |   0
 .../assembly/bin/load.sh                           |   0
 .../assembly/common/app.properties                 |   0
 .../assembly/common/build.sh                       |   0
 .../assembly/linux/dev.sh                          |   0
 .../assembly/linux/release.sh                      |   0
 .../assembly/linux/test.sh                         |   0
 .../assembly/mac/dev.sh                            |   0
 .../assembly/mac/release.sh                        |   0
 .../assembly/mac/test.sh                           |   0
 .../assembly/windows/dev.sh                        |   0
 .../assembly/windows/release.sh                    |   0
 .../assembly/windows/test.sh                       |   0
 .../profiles/dev/log.yml                           |   0
 .../profiles/dev}/server.yml                       |   2 -
 .../profiles/release/log.yml                       |   0
 .../profiles/release}/server.yml                   |   2 -
 .../profiles/test/log.yml                          |   0
 .../profiles/test}/server.yml                      |   2 -
 .../with-configcenter-go-client/app/client.go      |   0
 .../with-configcenter-go-client}/app/user.go       |   8 +-
 .../with-configcenter-go-client}/app/version.go    |   0
 .../assembly/bin/load.sh                           |   0
 .../assembly/common/app.properties                 |   0
 .../assembly/common/build.sh                       |   0
 .../assembly/linux/dev.sh                          |   0
 .../assembly/linux/release.sh                      |   0
 .../assembly/linux/test.sh                         |   0
 .../assembly/mac/dev.sh                            |   0
 .../assembly/mac/release.sh                        |   0
 .../assembly/mac/test.sh                           |   0
 .../assembly/windows/dev.sh                        |   0
 .../assembly/windows/release.sh                    |   0
 .../assembly/windows/test.sh                       |   0
 .../profiles/dev}/client.yml                       |   0
 .../profiles/dev/log.yml                           |   0
 .../profiles/release/client.yml                    |   0
 .../profiles/release/log.yml                       |   0
 .../profiles/test}/client.yml                      |   0
 .../profiles/test/log.yml                          |   0
 .../with-configcenter-go-server/app/server.go      |   0
 .../with-configcenter-go-server/app/user.go        |   8 +-
 .../with-configcenter-go-server}/app/version.go    |   0
 .../assembly/bin/load.sh                           |   0
 .../assembly/common/app.properties                 |   0
 .../assembly/common/build.sh                       |   0
 .../assembly/linux/dev.sh                          |   0
 .../assembly/linux/release.sh                      |   0
 .../assembly/linux/test.sh                         |   0
 .../assembly/mac/dev.sh                            |   0
 .../assembly/mac/release.sh                        |   0
 .../assembly/mac/test.sh                           |   0
 .../assembly/windows/dev.sh                        |   0
 .../assembly/windows/release.sh                    |   0
 .../assembly/windows/test.sh                       |   0
 .../profiles/dev/log.yml                           |   0
 .../profiles/dev/server.yml                        |   0
 .../profiles/release/log.yml                       |   0
 .../profiles/release}/server.yml                   |   0
 .../profiles/test/log.yml                          |   0
 .../profiles/test}/server.yml                      |   0
 examples/dubbo/go-client/app/client.go             | 151 ----------
 examples/dubbo/go-server/app/user.go               | 214 --------------
 .../src/main/java/com/ikurento/user/Consumer.java  | 101 -------
 examples/general/dubbo/go-client/app/client.go     | 311 +++++++++++++++++++++
 examples/{ => general}/dubbo/go-client/app/user.go |  42 ++-
 .../dubbo/go-client}/app/version.go                |   0
 .../dubbo/go-client}/assembly/bin/load.sh          |   0
 .../go-client}/assembly/common/app.properties      |   0
 .../dubbo/go-client/assembly/common/build.sh       |   0
 .../dubbo/go-client}/assembly/linux/dev.sh         |   0
 .../dubbo/go-client}/assembly/linux/release.sh     |   0
 .../dubbo/go-client}/assembly/linux/test.sh        |   0
 .../dubbo/go-client}/assembly/mac/dev.sh           |   0
 .../dubbo/go-client}/assembly/mac/release.sh       |   0
 .../dubbo/go-client}/assembly/mac/test.sh          |   0
 .../dubbo/go-client}/assembly/windows/dev.sh       |   0
 .../dubbo/go-client}/assembly/windows/release.sh   |   0
 .../dubbo/go-client}/assembly/windows/test.sh      |   0
 .../dubbo/go-client/profiles/dev/client.yml        |  26 +-
 .../dubbo/go-client}/profiles/dev/log.yml          |   0
 .../dubbo/go-client/profiles/release}/client.yml   |  38 ++-
 .../dubbo/go-client}/profiles/release/log.yml      |   0
 .../dubbo/go-client/profiles/test/client.yml       |  27 +-
 .../dubbo/go-client}/profiles/test/log.yml         |   0
 examples/{ => general}/dubbo/go-server/app/app     | Bin
 .../{ => general}/dubbo/go-server/app/server.go    |   2 +-
 .../dubbo/go-server}/app/user.go                   |  70 +++--
 .../general/dubbo/go-server/app/user_provider.go   | 102 +++++++
 .../general/dubbo/go-server/app/user_provider1.go  |  88 ++++++
 .../general/dubbo/go-server/app/user_provider2.go  |  97 +++++++
 .../dubbo/go-server}/app/version.go                |   0
 .../dubbo/go-server}/assembly/bin/load.sh          |   0
 .../go-server}/assembly/common/app.properties      |   0
 .../dubbo/go-server}/assembly/common/build.sh      |   0
 .../dubbo/go-server}/assembly/linux/dev.sh         |   0
 .../dubbo/go-server}/assembly/linux/release.sh     |   0
 .../dubbo/go-server}/assembly/linux/test.sh        |   0
 .../dubbo/go-server}/assembly/mac/dev.sh           |   0
 .../dubbo/go-server}/assembly/mac/release.sh       |   0
 .../dubbo/go-server}/assembly/mac/test.sh          |   0
 .../dubbo/go-server}/assembly/windows/dev.sh       |   0
 .../dubbo/go-server}/assembly/windows/release.sh   |   0
 .../dubbo/go-server}/assembly/windows/test.sh      |   0
 .../dubbo/go-server}/profiles/dev/log.yml          |   0
 .../dubbo/go-server/profiles/dev/server.yml        |  40 ++-
 .../dubbo/go-server}/profiles/release/log.yml      |   0
 .../dubbo/go-server/profiles/release}/server.yml   |  31 +-
 .../dubbo/go-server}/profiles/test/log.yml         |   0
 .../dubbo/go-server/profiles/test/server.yml       |  39 ++-
 .../dubbo}/java-client/build.sh                    |   0
 examples/{ => general}/dubbo/java-client/pom.xml   |   0
 .../java-client/src/main/assembly/assembly.xml     |   0
 .../src/main/assembly/conf/dubbo.properties        |   0
 .../src/main/assembly/conf}/log4j.properties       |   0
 .../src/main/java/com/ikurento/user/Consumer.java  | 208 ++++++++++++++
 .../src/main/java/com/ikurento/user/Gender.java    |   0
 .../src/main/java/com/ikurento/user/User.java      |   0
 .../main/java/com/ikurento/user/UserProvider.java  |   0
 .../resources/META-INF/spring/dubbo.consumer.xml   |   5 +-
 .../src/main/resources/META-INF/spring/service.xml |   2 +
 .../src/main/resources}/log4j.properties           |   0
 .../dubbo}/java-server/build.sh                    |   0
 .../{jsonrpc => general/dubbo}/java-server/pom.xml |   0
 .../dubbo}/java-server/script/debug.sh             |   0
 .../java-server/src/main/assembly/assembly.xml     |   0
 .../src/main/assembly/conf/dubbo.properties        |   0
 .../src/main/assembly/conf}/log4j.properties       |   0
 .../src/main/java/com/ikurento/user/Gender.java    |   0
 .../src/main/java/com/ikurento/user/Provider.java  |   0
 .../src/main/java/com/ikurento/user/Response.java  |   0
 .../src/main/java/com/ikurento/user/User.java      |   0
 .../main/java/com/ikurento/user/UserProvider.java  |   0
 .../com/ikurento/user/UserProviderAnotherImpl.java |   0
 .../java/com/ikurento/user/UserProviderImpl.java   |   0
 .../resources/META-INF/spring/dubbo.provider.xml   |   0
 .../src/main/resources}/log4j.properties           |   0
 .../{ => general}/jsonrpc/go-client/app/client.go  | 170 +++++++++--
 .../jsonrpc/go-client}/app/user.go                 |  40 ++-
 .../jsonrpc/go-client}/app/version.go              |   0
 .../jsonrpc}/go-client/assembly/bin/load.sh        |   0
 .../go-client/assembly/common/app.properties       |   0
 .../jsonrpc/go-client/assembly/common/build.sh     |   0
 .../jsonrpc}/go-client/assembly/linux/dev.sh       |   0
 .../jsonrpc}/go-client/assembly/linux/release.sh   |   0
 .../jsonrpc}/go-client/assembly/linux/test.sh      |   0
 .../jsonrpc}/go-client/assembly/mac/dev.sh         |   0
 .../jsonrpc}/go-client/assembly/mac/release.sh     |   0
 .../jsonrpc}/go-client/assembly/mac/test.sh        |   0
 .../jsonrpc}/go-client/assembly/windows/dev.sh     |   0
 .../jsonrpc}/go-client/assembly/windows/release.sh |   0
 .../jsonrpc}/go-client/assembly/windows/test.sh    |   0
 .../jsonrpc/go-client/profiles/dev}/client.yml     |  54 ++--
 .../jsonrpc/go-client}/profiles/dev/log.yml        |   0
 .../jsonrpc/go-client/profiles/release/client.yml  |  45 ++-
 .../jsonrpc/go-client}/profiles/release/log.yml    |   0
 .../jsonrpc}/go-client/profiles/test/client.yml    |  52 ++--
 .../jsonrpc/go-client}/profiles/test/log.yml       |   0
 .../{ => general}/jsonrpc/go-server/app/server.go  |   2 +-
 examples/general/jsonrpc/go-server/app/user.go     |  78 ++++++
 .../general/jsonrpc/go-server/app/user_provider.go |  98 +++++++
 .../jsonrpc/go-server/app/user_provider1.go        |  83 ++++++
 .../jsonrpc/go-server/app/user_provider2.go        |  93 ++++++
 .../jsonrpc/go-server}/app/version.go              |   0
 .../jsonrpc}/go-server/assembly/bin/load.sh        |   0
 .../go-server/assembly/common/app.properties       |   0
 .../jsonrpc}/go-server/assembly/common/build.sh    |   0
 .../jsonrpc}/go-server/assembly/linux/dev.sh       |   0
 .../jsonrpc}/go-server/assembly/linux/release.sh   |   0
 .../jsonrpc}/go-server/assembly/linux/test.sh      |   0
 .../jsonrpc}/go-server/assembly/mac/dev.sh         |   0
 .../jsonrpc}/go-server/assembly/mac/release.sh     |   0
 .../jsonrpc}/go-server/assembly/mac/test.sh        |   0
 .../jsonrpc}/go-server/assembly/windows/dev.sh     |   0
 .../jsonrpc}/go-server/assembly/windows/release.sh |   0
 .../jsonrpc}/go-server/assembly/windows/test.sh    |   0
 .../jsonrpc/go-server}/profiles/dev/log.yml        |   0
 .../jsonrpc}/go-server/profiles/dev/server.yml     |  65 +++--
 .../jsonrpc/go-server}/profiles/release/log.yml    |   0
 .../jsonrpc/go-server/profiles/release/server.yml  |  75 +++++
 .../jsonrpc/go-server}/profiles/test/log.yml       |   0
 .../jsonrpc}/go-server/profiles/test/server.yml    |  63 +++--
 .../jsonrpc}/java-client/build.sh                  |   0
 examples/{ => general}/jsonrpc/java-client/pom.xml |   0
 .../java-client/src/main/assembly/assembly.xml     |   0
 .../src/main/assembly/conf/dubbo.properties        |   0
 .../src/main/assembly/conf}/log4j.properties       |   0
 .../src/main/java/com/ikurento/user/Consumer.java  | 196 +++++++++++++
 .../src/main/java/com/ikurento/user/Gender.java    |   0
 .../src/main/java/com/ikurento/user/User.java      |   0
 .../main/java/com/ikurento/user/UserProvider.java  |   0
 .../resources/META-INF/spring/dubbo.consumer.xml   |   4 +
 .../src/main/resources/META-INF/spring/service.xml |   2 +
 .../src/main/resources}/log4j.properties           |   0
 .../jsonrpc}/java-server/build.sh                  |   0
 .../{dubbo => general/jsonrpc}/java-server/pom.xml |   0
 .../jsonrpc}/java-server/script/debug.sh           |   0
 .../java-server/src/main/assembly/assembly.xml     |   0
 .../src/main/assembly/conf/dubbo.properties        |   0
 .../src/main/assembly/conf}/log4j.properties       |   0
 .../src/main/java/com/ikurento/user/Gender.java    |   0
 .../src/main/java/com/ikurento/user/Provider.java  |   0
 .../src/main/java/com/ikurento/user/Response.java  |   0
 .../src/main/java/com/ikurento/user/User.java      |   0
 .../main/java/com/ikurento/user/UserProvider.java  |   0
 .../com/ikurento/user/UserProviderAnotherImpl.java |   0
 .../java/com/ikurento/user/UserProviderImpl.java   |   0
 .../resources/META-INF/spring/dubbo.provider.xml   |   0
 .../src/main/resources}/log4j.properties           |   0
 .../dubbo/go-client/app/client.go}                 |  43 +--
 .../helloworld/dubbo/go-client/app/user.go         |  37 ++-
 .../dubbo/go-client}/assembly/bin/load.sh          |   0
 .../go-client}/assembly/common/app.properties      |   0
 .../dubbo/go-client}/assembly/common/build.sh      |   0
 .../dubbo/go-client}/assembly/linux/dev.sh         |   0
 .../dubbo/go-client}/assembly/linux/release.sh     |   0
 .../dubbo/go-client}/assembly/linux/test.sh        |   0
 .../dubbo/go-client}/assembly/mac/dev.sh           |   0
 .../dubbo/go-client}/assembly/mac/release.sh       |   0
 .../dubbo/go-client}/assembly/mac/test.sh          |   0
 .../dubbo/go-client}/assembly/windows/dev.sh       |   0
 .../dubbo/go-client}/assembly/windows/release.sh   |   0
 .../dubbo/go-client}/assembly/windows/test.sh      |   0
 .../dubbo/go-client/profiles/dev/client.yml        |  18 +-
 .../dubbo/go-client}/profiles/dev/log.yml          |   0
 .../dubbo/go-client/profiles/release/client.yml    |  10 +-
 .../dubbo/go-client}/profiles/release/log.yml      |   0
 .../dubbo/go-client/profiles/test/client.yml       |  13 +-
 .../dubbo/go-client}/profiles/test/log.yml         |   0
 .../dubbo}/go-server/app/server.go                 |   8 +-
 .../helloworld/dubbo/go-server/app/user.go         |  39 ++-
 .../dubbo/go-server}/assembly/bin/load.sh          |   0
 .../go-server}/assembly/common/app.properties      |   0
 .../dubbo/go-server}/assembly/common/build.sh      |   0
 .../dubbo/go-server}/assembly/linux/dev.sh         |   0
 .../dubbo/go-server}/assembly/linux/release.sh     |   0
 .../dubbo/go-server}/assembly/linux/test.sh        |   0
 .../dubbo/go-server}/assembly/mac/dev.sh           |   0
 .../dubbo/go-server}/assembly/mac/release.sh       |   0
 .../dubbo/go-server}/assembly/mac/test.sh          |   0
 .../dubbo/go-server}/assembly/windows/dev.sh       |   0
 .../dubbo/go-server}/assembly/windows/release.sh   |   0
 .../dubbo/go-server}/assembly/windows/test.sh      |   0
 .../dubbo/go-server}/profiles/dev/log.yml          |   0
 .../dubbo/go-server/profiles/dev}/server.yml       |  29 +-
 .../dubbo/go-server}/profiles/release/log.yml      |   0
 .../dubbo/go-server/profiles/release/server.yml    |   8 +-
 .../dubbo/go-server}/profiles/test/log.yml         |   0
 .../dubbo/go-server/profiles/test/server.yml       |  20 +-
 .../dubbo}/java-server/build.sh                    |   0
 .../dubbo}/java-server/pom.xml                     |   0
 .../dubbo}/java-server/script/debug.sh             |   0
 .../java-server/src/main/assembly/assembly.xml     |   0
 .../src/main/assembly/conf/dubbo.properties        |   0
 .../src/main/assembly/conf}/log4j.properties       |   0
 .../src/main/java/com/ikurento/user/Provider.java  |   0
 .../src/main/java/com/ikurento/user/User.java      |  13 +-
 .../main/java/com/ikurento/user/UserProvider.java} |  12 +-
 .../java/com/ikurento/user/UserProviderImpl.java   |  15 +
 .../resources/META-INF/spring/dubbo.provider.xml   |   5 -
 .../src/main/resources/log4j.properties            |   0
 .../jsonrpc/go-client/profiles/test/client.yml     |  67 -----
 examples/jsonrpc/go-server/app/user.go             | 179 ------------
 examples/jsonrpc/go-server/profiles/dev/server.yml |  50 ----
 .../jsonrpc/go-server/profiles/release/server.yml  |  50 ----
 .../jsonrpc/go-server/profiles/test/server.yml     |  50 ----
 .../src/main/java/com/ikurento/user/Consumer.java  |  97 -------
 filter/impl/echo_filter_test.go                    |   4 +-
 filter/impl/generic_filter.go                      | 125 +++++++++
 filter/impl/generic_filter_test.go                 |  89 ++++++
 go.mod                                             |   4 +-
 go.sum                                             |   9 +-
 protocol/dubbo/client.go                           | 132 +++------
 protocol/dubbo/client_test.go                      |  48 ++--
 protocol/dubbo/codec.go                            |   2 -
 protocol/dubbo/codec_test.go                       |  10 +-
 protocol/dubbo/config.go                           |  38 +--
 protocol/dubbo/dubbo_exporter.go                   |   4 +-
 protocol/dubbo/dubbo_invoker_test.go               |   7 +-
 protocol/dubbo/dubbo_protocol.go                   |   6 +-
 protocol/dubbo/listener.go                         |  10 +-
 protocol/dubbo/pool.go                             |  27 +-
 protocol/dubbo/readwriter.go                       |   9 +-
 protocol/dubbo/server.go                           |  18 +-
 protocol/invocation/rpcinvocation.go               |  96 +++----
 protocol/jsonrpc/http_test.go                      |  12 +-
 protocol/jsonrpc/jsonrpc_exporter.go               |   4 +-
 protocol/jsonrpc/jsonrpc_invoker_test.go           |   8 +-
 protocol/jsonrpc/server.go                         |   9 +-
 registry/zookeeper/registry_test.go                |   4 +-
 remoting/zookeeper/client.go                       |   5 +-
 remoting/zookeeper/listener.go                     |   6 +-
 remoting/zookeeper/listener_test.go                |  13 +-
 348 files changed, 2847 insertions(+), 1842 deletions(-)

diff --cc go.mod
index 94540e4,61ce25b..c25f0bd
--- a/go.mod
+++ b/go.mod
@@@ -1,12 -1,9 +1,12 @@@
  module github.com/apache/dubbo-go
  
  require (
 +	github.com/Workiva/go-datastructures v1.0.50
- 	github.com/apache/dubbo-go-hessian2 v1.2.4-0.20190807202824-177b9c667283
+ 	github.com/apache/dubbo-go-hessian2 v1.2.5-0.20190731020727-1697039810c8
 +	github.com/davecgh/go-spew v1.1.1 // indirect
- 	github.com/dubbogo/getty v1.2.0
+ 	github.com/dubbogo/getty v1.2.2
  	github.com/dubbogo/gost v1.1.1
 +	github.com/golang/mock v1.3.1
  	github.com/magiconair/properties v1.8.1
  	github.com/pkg/errors v0.8.1
  	github.com/samuel/go-zookeeper v0.0.0-20180130194729-c4fab1ac1bec
diff --cc go.sum
index 5b81816,7718fce..39b2c6e
--- a/go.sum
+++ b/go.sum
@@@ -1,18 -1,13 +1,17 @@@
 +github.com/Workiva/go-datastructures v1.0.50 h1:slDmfW6KCHcC7U+LP3DDBbm4fqTwZGn1beOFPfGaLvo=
 +github.com/Workiva/go-datastructures v1.0.50/go.mod h1:Z+F2Rca0qCsVYDS8z7bAGm8f3UkzuWYS/oBZz5a7VVA=
- github.com/apache/dubbo-go-hessian2 v1.2.4-0.20190807202824-177b9c667283 h1:4VTXcUeRxyKE1SXsfdHrmCvQftO+PXO9TJCNaekT59E=
- github.com/apache/dubbo-go-hessian2 v1.2.4-0.20190807202824-177b9c667283/go.mod h1:LWnndnrFXZmJLAzoyNAPNHSIJ1KOHVkTSsHgC3YYWlo=
+ github.com/apache/dubbo-go-hessian2 v1.2.5-0.20190731020727-1697039810c8 h1:7zJlM+8bpCAUhv03TZnXkT4MLlLWng1s7An8CLuN73E=
+ github.com/apache/dubbo-go-hessian2 v1.2.5-0.20190731020727-1697039810c8/go.mod h1:LWnndnrFXZmJLAzoyNAPNHSIJ1KOHVkTSsHgC3YYWlo=
  github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
  github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
  github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
  github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
- github.com/dubbogo/getty v1.2.0 h1:LmP/R/yCYp5/ubUTm5Xa7QwE3EnFFSjguJH8DJruJ70=
- github.com/dubbogo/getty v1.2.0/go.mod h1:p9Pyk18a+5Aa0GZ546aCzlehEfvEof0jAF0+QQcEPYQ=
- github.com/dubbogo/gost v1.0.1-0.20190706005735-65c3ecbba418/go.mod h1:R7wZm1DrmrKGr50mBZVcg6C9ekG8aL5hP+sgWcIDwQg=
+ github.com/dubbogo/getty v1.2.2 h1:qDC9WXjxcs5NPvWZz2ruVKBKr2r1Jjm6i0Sq//CQwbE=
+ github.com/dubbogo/getty v1.2.2/go.mod h1:K4b3MkGLf7T+lMgQNFgpg0dI1Wvv1PTisFs1Psf86kU=
  github.com/dubbogo/gost v1.1.1 h1:JCM7vx5edPIjDA5ovJTuzEEXuw2t7xLyrlgi2mi5jHI=
  github.com/dubbogo/gost v1.1.1/go.mod h1:R7wZm1DrmrKGr50mBZVcg6C9ekG8aL5hP+sgWcIDwQg=
 +github.com/golang/mock v1.3.1 h1:qGJ6qTW+x6xX/my+8YUVl4WNpX9B7+/l2tRsHGZ7f2s=
 +github.com/golang/mock v1.3.1/go.mod h1:sBzyDLLjw3U8JLTeZvSv8jJB+tU5PVekmnlKIyFUx0Y=
  github.com/golang/snappy v0.0.1 h1:Qgr9rKW7uDUkrbSmQeiDsGa8SjGyCOGtuasMWwvp2P4=
  github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
  github.com/gorilla/websocket v1.4.0 h1:WDFjx/TMzVgy9VdMMQi2K2Emtwi2QcUQsztZ/zLaH/Q=
diff --cc protocol/dubbo/readwriter.go
index aaf27e4,b882231..8c6c8a5
--- a/protocol/dubbo/readwriter.go
+++ b/protocol/dubbo/readwriter.go
@@@ -27,6 -27,6 +27,7 @@@ import 
  	"github.com/dubbogo/getty"
  	perrors "github.com/pkg/errors"
  )
++
  import (
  	"github.com/apache/dubbo-go/common"
  	"github.com/apache/dubbo-go/common/constant"