You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@dubbo.apache.org by jo...@apache.org on 2020/09/27 14:21:27 UTC
[dubbo-samples] 16/26: Rem: println
This is an automated email from the ASF dual-hosted git repository.
joezou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-samples.git
commit 797ce884a00ac7e49d765d2c87f6fce3cb05c96e
Author: yuyu <yu...@alipay.com>
AuthorDate: Tue Sep 1 20:44:26 2020 +0800
Rem: println
---
golang/async/go-client/app/client.go | 14 +--
golang/async/go-server/app/user.go | 13 +--
.../apollo/dubbo/go-client/app/client.go | 12 +-
.../apollo/dubbo/go-server/app/user.go | 13 +--
.../nacos/dubbo/go-client/app/client.go | 12 +-
.../configcenter/nacos/dubbo/go-server/app/user.go | 13 +--
.../zookeeper/dubbo/go-client/app/client.go | 12 +-
.../zookeeper/dubbo/go-server/app/user.go | 13 +--
golang/direct/dubbo/go-client/app/client.go | 12 +-
golang/direct/dubbo/go-client/app/version.go | 2 +-
golang/direct/dubbo/go-server/app/user.go | 13 +--
golang/direct/dubbo/go-server/app/version.go | 2 +-
.../custom_filter/dubbo/go-client/app/client.go | 12 +-
.../custom_filter/dubbo/go-client/app/version.go | 2 +-
.../dubbo/go-server/app/custom_filter.go | 8 +-
.../custom_filter/dubbo/go-server/app/server.go | 3 +
.../custom_filter/dubbo/go-server/app/user.go | 13 +--
.../custom_filter/dubbo/go-server/app/version.go | 2 +-
.../filter/tpslimit/dubbo/go-client/app/client.go | 12 +-
.../filter/tpslimit/dubbo/go-client/app/version.go | 2 +-
.../go-server/app/random_tps_limit_strategy.go | 8 +-
golang/filter/tpslimit/dubbo/go-server/app/user.go | 13 +--
.../filter/tpslimit/dubbo/go-server/app/version.go | 2 +-
golang/general/dubbo/go-client/app/client.go | 128 ++++++++++-----------
golang/general/dubbo/go-client/app/version.go | 2 +-
golang/general/dubbo/go-server/app/user.go | 4 -
.../general/dubbo/go-server/app/user_provider.go | 18 +--
.../general/dubbo/go-server/app/user_provider1.go | 12 +-
.../general/dubbo/go-server/app/user_provider2.go | 16 ++-
golang/general/dubbo/go-server/app/version.go | 2 +-
golang/general/grpc/go-client/app/client.go | 12 +-
golang/general/grpc/go-client/app/version.go | 2 +-
golang/general/grpc/go-server/app/version.go | 2 +-
golang/general/jsonrpc/go-client/app/client.go | 104 ++++++++---------
golang/general/jsonrpc/go-client/app/version.go | 2 +-
golang/general/jsonrpc/go-server/app/user.go | 5 -
.../general/jsonrpc/go-server/app/user_provider.go | 18 +--
.../jsonrpc/go-server/app/user_provider1.go | 12 +-
.../jsonrpc/go-server/app/user_provider2.go | 16 ++-
golang/general/jsonrpc/go-server/app/version.go | 2 +-
golang/general/rest/go-client/app/client.go | 74 ++++++------
golang/general/rest/go-client/app/version.go | 2 +-
golang/general/rest/go-server/app/server.go | 11 +-
golang/general/rest/go-server/app/user.go | 5 -
golang/general/rest/go-server/app/user_provider.go | 11 +-
.../general/rest/go-server/app/user_provider1.go | 7 +-
.../general/rest/go-server/app/user_provider2.go | 11 +-
golang/general/rest/go-server/app/version.go | 2 +-
golang/generic/go-client/app/client.go | 24 ++--
golang/generic/go-server/app/user.go | 17 ++-
golang/generic/go-server/app/version.go | 2 +-
golang/helloworld/dubbo/go-client/app/client.go | 12 +-
golang/helloworld/dubbo/go-client/app/version.go | 2 +-
golang/helloworld/dubbo/go-server/app/user.go | 13 +--
golang/helloworld/dubbo/go-server/app/version.go | 2 +-
golang/metric/dubbo/go-client/app/client.go | 12 +-
golang/metric/dubbo/go-client/app/version.go | 2 +-
golang/metric/dubbo/go-server/app/user.go | 12 +-
golang/metric/dubbo/go-server/app/version.go | 2 +-
.../multi_registry/dubbo/go-client/app/client.go | 12 +-
.../multi_registry/dubbo/go-client/app/version.go | 2 +-
golang/multi_registry/dubbo/go-server/app/user.go | 13 +--
.../multi_registry/dubbo/go-server/app/version.go | 2 +-
.../zone/dubbo/go-client/app/client.go | 14 +--
.../zone/dubbo/go-client/app/version.go | 2 +-
.../zone/dubbo/go-server/app/user.go | 13 +--
.../zone/dubbo/go-server/app/version.go | 2 +-
golang/registry/etcd/go-client/app/client.go | 12 +-
golang/registry/etcd/go-client/app/version.go | 2 +-
golang/registry/etcd/go-server/app/user.go | 13 +--
golang/registry/etcd/go-server/app/version.go | 2 +-
.../registry/nacos/dubbo/go-client/app/client.go | 12 +-
.../registry/nacos/dubbo/go-client/app/version.go | 2 +-
golang/registry/nacos/dubbo/go-server/app/user.go | 13 +--
.../registry/nacos/dubbo/go-server/app/version.go | 2 +-
.../servicediscovery/etcd/go-client/app/client.go | 12 +-
.../servicediscovery/etcd/go-client/app/version.go | 2 +-
.../servicediscovery/etcd/go-server/app/server.go | 2 +
.../servicediscovery/etcd/go-server/app/user.go | 13 +--
.../servicediscovery/etcd/go-server/app/version.go | 2 +-
.../servicediscovery/nacos/go-client/app/client.go | 12 +-
.../nacos/go-client/app/version.go | 2 +-
.../servicediscovery/nacos/go-server/app/user.go | 13 +--
.../nacos/go-server/app/version.go | 2 +-
.../zookeeper/go-client/app/client.go | 12 +-
.../zookeeper/go-client/app/version.go | 2 +-
.../zookeeper/go-server/app/user.go | 13 +--
.../zookeeper/go-server/app/version.go | 2 +-
golang/router/condition/go-client/app/client.go | 12 +-
golang/router/condition/go-server/app/server.go | 3 +
golang/router/condition/go-server/app/user.go | 13 +--
golang/router/condition/go-server/app/version.go | 2 +-
golang/seata/client/app/version.go | 2 +-
golang/seata/order-svc/app/version.go | 2 +-
golang/seata/product-svc/app/version.go | 2 +-
golang/tracing/dubbo/go-client/app/client.go | 13 +--
golang/tracing/dubbo/go-client/app/user.go | 4 +-
golang/tracing/dubbo/go-client/app/version.go | 2 +-
golang/tracing/dubbo/go-server/app/server.go | 4 +-
golang/tracing/dubbo/go-server/app/user.go | 12 +-
golang/tracing/dubbo/go-server/app/version.go | 2 +-
golang/tracing/grpc/go-client/app/client.go | 16 +--
golang/tracing/grpc/go-client/app/version.go | 2 +-
golang/tracing/grpc/go-server/app/version.go | 2 +-
golang/tracing/jsonrpc/go-client/app/client.go | 97 ++++++++--------
golang/tracing/jsonrpc/go-client/app/version.go | 2 +-
golang/tracing/jsonrpc/go-server/app/server.go | 2 +
golang/tracing/jsonrpc/go-server/app/user.go | 5 -
.../tracing/jsonrpc/go-server/app/user_provider.go | 21 ++--
.../jsonrpc/go-server/app/user_provider1.go | 12 +-
.../jsonrpc/go-server/app/user_provider2.go | 18 +--
golang/tracing/jsonrpc/go-server/app/version.go | 2 +-
112 files changed, 635 insertions(+), 612 deletions(-)
diff --git a/golang/async/go-client/app/client.go b/golang/async/go-client/app/client.go
index 7092ce9..c4e79ca 100644
--- a/golang/async/go-client/app/client.go
+++ b/golang/async/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common"
"github.com/apache/dubbo-go/common/logger"
@@ -46,10 +50,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -58,13 +58,13 @@ func main() {
config.Load()
time.Sleep(1e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
@@ -119,5 +119,5 @@ func (User) JavaClassName() string {
}
func (u *UserProvider) CallBack(res common.CallbackResponse) {
- println("CallBack res: %v", res)
+ gxlog.CInfo("CallBack res: %v", res)
}
diff --git a/golang/async/go-server/app/user.go b/golang/async/go-server/app/user.go
index 6410074..89fa126 100644
--- a/golang/async/go-server/app/user.go
+++ b/golang/async/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/configcenter/apollo/dubbo/go-client/app/client.go b/golang/configcenter/apollo/dubbo/go-client/app/client.go
index 15b038a..0f7b9f6 100644
--- a/golang/configcenter/apollo/dubbo/go-client/app/client.go
+++ b/golang/configcenter/apollo/dubbo/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -46,10 +50,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -58,13 +58,13 @@ func main() {
config.Load()
time.Sleep(1e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
diff --git a/golang/configcenter/apollo/dubbo/go-server/app/user.go b/golang/configcenter/apollo/dubbo/go-server/app/user.go
index 6410074..89fa126 100644
--- a/golang/configcenter/apollo/dubbo/go-server/app/user.go
+++ b/golang/configcenter/apollo/dubbo/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/configcenter/nacos/dubbo/go-client/app/client.go b/golang/configcenter/nacos/dubbo/go-client/app/client.go
index 4786ed1..e457052 100755
--- a/golang/configcenter/nacos/dubbo/go-client/app/client.go
+++ b/golang/configcenter/nacos/dubbo/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -46,10 +50,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -58,13 +58,13 @@ func main() {
config.Load()
time.Sleep(1e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
diff --git a/golang/configcenter/nacos/dubbo/go-server/app/user.go b/golang/configcenter/nacos/dubbo/go-server/app/user.go
index 6410074..89fa126 100755
--- a/golang/configcenter/nacos/dubbo/go-server/app/user.go
+++ b/golang/configcenter/nacos/dubbo/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/configcenter/zookeeper/dubbo/go-client/app/client.go b/golang/configcenter/zookeeper/dubbo/go-client/app/client.go
index 24411ec..5e73b0e 100755
--- a/golang/configcenter/zookeeper/dubbo/go-client/app/client.go
+++ b/golang/configcenter/zookeeper/dubbo/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -46,10 +50,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -58,13 +58,13 @@ func main() {
config.Load()
time.Sleep(1e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
diff --git a/golang/configcenter/zookeeper/dubbo/go-server/app/user.go b/golang/configcenter/zookeeper/dubbo/go-server/app/user.go
index 6410074..89fa126 100755
--- a/golang/configcenter/zookeeper/dubbo/go-server/app/user.go
+++ b/golang/configcenter/zookeeper/dubbo/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/direct/dubbo/go-client/app/client.go b/golang/direct/dubbo/go-client/app/client.go
index 6956629..4cc0806 100755
--- a/golang/direct/dubbo/go-client/app/client.go
+++ b/golang/direct/dubbo/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
"github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -45,10 +49,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -57,13 +57,13 @@ func main() {
config.Load()
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
diff --git a/golang/direct/dubbo/go-client/app/version.go b/golang/direct/dubbo/go-client/app/version.go
index c613858..ae51f45 100644
--- a/golang/direct/dubbo/go-client/app/version.go
+++ b/golang/direct/dubbo/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/direct/dubbo/go-server/app/user.go b/golang/direct/dubbo/go-server/app/user.go
index 6410074..89fa126 100755
--- a/golang/direct/dubbo/go-server/app/user.go
+++ b/golang/direct/dubbo/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/direct/dubbo/go-server/app/version.go b/golang/direct/dubbo/go-server/app/version.go
index c613858..ae51f45 100644
--- a/golang/direct/dubbo/go-server/app/version.go
+++ b/golang/direct/dubbo/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/filter/custom_filter/dubbo/go-client/app/client.go b/golang/filter/custom_filter/dubbo/go-client/app/client.go
index 05a753f..0d0b138 100644
--- a/golang/filter/custom_filter/dubbo/go-client/app/client.go
+++ b/golang/filter/custom_filter/dubbo/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -53,13 +57,13 @@ func main() {
config.Load()
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
@@ -86,7 +90,3 @@ func initSignal() {
}
}
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/filter/custom_filter/dubbo/go-client/app/version.go b/golang/filter/custom_filter/dubbo/go-client/app/version.go
index c613858..ae51f45 100644
--- a/golang/filter/custom_filter/dubbo/go-client/app/version.go
+++ b/golang/filter/custom_filter/dubbo/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/filter/custom_filter/dubbo/go-server/app/custom_filter.go b/golang/filter/custom_filter/dubbo/go-server/app/custom_filter.go
index 3d317fd..bda2c36 100644
--- a/golang/filter/custom_filter/dubbo/go-server/app/custom_filter.go
+++ b/golang/filter/custom_filter/dubbo/go-server/app/custom_filter.go
@@ -23,6 +23,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
"github.com/apache/dubbo-go/common/extension"
"github.com/apache/dubbo-go/filter"
"github.com/apache/dubbo-go/protocol"
@@ -56,13 +60,13 @@ func (mf myCustomFilter) Invoke(ctx context.Context, invoker protocol.Invoker, i
// you can get many params in url. And the invocation provides more information about
url := invoker.GetUrl()
serviceKey := url.ServiceKey()
- println("Here is the my custom filter. The service is invoked: %s", serviceKey)
+ gxlog.CInfo("Here is the my custom filter. The service is invoked: %s", serviceKey)
return invoker.Invoke(ctx, invocation)
}
func (mf myCustomFilter) OnResponse(ctx context.Context, result protocol.Result, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result {
// you can do something here with result
- println("Got result!")
+ gxlog.CInfo("Got result!")
return result
}
diff --git a/golang/filter/custom_filter/dubbo/go-server/app/server.go b/golang/filter/custom_filter/dubbo/go-server/app/server.go
index fd81aab..a2d17f4 100644
--- a/golang/filter/custom_filter/dubbo/go-server/app/server.go
+++ b/golang/filter/custom_filter/dubbo/go-server/app/server.go
@@ -27,6 +27,9 @@ import (
import (
hessian "github.com/apache/dubbo-go-hessian2"
+)
+
+import (
"github.com/apache/dubbo-go/common/logger"
"github.com/apache/dubbo-go/config"
_ "github.com/apache/dubbo-go/protocol/dubbo"
diff --git a/golang/filter/custom_filter/dubbo/go-server/app/user.go b/golang/filter/custom_filter/dubbo/go-server/app/user.go
index 6410074..89fa126 100644
--- a/golang/filter/custom_filter/dubbo/go-server/app/user.go
+++ b/golang/filter/custom_filter/dubbo/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/filter/custom_filter/dubbo/go-server/app/version.go b/golang/filter/custom_filter/dubbo/go-server/app/version.go
index c613858..ae51f45 100644
--- a/golang/filter/custom_filter/dubbo/go-server/app/version.go
+++ b/golang/filter/custom_filter/dubbo/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/filter/tpslimit/dubbo/go-client/app/client.go b/golang/filter/tpslimit/dubbo/go-client/app/client.go
index 05a753f..0d0b138 100644
--- a/golang/filter/tpslimit/dubbo/go-client/app/client.go
+++ b/golang/filter/tpslimit/dubbo/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -53,13 +57,13 @@ func main() {
config.Load()
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
@@ -86,7 +90,3 @@ func initSignal() {
}
}
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/filter/tpslimit/dubbo/go-client/app/version.go b/golang/filter/tpslimit/dubbo/go-client/app/version.go
index c613858..ae51f45 100644
--- a/golang/filter/tpslimit/dubbo/go-client/app/version.go
+++ b/golang/filter/tpslimit/dubbo/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/filter/tpslimit/dubbo/go-server/app/random_tps_limit_strategy.go b/golang/filter/tpslimit/dubbo/go-server/app/random_tps_limit_strategy.go
index 8e4db41..38b0e78 100644
--- a/golang/filter/tpslimit/dubbo/go-server/app/random_tps_limit_strategy.go
+++ b/golang/filter/tpslimit/dubbo/go-server/app/random_tps_limit_strategy.go
@@ -18,11 +18,15 @@
package main
import (
- "github.com/apache/dubbo-go/filter"
"math/rand"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
+ "github.com/apache/dubbo-go/filter"
"github.com/apache/dubbo-go/common/extension"
)
@@ -52,7 +56,7 @@ type RandomTpsLimitStrategy struct {
func (r RandomTpsLimitStrategy) IsAllowable() bool {
// this is a simple demo.
- println("Random IsAllowable!")
+ gxlog.CInfo("Random IsAllowable!")
randNum := rand.Int63n(2)
return randNum == 0
}
diff --git a/golang/filter/tpslimit/dubbo/go-server/app/user.go b/golang/filter/tpslimit/dubbo/go-server/app/user.go
index 6410074..89fa126 100644
--- a/golang/filter/tpslimit/dubbo/go-server/app/user.go
+++ b/golang/filter/tpslimit/dubbo/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/filter/tpslimit/dubbo/go-server/app/version.go b/golang/filter/tpslimit/dubbo/go-server/app/version.go
index c613858..ae51f45 100644
--- a/golang/filter/tpslimit/dubbo/go-server/app/version.go
+++ b/golang/filter/tpslimit/dubbo/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/general/dubbo/go-client/app/client.go b/golang/general/dubbo/go-client/app/client.go
index 62e8b3e..838887d 100755
--- a/golang/general/dubbo/go-client/app/client.go
+++ b/golang/general/dubbo/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -55,11 +59,11 @@ func main() {
config.Load()
- println("\n\ntest")
+ gxlog.CInfo("\n\ntest")
test()
- println("\n\ntest1")
+ gxlog.CInfo("\n\ntest1")
test1()
- println("\n\ntest2")
+ gxlog.CInfo("\n\ntest2")
test2()
initSignal()
}
@@ -88,230 +92,226 @@ func initSignal() {
}
}
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
func test() {
- println("\n\n\necho")
+ gxlog.CInfo("\n\n\necho")
res, err := userProvider.Echo(context.TODO(), "OK")
if err != nil {
panic(err)
}
- println("res: %v\n", res)
+ gxlog.CInfo("res: %v\n", res)
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err = userProvider.GetUser(context.TODO(), []interface{}{"A003"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test dubbo - enum")
+ gxlog.CInfo("\n\n\nstart to test dubbo - enum")
gender, err := userProvider.GetGender(1)
if err != nil {
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
} else {
- println("response result: %v", gender)
+ gxlog.CInfo("response result: %v", gender)
}
- println("\n\n\nstart to test dubbo - GetUser0")
+ gxlog.CInfo("\n\n\nstart to test dubbo - GetUser0")
ret, err := userProvider.GetUser0("A003", "Moorse")
if err != nil {
panic(err)
}
- println("response result: %v", ret)
+ gxlog.CInfo("response result: %v", ret)
- println("\n\n\nstart to test dubbo - GetUsers")
+ gxlog.CInfo("\n\n\nstart to test dubbo - GetUsers")
ret1, err := userProvider.GetUsers([]interface{}{[]interface{}{"A002", "A003"}})
if err != nil {
panic(err)
}
- println("response result: %v", ret1)
+ gxlog.CInfo("response result: %v", ret1)
- println("\n\n\nstart to test dubbo - getUser")
+ gxlog.CInfo("\n\n\nstart to test dubbo - getUser")
user = &User{}
var i int32 = 1
err = userProvider.GetUser2(context.TODO(), []interface{}{i}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test dubbo - getUser - overload")
+ gxlog.CInfo("\n\n\nstart to test dubbo - getUser - overload")
user = &User{}
err = userProvider.GetUser2(context.TODO(), []interface{}{i, "overload"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test dubbo - GetUser3")
+ gxlog.CInfo("\n\n\nstart to test dubbo - GetUser3")
err = userProvider.GetUser3()
if err != nil {
panic(err)
}
- println("succ!")
+ gxlog.CInfo("succ!")
- println("\n\n\nstart to test dubbo - getErr")
+ gxlog.CInfo("\n\n\nstart to test dubbo - getErr")
user = &User{}
err = userProvider.GetErr(context.TODO(), []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("getErr - error: %v", err)
+ gxlog.CInfo("getErr - error: %v", err)
- println("\n\n\nstart to test dubbo illegal method")
+ gxlog.CInfo("\n\n\nstart to test dubbo illegal method")
err = userProvider.GetUser1(context.TODO(), []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
}
func test1() {
- println("\n\n\necho")
+ gxlog.CInfo("\n\n\necho")
res, err := userProvider1.Echo(context.TODO(), "OK")
if err != nil {
panic(err)
}
- println("res: %v\n", res)
+ gxlog.CInfo("res: %v\n", res)
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err = userProvider1.GetUser(context.TODO(), []interface{}{"A003"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test dubbo - GetUser0")
+ gxlog.CInfo("\n\n\nstart to test dubbo - GetUser0")
ret, err := userProvider1.GetUser0("A003", "Moorse")
if err != nil {
panic(err)
}
- println("response result: %v", ret)
+ gxlog.CInfo("response result: %v", ret)
- println("\n\n\nstart to test dubbo - GetUsers")
+ gxlog.CInfo("\n\n\nstart to test dubbo - GetUsers")
ret1, err := userProvider1.GetUsers([]interface{}{[]interface{}{"A002", "A003"}})
if err != nil {
panic(err)
}
- println("response result: %v", ret1)
+ gxlog.CInfo("response result: %v", ret1)
- println("\n\n\nstart to test dubbo - getUser")
+ gxlog.CInfo("\n\n\nstart to test dubbo - getUser")
user = &User{}
var i int32 = 1
err = userProvider1.GetUser2(context.TODO(), []interface{}{i}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test dubbo - getUser - overload")
+ gxlog.CInfo("\n\n\nstart to test dubbo - getUser - overload")
user = &User{}
err = userProvider1.GetUser2(context.TODO(), []interface{}{i, "overload"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test dubbo - GetUser3")
+ gxlog.CInfo("\n\n\nstart to test dubbo - GetUser3")
err = userProvider1.GetUser3()
if err != nil {
panic(err)
}
- println("succ!")
+ gxlog.CInfo("succ!")
- println("\n\n\nstart to test dubbo - getErr")
+ gxlog.CInfo("\n\n\nstart to test dubbo - getErr")
user = &User{}
err = userProvider1.GetErr(context.TODO(), []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("getErr - error: %v", err)
+ gxlog.CInfo("getErr - error: %v", err)
- println("\n\n\nstart to test dubbo illegal method")
+ gxlog.CInfo("\n\n\nstart to test dubbo illegal method")
err = userProvider1.GetUser1(context.TODO(), []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
}
func test2() {
- println("\n\n\necho")
+ gxlog.CInfo("\n\n\necho")
res, err := userProvider2.Echo(context.TODO(), "OK")
if err != nil {
panic(err)
}
- println("res: %v\n", res)
+ gxlog.CInfo("res: %v\n", res)
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err = userProvider2.GetUser(context.TODO(), []interface{}{"A003"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test dubbo - GetUser0")
+ gxlog.CInfo("\n\n\nstart to test dubbo - GetUser0")
ret, err := userProvider2.GetUser0("A003", "Moorse")
if err != nil {
panic(err)
}
- println("response result: %v", ret)
+ gxlog.CInfo("response result: %v", ret)
- println("\n\n\nstart to test dubbo - GetUsers")
+ gxlog.CInfo("\n\n\nstart to test dubbo - GetUsers")
ret1, err := userProvider2.GetUsers([]interface{}{[]interface{}{"A002", "A003"}})
if err != nil {
panic(err)
}
- println("response result: %v", ret1)
+ gxlog.CInfo("response result: %v", ret1)
- println("\n\n\nstart to test dubbo - getUser")
+ gxlog.CInfo("\n\n\nstart to test dubbo - getUser")
user = &User{}
var i int32 = 1
err = userProvider2.GetUser2(context.TODO(), []interface{}{i}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test dubbo - getUser - overload")
+ gxlog.CInfo("\n\n\nstart to test dubbo - getUser - overload")
user = &User{}
err = userProvider2.GetUser2(context.TODO(), []interface{}{i, "overload"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test dubbo - GetUser3")
+ gxlog.CInfo("\n\n\nstart to test dubbo - GetUser3")
err = userProvider2.GetUser3()
if err != nil {
panic(err)
}
- println("succ!")
+ gxlog.CInfo("succ!")
- println("\n\n\nstart to test dubbo - getErr")
+ gxlog.CInfo("\n\n\nstart to test dubbo - getErr")
user = &User{}
err = userProvider2.GetErr(context.TODO(), []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("getErr - error: %v", err)
+ gxlog.CInfo("getErr - error: %v", err)
- println("\n\n\nstart to test dubbo illegal method")
+ gxlog.CInfo("\n\n\nstart to test dubbo illegal method")
err = userProvider2.GetUser1(context.TODO(), []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
}
diff --git a/golang/general/dubbo/go-client/app/version.go b/golang/general/dubbo/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/general/dubbo/go-client/app/version.go
+++ b/golang/general/dubbo/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/general/dubbo/go-server/app/user.go b/golang/general/dubbo/go-server/app/user.go
index e07a02e..21fbe9a 100755
--- a/golang/general/dubbo/go-server/app/user.go
+++ b/golang/general/dubbo/go-server/app/user.go
@@ -107,7 +107,3 @@ func (u User) String() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/general/dubbo/go-server/app/user_provider.go b/golang/general/dubbo/go-server/app/user_provider.go
index 2a02f21..9e13932 100755
--- a/golang/general/dubbo/go-server/app/user_provider.go
+++ b/golang/general/dubbo/go-server/app/user_provider.go
@@ -25,6 +25,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
"github.com/apache/dubbo-go-hessian2/java_exception"
"github.com/apache/dubbo-go/config"
perrors "github.com/pkg/errors"
@@ -51,11 +55,11 @@ func (u *UserProvider) GetUser(ctx context.Context, req []interface{}, rsp *User
user *User
)
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
@@ -63,7 +67,7 @@ func (u *UserProvider) GetUser(ctx context.Context, req []interface{}, rsp *User
func (u *UserProvider) GetUser0(id string, name string) (User, error) {
var err error
- println("id:%s, name:%s", id, name)
+ gxlog.CInfo("id:%s, name:%s", id, name)
user, err := u.getUser(id)
if err != nil {
return User{}, err
@@ -77,7 +81,7 @@ func (u *UserProvider) GetUser0(id string, name string) (User, error) {
func (u *UserProvider) GetUser2(ctx context.Context, req []interface{}, rsp *User) error {
var err error
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp.Id = strconv.Itoa(int(req[0].(int32)))
return err
}
@@ -93,18 +97,18 @@ func (u *UserProvider) GetErr(ctx context.Context, req []interface{}, rsp *User)
func (u *UserProvider) GetUsers(req []interface{}) ([]interface{}, error) {
var err error
- println("req:%s", req)
+ gxlog.CInfo("req:%s", req)
t := req[0].([]interface{})
user, err := u.getUser(t[0].(string))
if err != nil {
return nil, err
}
- println("user:%v", user)
+ gxlog.CInfo("user:%v", user)
user1, err := u.getUser(t[1].(string))
if err != nil {
return nil, err
}
- println("user1:%v", user1)
+ gxlog.CInfo("user1:%v", user1)
return []interface{}{user, user1}, err
}
diff --git a/golang/general/dubbo/go-server/app/user_provider1.go b/golang/general/dubbo/go-server/app/user_provider1.go
index afc2a1d..7dfc141 100755
--- a/golang/general/dubbo/go-server/app/user_provider1.go
+++ b/golang/general/dubbo/go-server/app/user_provider1.go
@@ -24,6 +24,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
"github.com/apache/dubbo-go-hessian2/java_exception"
"github.com/apache/dubbo-go/config"
perrors "github.com/pkg/errors"
@@ -50,11 +54,11 @@ func (u *UserProvider1) GetUser(ctx context.Context, req []interface{}, rsp *Use
user *User
)
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
@@ -62,7 +66,7 @@ func (u *UserProvider1) GetUser(ctx context.Context, req []interface{}, rsp *Use
func (u *UserProvider1) GetUser0(id string, name string) (User, error) {
var err error
- println("id:%s, name:%s", id, name)
+ gxlog.CInfo("id:%s, name:%s", id, name)
user, err := u.getUser(id)
if err != nil {
return User{}, err
@@ -76,7 +80,7 @@ func (u *UserProvider1) GetUser0(id string, name string) (User, error) {
func (u *UserProvider1) GetUser2(ctx context.Context, req []interface{}, rsp *User) error {
var err error
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp.Id = strconv.Itoa(int(req[0].(int32)))
return err
}
diff --git a/golang/general/dubbo/go-server/app/user_provider2.go b/golang/general/dubbo/go-server/app/user_provider2.go
index cc19e0b..4472242 100755
--- a/golang/general/dubbo/go-server/app/user_provider2.go
+++ b/golang/general/dubbo/go-server/app/user_provider2.go
@@ -24,6 +24,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
"github.com/apache/dubbo-go-hessian2/java_exception"
"github.com/apache/dubbo-go/config"
perrors "github.com/pkg/errors"
@@ -50,11 +54,11 @@ func (u *UserProvider2) GetUser(ctx context.Context, req []interface{}, rsp *Use
user *User
)
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
@@ -62,7 +66,7 @@ func (u *UserProvider2) GetUser(ctx context.Context, req []interface{}, rsp *Use
func (u *UserProvider2) GetUser0(id string, name string) (User, error) {
var err error
- println("id:%s, name:%s", id, name)
+ gxlog.CInfo("id:%s, name:%s", id, name)
user, err := u.getUser(id)
if err != nil {
return User{}, err
@@ -76,7 +80,7 @@ func (u *UserProvider2) GetUser0(id string, name string) (User, error) {
func (u *UserProvider2) GetUser2(ctx context.Context, req []interface{}, rsp *User) error {
var err error
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp.Id = strconv.Itoa(int(req[0].(int32)))
return err
}
@@ -92,13 +96,13 @@ func (u *UserProvider2) GetErr(ctx context.Context, req []interface{}, rsp *User
func (u *UserProvider2) GetUsers(req []interface{}) ([]interface{}, error) {
var err error
- println("req:%s", req)
+ gxlog.CInfo("req:%s", req)
t := req[0].([]interface{})
user, err := u.getUser(t[0].(string))
if err != nil {
return nil, err
}
- println("user:%v", user)
+ gxlog.CInfo("user:%v", user)
return []interface{}{user}, err
}
diff --git a/golang/general/dubbo/go-server/app/version.go b/golang/general/dubbo/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/general/dubbo/go-server/app/version.go
+++ b/golang/general/dubbo/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/general/grpc/go-client/app/client.go b/golang/general/grpc/go-client/app/client.go
index 55431f4..d8634b7 100644
--- a/golang/general/grpc/go-client/app/client.go
+++ b/golang/general/grpc/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
_ "github.com/apache/dubbo-go/cluster/cluster_impl"
_ "github.com/apache/dubbo-go/cluster/loadbalance"
"github.com/apache/dubbo-go/common/logger"
@@ -43,10 +47,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -54,7 +54,7 @@ func main() {
config.Load()
time.Sleep(time.Second)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
reply := &HelloReply{}
req := &HelloRequest{
Name: "xujianhai",
@@ -63,7 +63,7 @@ func main() {
if err != nil {
panic(err)
}
- println("client response result: %v\n", reply)
+ gxlog.CInfo("client response result: %v\n", reply)
initSignal()
}
diff --git a/golang/general/grpc/go-client/app/version.go b/golang/general/grpc/go-client/app/version.go
index c613858..ae51f45 100644
--- a/golang/general/grpc/go-client/app/version.go
+++ b/golang/general/grpc/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/general/grpc/go-server/app/version.go b/golang/general/grpc/go-server/app/version.go
index c613858..ae51f45 100644
--- a/golang/general/grpc/go-server/app/version.go
+++ b/golang/general/grpc/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/general/jsonrpc/go-client/app/client.go b/golang/general/jsonrpc/go-client/app/client.go
index 2ff5a11..aa857df 100755
--- a/golang/general/jsonrpc/go-client/app/client.go
+++ b/golang/general/jsonrpc/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
"github.com/apache/dubbo-go/config"
@@ -51,11 +55,11 @@ func main() {
config.Load()
- println("\n\ntest")
+ gxlog.CInfo("\n\ntest")
test()
- println("\n\ntest1")
+ gxlog.CInfo("\n\ntest1")
test1()
- println("\n\ntest2")
+ gxlog.CInfo("\n\ntest2")
test2()
initSignal()
@@ -85,174 +89,170 @@ func initSignal() {
}
}
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
func test() {
- println("\n\n\necho")
+ gxlog.CInfo("\n\n\necho")
res, err := userProvider.Echo(context.TODO(), "OK")
if err != nil {
- println("echo - error: %v", err)
+ gxlog.CInfo("echo - error: %v", err)
} else {
- println("res: %v", res)
+ gxlog.CInfo("res: %v", res)
}
time.Sleep(3e9)
- println("\n\n\nstart to test jsonrpc")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc")
user := &JsonRPCUser{}
err = userProvider.GetUser(context.TODO(), []interface{}{"A003"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test jsonrpc - GetUser0")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUser0")
ret, err := userProvider.GetUser0("A003", "Moorse")
if err != nil {
panic(err)
}
- println("response result: %v", ret)
+ gxlog.CInfo("response result: %v", ret)
- println("\n\n\nstart to test jsonrpc - GetUsers")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUsers")
ret1, err := userProvider.GetUsers([]interface{}{[]interface{}{"A002", "A003"}})
if err != nil {
panic(err)
}
- println("response result: %v", ret1)
+ gxlog.CInfo("response result: %v", ret1)
- println("\n\n\nstart to test jsonrpc - getUser")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - getUser")
user = &JsonRPCUser{}
err = userProvider.GetUser2(context.TODO(), []interface{}{1}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test jsonrpc - GetUser3")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUser3")
err = userProvider.GetUser3()
if err != nil {
panic(err)
}
- println("succ!")
+ gxlog.CInfo("succ!")
- println("\n\n\nstart to test jsonrpc illegal method")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc illegal method")
err = userProvider.GetUser1(context.TODO(), []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
}
func test1() {
- println("\n\n\necho")
+ gxlog.CInfo("\n\n\necho")
res, err := userProvider1.Echo(context.TODO(), "OK")
if err != nil {
- println("echo - error: %v", err)
+ gxlog.CInfo("echo - error: %v", err)
} else {
- println("res: %v", res)
+ gxlog.CInfo("res: %v", res)
}
time.Sleep(3e9)
- println("\n\n\nstart to test jsonrpc")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc")
user := &JsonRPCUser{}
err = userProvider1.GetUser(context.TODO(), []interface{}{"A003"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test jsonrpc - GetUser0")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUser0")
ret, err := userProvider1.GetUser0("A003", "Moorse")
if err != nil {
panic(err)
}
- println("response result: %v", ret)
+ gxlog.CInfo("response result: %v", ret)
- println("\n\n\nstart to test jsonrpc - GetUsers")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUsers")
ret1, err := userProvider1.GetUsers([]interface{}{[]interface{}{"A002", "A003"}})
if err != nil {
panic(err)
}
- println("response result: %v", ret1)
+ gxlog.CInfo("response result: %v", ret1)
- println("\n\n\nstart to test jsonrpc - getUser")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - getUser")
user = &JsonRPCUser{}
err = userProvider1.GetUser2(context.TODO(), []interface{}{1}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test jsonrpc - GetUser3")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUser3")
err = userProvider1.GetUser3()
if err != nil {
panic(err)
}
- println("succ!")
+ gxlog.CInfo("succ!")
- println("\n\n\nstart to test jsonrpc illegal method")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc illegal method")
err = userProvider1.GetUser1(context.TODO(), []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
}
func test2() {
- println("\n\n\necho")
+ gxlog.CInfo("\n\n\necho")
res, err := userProvider2.Echo(context.TODO(), "OK")
if err != nil {
- println("echo - error: %v", err)
+ gxlog.CInfo("echo - error: %v", err)
} else {
- println("res: %v", res)
+ gxlog.CInfo("res: %v", res)
}
time.Sleep(3e9)
- println("\n\n\nstart to test jsonrpc")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc")
user := &JsonRPCUser{}
err = userProvider2.GetUser(context.TODO(), []interface{}{"A003"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test jsonrpc - GetUser0")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUser0")
ret, err := userProvider2.GetUser0("A003", "Moorse")
if err != nil {
panic(err)
}
- println("response result: %v", ret)
+ gxlog.CInfo("response result: %v", ret)
- println("\n\n\nstart to test jsonrpc - GetUsers")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUsers")
ret1, err := userProvider2.GetUsers([]interface{}{[]interface{}{"A002", "A003"}})
if err != nil {
panic(err)
}
- println("response result: %v", ret1)
+ gxlog.CInfo("response result: %v", ret1)
- println("\n\n\nstart to test jsonrpc - getUser")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - getUser")
user = &JsonRPCUser{}
err = userProvider2.GetUser2(context.TODO(), []interface{}{1}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test jsonrpc - GetUser3")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUser3")
err = userProvider2.GetUser3()
if err != nil {
panic(err)
}
- println("succ!")
+ gxlog.CInfo("succ!")
- println("\n\n\nstart to test jsonrpc illegal method")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc illegal method")
err = userProvider2.GetUser1(context.TODO(), []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
}
diff --git a/golang/general/jsonrpc/go-client/app/version.go b/golang/general/jsonrpc/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/general/jsonrpc/go-client/app/version.go
+++ b/golang/general/jsonrpc/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/general/jsonrpc/go-server/app/user.go b/golang/general/jsonrpc/go-server/app/user.go
index 8376610..e1df07a 100755
--- a/golang/general/jsonrpc/go-server/app/user.go
+++ b/golang/general/jsonrpc/go-server/app/user.go
@@ -18,7 +18,6 @@
package main
import (
- "fmt"
"time"
)
@@ -72,7 +71,3 @@ func init() {
userMap[k] = v
}
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/general/jsonrpc/go-server/app/user_provider.go b/golang/general/jsonrpc/go-server/app/user_provider.go
index 4af4bb0..0b878b3 100755
--- a/golang/general/jsonrpc/go-server/app/user_provider.go
+++ b/golang/general/jsonrpc/go-server/app/user_provider.go
@@ -7,6 +7,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
"github.com/apache/dubbo-go/config"
perrors "github.com/pkg/errors"
)
@@ -32,11 +36,11 @@ func (u *UserProvider) GetUser(ctx context.Context, req []interface{}, rsp *User
user *User
)
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
@@ -44,7 +48,7 @@ func (u *UserProvider) GetUser(ctx context.Context, req []interface{}, rsp *User
func (u *UserProvider) GetUser0(id string, name string) (User, error) {
var err error
- println("id:%s, name:%s", id, name)
+ gxlog.CInfo("id:%s, name:%s", id, name)
user, err := u.getUser(id)
if err != nil {
return User{}, err
@@ -58,7 +62,7 @@ func (u *UserProvider) GetUser0(id string, name string) (User, error) {
func (u *UserProvider) GetUser2(ctx context.Context, req []interface{}, rsp *User) error {
var err error
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp.Id = strconv.FormatFloat(req[0].(float64), 'f', 0, 64)
rsp.Sex = Gender(MAN).String()
return err
@@ -71,18 +75,18 @@ func (u *UserProvider) GetUser3() error {
func (u *UserProvider) GetUsers(req []interface{}) ([]User, error) {
var err error
- println("req:%s", req)
+ gxlog.CInfo("req:%s", req)
t := req[0].([]interface{})
user, err := u.getUser(t[0].(string))
if err != nil {
return nil, err
}
- println("user:%v", user)
+ gxlog.CInfo("user:%v", user)
user1, err := u.getUser(t[1].(string))
if err != nil {
return nil, err
}
- println("user1:%v", user1)
+ gxlog.CInfo("user1:%v", user1)
return []User{*user, *user1}, err
}
diff --git a/golang/general/jsonrpc/go-server/app/user_provider1.go b/golang/general/jsonrpc/go-server/app/user_provider1.go
index 1557c6b..fa591a3 100755
--- a/golang/general/jsonrpc/go-server/app/user_provider1.go
+++ b/golang/general/jsonrpc/go-server/app/user_provider1.go
@@ -7,6 +7,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
"github.com/apache/dubbo-go/config"
perrors "github.com/pkg/errors"
)
@@ -32,11 +36,11 @@ func (u *UserProvider1) GetUser(ctx context.Context, req []interface{}, rsp *Use
user *User
)
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
@@ -44,7 +48,7 @@ func (u *UserProvider1) GetUser(ctx context.Context, req []interface{}, rsp *Use
func (u *UserProvider1) GetUser0(id string, name string) (User, error) {
var err error
- println("id:%s, name:%s", id, name)
+ gxlog.CInfo("id:%s, name:%s", id, name)
user, err := u.getUser(id)
if err != nil {
return User{}, err
@@ -58,7 +62,7 @@ func (u *UserProvider1) GetUser0(id string, name string) (User, error) {
func (u *UserProvider1) GetUser2(ctx context.Context, req []interface{}, rsp *User) error {
var err error
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp.Id = strconv.FormatFloat(req[0].(float64), 'f', 0, 64)
rsp.Sex = Gender(MAN).String()
return err
diff --git a/golang/general/jsonrpc/go-server/app/user_provider2.go b/golang/general/jsonrpc/go-server/app/user_provider2.go
index 7d2fb80..8561338 100755
--- a/golang/general/jsonrpc/go-server/app/user_provider2.go
+++ b/golang/general/jsonrpc/go-server/app/user_provider2.go
@@ -7,6 +7,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
"github.com/apache/dubbo-go/config"
perrors "github.com/pkg/errors"
)
@@ -32,11 +36,11 @@ func (u *UserProvider2) GetUser(ctx context.Context, req []interface{}, rsp *Use
user *User
)
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
@@ -44,7 +48,7 @@ func (u *UserProvider2) GetUser(ctx context.Context, req []interface{}, rsp *Use
func (u *UserProvider2) GetUser0(id string, name string) (User, error) {
var err error
- println("id:%s, name:%s", id, name)
+ gxlog.CInfo("id:%s, name:%s", id, name)
user, err := u.getUser(id)
if err != nil {
return User{}, err
@@ -58,7 +62,7 @@ func (u *UserProvider2) GetUser0(id string, name string) (User, error) {
func (u *UserProvider2) GetUser2(ctx context.Context, req []interface{}, rsp *User) error {
var err error
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp.Id = strconv.FormatFloat(req[0].(float64), 'f', 0, 64)
rsp.Sex = Gender(MAN).String()
return err
@@ -71,13 +75,13 @@ func (u *UserProvider2) GetUser3() error {
func (u *UserProvider2) GetUsers(req []interface{}) ([]User, error) {
var err error
- println("req:%s", req)
+ gxlog.CInfo("req:%s", req)
t := req[0].([]interface{})
user, err := u.getUser(t[0].(string))
if err != nil {
return nil, err
}
- println("user:%v", user)
+ gxlog.CInfo("user:%v", user)
return []User{*user}, err
}
diff --git a/golang/general/jsonrpc/go-server/app/version.go b/golang/general/jsonrpc/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/general/jsonrpc/go-server/app/version.go
+++ b/golang/general/jsonrpc/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/general/rest/go-client/app/client.go b/golang/general/rest/go-client/app/client.go
index 0b02a74..7180b84 100755
--- a/golang/general/rest/go-client/app/client.go
+++ b/golang/general/rest/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
"github.com/apache/dubbo-go/config"
@@ -51,11 +55,11 @@ func main() {
config.Load()
- println("\n\ntest")
+ gxlog.CInfo("\n\ntest")
test()
- println("\n\ntest1")
+ gxlog.CInfo("\n\ntest1")
test1()
- println("\n\ntest2")
+ gxlog.CInfo("\n\ntest2")
test2()
initSignal()
@@ -85,125 +89,121 @@ func initSignal() {
}
}
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
func test() {
- println("\n\n\nstart to test rest")
+ gxlog.CInfo("\n\n\nstart to test rest")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A003"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test rest - GetUser0")
+ gxlog.CInfo("\n\n\nstart to test rest - GetUser0")
ret, err := userProvider.GetUser0("A003", "Moorseä¸æ–‡", 30)
if err != nil {
panic(err)
}
- println("response result: %v", ret)
+ gxlog.CInfo("response result: %v", ret)
- println("\n\n\nstart to test rest - GetUsers")
+ gxlog.CInfo("\n\n\nstart to test rest - GetUsers")
ret1, err := userProvider.GetUsers([]interface{}{&User{ID: "A002"}})
if err != nil {
panic(err)
}
- println("response result: %v", ret1)
+ gxlog.CInfo("response result: %v", ret1)
- println("\n\n\nstart to test rest - GetUser3")
+ gxlog.CInfo("\n\n\nstart to test rest - GetUser3")
err = userProvider.GetUser3()
if err != nil {
panic(err)
}
- println("succ!")
+ gxlog.CInfo("succ!")
- println("\n\n\nstart to test rest illegal method")
+ gxlog.CInfo("\n\n\nstart to test rest illegal method")
err = userProvider.GetUser1(context.TODO(), []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
}
func test1() {
time.Sleep(3e9)
- println("\n\n\nstart to test rest")
+ gxlog.CInfo("\n\n\nstart to test rest")
user := &User{}
err := userProvider1.GetUser(context.TODO(), []interface{}{"A003"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test rest - GetUser0")
+ gxlog.CInfo("\n\n\nstart to test rest - GetUser0")
ret, err := userProvider1.GetUser0("A003", "Moorseä¸æ–‡", 30)
if err != nil {
panic(err)
}
- println("response result: %v", ret)
+ gxlog.CInfo("response result: %v", ret)
- println("\n\n\nstart to test rest - GetUsers")
+ gxlog.CInfo("\n\n\nstart to test rest - GetUsers")
ret1, err := userProvider1.GetUsers([]interface{}{&User{ID: "A002"}})
if err != nil {
panic(err)
}
- println("response result: %v", ret1)
+ gxlog.CInfo("response result: %v", ret1)
- println("\n\n\nstart to test rest - GetUser3")
+ gxlog.CInfo("\n\n\nstart to test rest - GetUser3")
err = userProvider1.GetUser3()
if err != nil {
panic(err)
}
- println("succ!")
+ gxlog.CInfo("succ!")
- println("\n\n\nstart to test rest illegal method")
+ gxlog.CInfo("\n\n\nstart to test rest illegal method")
err = userProvider1.GetUser1(context.TODO(), []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
}
func test2() {
- println("\n\n\nstart to test rest")
+ gxlog.CInfo("\n\n\nstart to test rest")
user := &User{}
err := userProvider2.GetUser(context.TODO(), []interface{}{"A003"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test rest - GetUser0")
+ gxlog.CInfo("\n\n\nstart to test rest - GetUser0")
ret, err := userProvider2.GetUser0("A003", "Moorseä¸æ–‡", 30)
if err != nil {
panic(err)
}
- println("response result: %v", ret)
+ gxlog.CInfo("response result: %v", ret)
- println("\n\n\nstart to test rest - GetUsers")
+ gxlog.CInfo("\n\n\nstart to test rest - GetUsers")
ret1, err := userProvider2.GetUsers([]interface{}{&User{ID: "A002"}})
if err != nil {
panic(err)
}
- println("response result: %v", ret1)
+ gxlog.CInfo("response result: %v", ret1)
- println("\n\n\nstart to test rest - GetUser3")
+ gxlog.CInfo("\n\n\nstart to test rest - GetUser3")
err = userProvider2.GetUser3()
if err != nil {
panic(err)
}
- println("succ!")
+ gxlog.CInfo("succ!")
- println("\n\n\nstart to test rest illegal method")
+ gxlog.CInfo("\n\n\nstart to test rest illegal method")
err = userProvider2.GetUser1(context.TODO(), []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
}
diff --git a/golang/general/rest/go-client/app/version.go b/golang/general/rest/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/general/rest/go-client/app/version.go
+++ b/golang/general/rest/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/general/rest/go-server/app/server.go b/golang/general/rest/go-server/app/server.go
index b98c677..fc92ac5 100755
--- a/golang/general/rest/go-server/app/server.go
+++ b/golang/general/rest/go-server/app/server.go
@@ -26,13 +26,18 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+ "github.com/emicklei/go-restful"
+ "github.com/emicklei/go-restful/v3"
+)
+
+import (
"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/protocol/rest"
"github.com/apache/dubbo-go/protocol/rest/server/server_impl"
_ "github.com/apache/dubbo-go/registry/protocol"
- "github.com/emicklei/go-restful/v3"
_ "github.com/apache/dubbo-go/filter/filter_impl"
@@ -50,11 +55,11 @@ var (
// export APP_LOG_CONF_FILE="xxx"
func main() {
server_impl.AddGoRestfulServerFilter(func(request *restful.Request, response *restful.Response, chain *restful.FilterChain) {
- println(request.SelectedRoutePath())
+ gxlog.CInfo(request.SelectedRoutePath())
chain.ProcessFilter(request, response)
})
server_impl.AddGoRestfulServerFilter(func(request *restful.Request, response *restful.Response, chain *restful.FilterChain) {
- println("filter2")
+ gxlog.CInfo("filter2")
chain.ProcessFilter(request, response)
})
config.Load()
diff --git a/golang/general/rest/go-server/app/user.go b/golang/general/rest/go-server/app/user.go
index 0967f3f..db2a147 100755
--- a/golang/general/rest/go-server/app/user.go
+++ b/golang/general/rest/go-server/app/user.go
@@ -18,7 +18,6 @@
package main
import (
- "fmt"
"time"
)
@@ -72,7 +71,3 @@ func init() {
userMap[k] = v
}
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/general/rest/go-server/app/user_provider.go b/golang/general/rest/go-server/app/user_provider.go
index a53f361..49dab4d 100755
--- a/golang/general/rest/go-server/app/user_provider.go
+++ b/golang/general/rest/go-server/app/user_provider.go
@@ -7,6 +7,7 @@ import (
import (
perrors "github.com/pkg/errors"
+ "github.com/dubbogo/gost/log"
)
import (
@@ -34,11 +35,11 @@ func (u *UserProvider) GetUser(ctx context.Context, req []interface{}, rsp *User
user *User
)
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
@@ -46,7 +47,7 @@ func (u *UserProvider) GetUser(ctx context.Context, req []interface{}, rsp *User
func (u *UserProvider) GetUser0(id string, name string, age int) (*User, error) {
var err error
- println("id:%s, name:%s, age:%d", id, name, age)
+ gxlog.CInfo("id:%s, name:%s, age:%d", id, name, age)
user, err := u.getUser(id)
if err != nil {
return &User{}, err
@@ -67,13 +68,13 @@ func (u *UserProvider) GetUser3() error {
func (u *UserProvider) GetUsers(req []interface{}) ([]User, error) {
var err error
- println("req:%s", req)
+ gxlog.CInfo("req:%s", req)
t := req[0].(map[string]interface{})
user, err := u.getUser(t["ID"].(string))
if err != nil {
return nil, err
}
- println("user:%v", user)
+ gxlog.CInfo("user:%v", user)
return []User{*user}, err
}
diff --git a/golang/general/rest/go-server/app/user_provider1.go b/golang/general/rest/go-server/app/user_provider1.go
index f81b9dd..7b8fba4 100755
--- a/golang/general/rest/go-server/app/user_provider1.go
+++ b/golang/general/rest/go-server/app/user_provider1.go
@@ -7,6 +7,7 @@ import (
import (
perrors "github.com/pkg/errors"
+ "github.com/dubbogo/gost/log"
)
import (
@@ -34,11 +35,11 @@ func (u *UserProvider1) GetUser(ctx context.Context, req []interface{}, rsp *Use
user *User
)
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
@@ -46,7 +47,7 @@ func (u *UserProvider1) GetUser(ctx context.Context, req []interface{}, rsp *Use
func (u *UserProvider1) GetUser0(id string, name string, age int) (User, error) {
var err error
- println("id:%s, name:%s, age:%d", id, name, age)
+ gxlog.CInfo("id:%s, name:%s, age:%d", id, name, age)
user, err := u.getUser(id)
if err != nil {
return User{}, err
diff --git a/golang/general/rest/go-server/app/user_provider2.go b/golang/general/rest/go-server/app/user_provider2.go
index c048acc..45d962b 100755
--- a/golang/general/rest/go-server/app/user_provider2.go
+++ b/golang/general/rest/go-server/app/user_provider2.go
@@ -7,6 +7,7 @@ import (
import (
perrors "github.com/pkg/errors"
+ "github.com/dubbogo/gost/log"
)
import (
@@ -34,11 +35,11 @@ func (u *UserProvider2) GetUser(ctx context.Context, req []interface{}, rsp *Use
user *User
)
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
@@ -46,7 +47,7 @@ func (u *UserProvider2) GetUser(ctx context.Context, req []interface{}, rsp *Use
func (u *UserProvider2) GetUser0(id string, name string, age int) (User, error) {
var err error
- println("id:%s, name:%s, age:%d", id, name, age)
+ gxlog.CInfo("id:%s, name:%s, age:%d", id, name, age)
user, err := u.getUser(id)
if err != nil {
return User{}, err
@@ -67,13 +68,13 @@ func (u *UserProvider2) GetUser3() error {
func (u *UserProvider2) GetUsers(req []interface{}) ([]User, error) {
var err error
- println("req:%s", req)
+ gxlog.CInfo("req:%s", req)
t := req[0].(map[string]interface{})
user, err := u.getUser(t["ID"].(string))
if err != nil {
return nil, err
}
- println("user:%v", user)
+ gxlog.CInfo("user:%v", user)
return []User{*user}, err
}
diff --git a/golang/general/rest/go-server/app/version.go b/golang/general/rest/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/general/rest/go-server/app/version.go
+++ b/golang/general/rest/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/generic/go-client/app/client.go b/golang/generic/go-client/app/client.go
index 2ed8554..342a613 100755
--- a/golang/generic/go-client/app/client.go
+++ b/golang/generic/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
"github.com/apache/dubbo-go/config"
@@ -48,17 +52,13 @@ var (
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
func main() {
- println("\n\ntest")
+ gxlog.CInfo("\n\ntest")
test()
- println("\n\ntest2")
+ gxlog.CInfo("\n\ntest2")
test2()
initSignal()
}
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
func initSignal() {
signals := make(chan os.Signal, 1)
// It is not possible to block SIGKILL or syscall.SIGSTOP
@@ -95,13 +95,13 @@ func test() {
referenceConfig.GenericLoad(appName) //appName is the unique identification of RPCService
time.Sleep(3 * time.Second)
- println("\n\n\nstart to generic invoke")
+ gxlog.CInfo("\n\n\nstart to generic invoke")
resp, err := referenceConfig.GetRPCService().(*config.GenericService).Invoke(context.TODO(), []interface{}{"GetUser", []string{"java.lang.String"}, []interface{}{"A003"}})
if err != nil {
panic(err)
}
- println("res: %+v\n", resp)
- println("succ!")
+ gxlog.CInfo("res: %+v\n", resp)
+ gxlog.CInfo("succ!")
}
func test2() {
@@ -116,7 +116,7 @@ func test2() {
referenceConfig.GenericLoad(appName) //appName is the unique identification of RPCService
time.Sleep(3 * time.Second)
- println("\n\n\nstart to generic invoke")
+ gxlog.CInfo("\n\n\nstart to generic invoke")
user := User{
Id: "3213",
Name: "panty",
@@ -127,7 +127,7 @@ func test2() {
if err != nil {
panic(err)
}
- println("res: %+v\n", resp)
- println("succ!")
+ gxlog.CInfo("res: %+v\n", resp)
+ gxlog.CInfo("succ!")
}
diff --git a/golang/generic/go-server/app/user.go b/golang/generic/go-server/app/user.go
index 411645a..8c26b11 100755
--- a/golang/generic/go-server/app/user.go
+++ b/golang/generic/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,16 +48,16 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, userId string) (*User, error) {
- println("req:%#v", userId)
+ gxlog.CInfo("req:%#v", userId)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
func (u *UserProvider) QueryUser(ctx context.Context, user *User) (*User, error) {
- println("req1:%#v", user)
+ gxlog.CInfo("req1:%#v", user)
rsp := User{user.Id, user.Name, user.Age, time.Now()}
- println("rsp1:%#v", rsp)
+ gxlog.CInfo("rsp1:%#v", rsp)
return &rsp, nil
}
@@ -71,7 +74,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/generic/go-server/app/version.go b/golang/generic/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/generic/go-server/app/version.go
+++ b/golang/generic/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/helloworld/dubbo/go-client/app/client.go b/golang/helloworld/dubbo/go-client/app/client.go
index 28fe7eb..0d0b138 100755
--- a/golang/helloworld/dubbo/go-client/app/client.go
+++ b/golang/helloworld/dubbo/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -45,10 +49,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -57,13 +57,13 @@ func main() {
config.Load()
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
diff --git a/golang/helloworld/dubbo/go-client/app/version.go b/golang/helloworld/dubbo/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/helloworld/dubbo/go-client/app/version.go
+++ b/golang/helloworld/dubbo/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/helloworld/dubbo/go-server/app/user.go b/golang/helloworld/dubbo/go-server/app/user.go
index 6410074..89fa126 100755
--- a/golang/helloworld/dubbo/go-server/app/user.go
+++ b/golang/helloworld/dubbo/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/helloworld/dubbo/go-server/app/version.go b/golang/helloworld/dubbo/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/helloworld/dubbo/go-server/app/version.go
+++ b/golang/helloworld/dubbo/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/metric/dubbo/go-client/app/client.go b/golang/metric/dubbo/go-client/app/client.go
index 5a37afd..501cd8b 100755
--- a/golang/metric/dubbo/go-client/app/client.go
+++ b/golang/metric/dubbo/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -45,10 +49,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -56,13 +56,13 @@ func main() {
hessian.RegisterPOJO(&User{})
config.Load()
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.Background(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
diff --git a/golang/metric/dubbo/go-client/app/version.go b/golang/metric/dubbo/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/metric/dubbo/go-client/app/version.go
+++ b/golang/metric/dubbo/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/metric/dubbo/go-server/app/user.go b/golang/metric/dubbo/go-server/app/user.go
index b729ded..ed7e6b7 100755
--- a/golang/metric/dubbo/go-server/app/user.go
+++ b/golang/metric/dubbo/go-server/app/user.go
@@ -19,9 +19,11 @@ package main
import (
"context"
- "fmt"
"time"
+)
+import (
+ "github.com/dubbogo/gost/log"
"github.com/opentracing/opentracing-go"
)
@@ -47,12 +49,12 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
span, ctx := opentracing.StartSpanFromContext(ctx, "User-Server-Span")
time.Sleep(100 * time.Millisecond)
span.Finish()
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -63,7 +65,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/metric/dubbo/go-server/app/version.go b/golang/metric/dubbo/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/metric/dubbo/go-server/app/version.go
+++ b/golang/metric/dubbo/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/multi_registry/dubbo/go-client/app/client.go b/golang/multi_registry/dubbo/go-client/app/client.go
index 28fe7eb..0d0b138 100755
--- a/golang/multi_registry/dubbo/go-client/app/client.go
+++ b/golang/multi_registry/dubbo/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -45,10 +49,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -57,13 +57,13 @@ func main() {
config.Load()
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
diff --git a/golang/multi_registry/dubbo/go-client/app/version.go b/golang/multi_registry/dubbo/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/multi_registry/dubbo/go-client/app/version.go
+++ b/golang/multi_registry/dubbo/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/multi_registry/dubbo/go-server/app/user.go b/golang/multi_registry/dubbo/go-server/app/user.go
index 6410074..89fa126 100755
--- a/golang/multi_registry/dubbo/go-server/app/user.go
+++ b/golang/multi_registry/dubbo/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/multi_registry/dubbo/go-server/app/version.go b/golang/multi_registry/dubbo/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/multi_registry/dubbo/go-server/app/version.go
+++ b/golang/multi_registry/dubbo/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/multi_registry/zone/dubbo/go-client/app/client.go b/golang/multi_registry/zone/dubbo/go-client/app/client.go
index bad335c..39df5ae 100755
--- a/golang/multi_registry/zone/dubbo/go-client/app/client.go
+++ b/golang/multi_registry/zone/dubbo/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/constant"
"github.com/apache/dubbo-go/common/logger"
@@ -47,10 +51,6 @@ var (
survivalTimeout int = 60 * 1000
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -59,7 +59,7 @@ func main() {
config.Load()
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
// context zone hangzhou,
ctx := context.Background()
@@ -80,10 +80,10 @@ func main() {
if "dev-sh" == user.Id {
sh++
}
- println("response %d result: %v\n", i, user)
+ gxlog.CInfo("response %d result: %v\n", i, user)
}
- println("loop count : %d, hangzhou count : %d, shanghai count : %d", loop,
+ gxlog.CInfo("loop count : %d, hangzhou count : %d, shanghai count : %d", loop,
hz, sh)
initSignal()
diff --git a/golang/multi_registry/zone/dubbo/go-client/app/version.go b/golang/multi_registry/zone/dubbo/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/multi_registry/zone/dubbo/go-client/app/version.go
+++ b/golang/multi_registry/zone/dubbo/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/multi_registry/zone/dubbo/go-server/app/user.go b/golang/multi_registry/zone/dubbo/go-server/app/user.go
index 9ac7904..5c476a6 100755
--- a/golang/multi_registry/zone/dubbo/go-server/app/user.go
+++ b/golang/multi_registry/zone/dubbo/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,10 +48,10 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
env := config.GetProviderConfig().ApplicationConfig.Environment
rsp := User{env, "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -59,7 +62,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/multi_registry/zone/dubbo/go-server/app/version.go b/golang/multi_registry/zone/dubbo/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/multi_registry/zone/dubbo/go-server/app/version.go
+++ b/golang/multi_registry/zone/dubbo/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/registry/etcd/go-client/app/client.go b/golang/registry/etcd/go-client/app/client.go
index e2fc934..df52b1f 100644
--- a/golang/registry/etcd/go-client/app/client.go
+++ b/golang/registry/etcd/go-client/app/client.go
@@ -10,6 +10,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -30,10 +34,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -42,13 +42,13 @@ func main() {
config.Load()
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
diff --git a/golang/registry/etcd/go-client/app/version.go b/golang/registry/etcd/go-client/app/version.go
index 60c1a81..2ecc5fa 100644
--- a/golang/registry/etcd/go-client/app/version.go
+++ b/golang/registry/etcd/go-client/app/version.go
@@ -1,5 +1,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/registry/etcd/go-server/app/user.go b/golang/registry/etcd/go-server/app/user.go
index e094dbc..d146aa0 100644
--- a/golang/registry/etcd/go-server/app/user.go
+++ b/golang/registry/etcd/go-server/app/user.go
@@ -2,11 +2,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -28,9 +31,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -41,7 +44,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/registry/etcd/go-server/app/version.go b/golang/registry/etcd/go-server/app/version.go
index 60c1a81..2ecc5fa 100644
--- a/golang/registry/etcd/go-server/app/version.go
+++ b/golang/registry/etcd/go-server/app/version.go
@@ -1,5 +1,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/registry/nacos/dubbo/go-client/app/client.go b/golang/registry/nacos/dubbo/go-client/app/client.go
index 4c03212..6e9f876 100755
--- a/golang/registry/nacos/dubbo/go-client/app/client.go
+++ b/golang/registry/nacos/dubbo/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -45,10 +49,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -57,13 +57,13 @@ func main() {
config.Load()
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
diff --git a/golang/registry/nacos/dubbo/go-client/app/version.go b/golang/registry/nacos/dubbo/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/registry/nacos/dubbo/go-client/app/version.go
+++ b/golang/registry/nacos/dubbo/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/registry/nacos/dubbo/go-server/app/user.go b/golang/registry/nacos/dubbo/go-server/app/user.go
index 6410074..89fa126 100755
--- a/golang/registry/nacos/dubbo/go-server/app/user.go
+++ b/golang/registry/nacos/dubbo/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/registry/nacos/dubbo/go-server/app/version.go b/golang/registry/nacos/dubbo/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/registry/nacos/dubbo/go-server/app/version.go
+++ b/golang/registry/nacos/dubbo/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/registry/servicediscovery/etcd/go-client/app/client.go b/golang/registry/servicediscovery/etcd/go-client/app/client.go
index 6507bbd..2a10525 100755
--- a/golang/registry/servicediscovery/etcd/go-client/app/client.go
+++ b/golang/registry/servicediscovery/etcd/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
@@ -51,10 +55,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -63,14 +63,14 @@ func main() {
config.Load()
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
for i := 0; i < 5; i++ {
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
}
initSignal()
}
diff --git a/golang/registry/servicediscovery/etcd/go-client/app/version.go b/golang/registry/servicediscovery/etcd/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/registry/servicediscovery/etcd/go-client/app/version.go
+++ b/golang/registry/servicediscovery/etcd/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/registry/servicediscovery/etcd/go-server/app/server.go b/golang/registry/servicediscovery/etcd/go-server/app/server.go
index 6a61ba8..139ba3a 100755
--- a/golang/registry/servicediscovery/etcd/go-server/app/server.go
+++ b/golang/registry/servicediscovery/etcd/go-server/app/server.go
@@ -27,7 +27,9 @@ import (
import (
hessian "github.com/apache/dubbo-go-hessian2"
+)
+import (
"github.com/apache/dubbo-go/common/logger"
"github.com/apache/dubbo-go/config"
_ "github.com/apache/dubbo-go/protocol/dubbo"
diff --git a/golang/registry/servicediscovery/etcd/go-server/app/user.go b/golang/registry/servicediscovery/etcd/go-server/app/user.go
index 6410074..89fa126 100755
--- a/golang/registry/servicediscovery/etcd/go-server/app/user.go
+++ b/golang/registry/servicediscovery/etcd/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/registry/servicediscovery/etcd/go-server/app/version.go b/golang/registry/servicediscovery/etcd/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/registry/servicediscovery/etcd/go-server/app/version.go
+++ b/golang/registry/servicediscovery/etcd/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/registry/servicediscovery/nacos/go-client/app/client.go b/golang/registry/servicediscovery/nacos/go-client/app/client.go
index 17700fc..a7af777 100755
--- a/golang/registry/servicediscovery/nacos/go-client/app/client.go
+++ b/golang/registry/servicediscovery/nacos/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
@@ -54,10 +58,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -66,14 +66,14 @@ func main() {
config.Load()
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
for i := 0; i < 5; i++ {
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
}
initSignal()
}
diff --git a/golang/registry/servicediscovery/nacos/go-client/app/version.go b/golang/registry/servicediscovery/nacos/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/registry/servicediscovery/nacos/go-client/app/version.go
+++ b/golang/registry/servicediscovery/nacos/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/registry/servicediscovery/nacos/go-server/app/user.go b/golang/registry/servicediscovery/nacos/go-server/app/user.go
index 6410074..89fa126 100755
--- a/golang/registry/servicediscovery/nacos/go-server/app/user.go
+++ b/golang/registry/servicediscovery/nacos/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/registry/servicediscovery/nacos/go-server/app/version.go b/golang/registry/servicediscovery/nacos/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/registry/servicediscovery/nacos/go-server/app/version.go
+++ b/golang/registry/servicediscovery/nacos/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/registry/servicediscovery/zookeeper/go-client/app/client.go b/golang/registry/servicediscovery/zookeeper/go-client/app/client.go
index e4f5359..a2c0662 100755
--- a/golang/registry/servicediscovery/zookeeper/go-client/app/client.go
+++ b/golang/registry/servicediscovery/zookeeper/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
@@ -51,10 +55,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -63,14 +63,14 @@ func main() {
config.Load()
time.Sleep(3e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
for i := 0; i < 5; i++ {
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
}
initSignal()
}
diff --git a/golang/registry/servicediscovery/zookeeper/go-client/app/version.go b/golang/registry/servicediscovery/zookeeper/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/registry/servicediscovery/zookeeper/go-client/app/version.go
+++ b/golang/registry/servicediscovery/zookeeper/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/registry/servicediscovery/zookeeper/go-server/app/user.go b/golang/registry/servicediscovery/zookeeper/go-server/app/user.go
index 6410074..89fa126 100755
--- a/golang/registry/servicediscovery/zookeeper/go-server/app/user.go
+++ b/golang/registry/servicediscovery/zookeeper/go-server/app/user.go
@@ -19,11 +19,14 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/registry/servicediscovery/zookeeper/go-server/app/version.go b/golang/registry/servicediscovery/zookeeper/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/registry/servicediscovery/zookeeper/go-server/app/version.go
+++ b/golang/registry/servicediscovery/zookeeper/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/router/condition/go-client/app/client.go b/golang/router/condition/go-client/app/client.go
index 706e348..672fbeb 100644
--- a/golang/router/condition/go-client/app/client.go
+++ b/golang/router/condition/go-client/app/client.go
@@ -27,6 +27,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
@@ -47,10 +51,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -60,13 +60,13 @@ func main() {
config.Load()
time.Sleep(1e9)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
err := userProvider.GetUser(context.TODO(), []interface{}{"A001"}, user)
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
diff --git a/golang/router/condition/go-server/app/server.go b/golang/router/condition/go-server/app/server.go
index 3cae749..358241d 100644
--- a/golang/router/condition/go-server/app/server.go
+++ b/golang/router/condition/go-server/app/server.go
@@ -27,6 +27,9 @@ import (
import (
hessian "github.com/apache/dubbo-go-hessian2"
+)
+
+import (
_ "github.com/apache/dubbo-go/cluster/cluster_impl"
_ "github.com/apache/dubbo-go/cluster/loadbalance"
"github.com/apache/dubbo-go/common/logger"
diff --git a/golang/router/condition/go-server/app/user.go b/golang/router/condition/go-server/app/user.go
index 6410074..056b28d 100644
--- a/golang/router/condition/go-server/app/user.go
+++ b/golang/router/condition/go-server/app/user.go
@@ -19,12 +19,15 @@ package main
import (
"context"
- "fmt"
"time"
)
import (
+ "github.com/dubbogo/gost/log"
hessian "github.com/apache/dubbo-go-hessian2"
+)
+
+import (
"github.com/apache/dubbo-go/config"
)
@@ -45,9 +48,9 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -58,7 +61,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/router/condition/go-server/app/version.go b/golang/router/condition/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/router/condition/go-server/app/version.go
+++ b/golang/router/condition/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/seata/client/app/version.go b/golang/seata/client/app/version.go
index c613858..ae51f45 100644
--- a/golang/seata/client/app/version.go
+++ b/golang/seata/client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/seata/order-svc/app/version.go b/golang/seata/order-svc/app/version.go
index c613858..ae51f45 100644
--- a/golang/seata/order-svc/app/version.go
+++ b/golang/seata/order-svc/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/seata/product-svc/app/version.go b/golang/seata/product-svc/app/version.go
index c613858..ae51f45 100644
--- a/golang/seata/product-svc/app/version.go
+++ b/golang/seata/product-svc/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/tracing/dubbo/go-client/app/client.go b/golang/tracing/dubbo/go-client/app/client.go
index f714935..7d75d49 100755
--- a/golang/tracing/dubbo/go-client/app/client.go
+++ b/golang/tracing/dubbo/go-client/app/client.go
@@ -24,15 +24,18 @@ import (
"os/signal"
"syscall"
"time"
+)
+import (
+ "github.com/dubbogo/gost/log"
"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"
+ hessian "github.com/apache/dubbo-go-hessian2"
)
import (
- hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
_ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
"github.com/apache/dubbo-go/config"
@@ -50,10 +53,6 @@ var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
// export APP_LOG_CONF_FILE="xxx"
@@ -62,7 +61,7 @@ func main() {
config.Load()
initZipkin()
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
user := &User{}
span, ctx := opentracing.StartSpanFromContext(context.Background(), "Test-Client-Service")
err := userProvider.GetUser(ctx, []interface{}{"A001"}, user)
@@ -70,7 +69,7 @@ func main() {
if err != nil {
panic(err)
}
- println("response result: %v\n", user)
+ gxlog.CInfo("response result: %v\n", user)
initSignal()
}
diff --git a/golang/tracing/dubbo/go-client/app/user.go b/golang/tracing/dubbo/go-client/app/user.go
index ff4486f..8158eed 100755
--- a/golang/tracing/dubbo/go-client/app/user.go
+++ b/golang/tracing/dubbo/go-client/app/user.go
@@ -27,7 +27,9 @@ import (
"github.com/apache/dubbo-go/config"
)
-var userProvider = new(UserProvider)
+var (
+ userProvider = &UserProvider{}
+)
func init() {
config.SetConsumerService(userProvider)
diff --git a/golang/tracing/dubbo/go-client/app/version.go b/golang/tracing/dubbo/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/tracing/dubbo/go-client/app/version.go
+++ b/golang/tracing/dubbo/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/tracing/dubbo/go-server/app/server.go b/golang/tracing/dubbo/go-server/app/server.go
index f2aabd0..7e5a945 100755
--- a/golang/tracing/dubbo/go-server/app/server.go
+++ b/golang/tracing/dubbo/go-server/app/server.go
@@ -23,15 +23,17 @@ import (
"os/signal"
"syscall"
"time"
+)
+import (
"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"
+ hessian "github.com/apache/dubbo-go-hessian2"
)
import (
- hessian "github.com/apache/dubbo-go-hessian2"
"github.com/apache/dubbo-go/common/logger"
"github.com/apache/dubbo-go/config"
_ "github.com/apache/dubbo-go/protocol/dubbo"
diff --git a/golang/tracing/dubbo/go-server/app/user.go b/golang/tracing/dubbo/go-server/app/user.go
index b729ded..ed7e6b7 100755
--- a/golang/tracing/dubbo/go-server/app/user.go
+++ b/golang/tracing/dubbo/go-server/app/user.go
@@ -19,9 +19,11 @@ package main
import (
"context"
- "fmt"
"time"
+)
+import (
+ "github.com/dubbogo/gost/log"
"github.com/opentracing/opentracing-go"
)
@@ -47,12 +49,12 @@ type UserProvider struct {
}
func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp := User{"A001", "Alex Stocks", 18, time.Now()}
span, ctx := opentracing.StartSpanFromContext(ctx, "User-Server-Span")
time.Sleep(100 * time.Millisecond)
span.Finish()
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
return &rsp, nil
}
@@ -63,7 +65,3 @@ func (u *UserProvider) Reference() string {
func (u User) JavaClassName() string {
return "com.ikurento.user.User"
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/tracing/dubbo/go-server/app/version.go b/golang/tracing/dubbo/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/tracing/dubbo/go-server/app/version.go
+++ b/golang/tracing/dubbo/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/tracing/grpc/go-client/app/client.go b/golang/tracing/grpc/go-client/app/client.go
index 0135cb0..48df757 100644
--- a/golang/tracing/grpc/go-client/app/client.go
+++ b/golang/tracing/grpc/go-client/app/client.go
@@ -27,6 +27,12 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+ opentracing "github.com/opentracing/opentracing-go"
+ jaegercfg "github.com/uber/jaeger-client-go/config"
+)
+
+import (
_ "github.com/apache/dubbo-go/cluster/cluster_impl"
_ "github.com/apache/dubbo-go/cluster/loadbalance"
"github.com/apache/dubbo-go/common/logger"
@@ -37,18 +43,12 @@ import (
_ "github.com/apache/dubbo-go/protocol/grpc"
_ "github.com/apache/dubbo-go/registry/protocol"
_ "github.com/apache/dubbo-go/registry/zookeeper"
-
- opentracing "github.com/opentracing/opentracing-go"
- jaegercfg "github.com/uber/jaeger-client-go/config"
)
var (
survivalTimeout int = 10e9
)
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
// they are necessary:
// export CONF_CONSUMER_FILE_PATH="xxx"
@@ -70,7 +70,7 @@ func main() {
config.Load()
time.Sleep(time.Second)
- println("\n\n\nstart to test dubbo")
+ gxlog.CInfo("\n\n\nstart to test dubbo")
reply := &HelloReply{}
req := &HelloRequest{
Name: "xujianhai",
@@ -79,7 +79,7 @@ func main() {
if err != nil {
panic(err)
}
- println("client response result: %v\n", reply)
+ gxlog.CInfo("client response result: %v\n", reply)
initSignal()
}
diff --git a/golang/tracing/grpc/go-client/app/version.go b/golang/tracing/grpc/go-client/app/version.go
index c613858..ae51f45 100644
--- a/golang/tracing/grpc/go-client/app/version.go
+++ b/golang/tracing/grpc/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/tracing/grpc/go-server/app/version.go b/golang/tracing/grpc/go-server/app/version.go
index c613858..ae51f45 100644
--- a/golang/tracing/grpc/go-server/app/version.go
+++ b/golang/tracing/grpc/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/tracing/jsonrpc/go-client/app/client.go b/golang/tracing/jsonrpc/go-client/app/client.go
index 2839875..4974ec5 100755
--- a/golang/tracing/jsonrpc/go-client/app/client.go
+++ b/golang/tracing/jsonrpc/go-client/app/client.go
@@ -24,7 +24,10 @@ import (
"os/signal"
"syscall"
"time"
+)
+import (
+ "github.com/dubbogo/gost/log"
"github.com/opentracing/opentracing-go"
zipkinot "github.com/openzipkin-contrib/zipkin-go-opentracing"
"github.com/openzipkin/zipkin-go"
@@ -57,7 +60,7 @@ func main() {
config.Load()
initZipkin()
- println("\n\n\nstart to test jsonrpc")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc")
user := &JsonRPCUser{}
ctx := context.WithValue(context.Background(), "MyTracing", "Tracing123")
span, spanCtx := opentracing.StartSpanFromContext(ctx, "User-Test-Service")
@@ -66,7 +69,7 @@ func main() {
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
initSignal()
}
@@ -118,169 +121,165 @@ func initSignal() {
}
}
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
-
func test() {
- println("\n\n\necho")
+ gxlog.CInfo("\n\n\necho")
res, err := userProvider.Echo(context.TODO(), "OK")
if err != nil {
- println("echo - error: %v", err)
+ gxlog.CInfo("echo - error: %v", err)
} else {
- println("res: %v", res)
+ gxlog.CInfo("res: %v", res)
}
time.Sleep(3e9)
ctx := context.WithValue(context.Background(), "TracingID", "Tracing123")
- println("\n\n\nstart to test jsonrpc - GetUser0")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUser0")
ret, err := userProvider.GetUser0("A003", "Moorse")
if err != nil {
panic(err)
}
- println("response result: %v", ret)
+ gxlog.CInfo("response result: %v", ret)
- println("\n\n\nstart to test jsonrpc - GetUsers")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUsers")
ret1, err := userProvider.GetUsers([]interface{}{[]interface{}{"A002", "A003"}})
if err != nil {
panic(err)
}
- println("response result: %v", ret1)
+ gxlog.CInfo("response result: %v", ret1)
- println("\n\n\nstart to test jsonrpc - getUser")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - getUser")
user := &JsonRPCUser{}
err = userProvider.GetUser2(ctx, []interface{}{1}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test jsonrpc - GetUser3")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUser3")
err = userProvider.GetUser3()
if err != nil {
panic(err)
}
- println("succ!")
+ gxlog.CInfo("succ!")
- println("\n\n\nstart to test jsonrpc illegal method")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc illegal method")
err = userProvider.GetUser1(ctx, []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
}
func test1() {
ctx := context.WithValue(context.Background(), "TracingID", "Tracing123")
- println("\n\n\necho")
+ gxlog.CInfo("\n\n\necho")
res, err := userProvider1.Echo(ctx, "OK")
if err != nil {
- println("echo - error: %v", err)
+ gxlog.CInfo("echo - error: %v", err)
} else {
- println("res: %v", res)
+ gxlog.CInfo("res: %v", res)
}
time.Sleep(3e9)
- println("\n\n\nstart to test jsonrpc")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc")
user := &JsonRPCUser{}
err = userProvider1.GetUser(ctx, []interface{}{"A003"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test jsonrpc - GetUser0")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUser0")
ret, err := userProvider1.GetUser0("A003", "Moorse")
if err != nil {
panic(err)
}
- println("response result: %v", ret)
+ gxlog.CInfo("response result: %v", ret)
- println("\n\n\nstart to test jsonrpc - GetUsers")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUsers")
ret1, err := userProvider1.GetUsers([]interface{}{[]interface{}{"A002", "A003"}})
if err != nil {
panic(err)
}
- println("response result: %v", ret1)
+ gxlog.CInfo("response result: %v", ret1)
- println("\n\n\nstart to test jsonrpc - getUser")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - getUser")
user = &JsonRPCUser{}
err = userProvider1.GetUser2(ctx, []interface{}{1}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test jsonrpc - GetUser3")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUser3")
err = userProvider1.GetUser3()
if err != nil {
panic(err)
}
- println("succ!")
+ gxlog.CInfo("succ!")
- println("\n\n\nstart to test jsonrpc illegal method")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc illegal method")
err = userProvider1.GetUser1(ctx, []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
}
func test2() {
ctx := context.WithValue(context.Background(), "TracingID", "Tracing123")
- println("\n\n\necho")
+ gxlog.CInfo("\n\n\necho")
res, err := userProvider2.Echo(ctx, "OK")
if err != nil {
- println("echo - error: %v", err)
+ gxlog.CInfo("echo - error: %v", err)
} else {
- println("res: %v", res)
+ gxlog.CInfo("res: %v", res)
}
time.Sleep(3e9)
- println("\n\n\nstart to test jsonrpc")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc")
user := &JsonRPCUser{}
err = userProvider2.GetUser(ctx, []interface{}{"A003"}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test jsonrpc - GetUser0")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUser0")
ret, err := userProvider2.GetUser0("A003", "Moorse")
if err != nil {
panic(err)
}
- println("response result: %v", ret)
+ gxlog.CInfo("response result: %v", ret)
- println("\n\n\nstart to test jsonrpc - GetUsers")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUsers")
ret1, err := userProvider2.GetUsers([]interface{}{[]interface{}{"A002", "A003"}})
if err != nil {
panic(err)
}
- println("response result: %v", ret1)
+ gxlog.CInfo("response result: %v", ret1)
- println("\n\n\nstart to test jsonrpc - getUser")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - getUser")
user = &JsonRPCUser{}
err = userProvider2.GetUser2(ctx, []interface{}{1}, user)
if err != nil {
panic(err)
}
- println("response result: %v", user)
+ gxlog.CInfo("response result: %v", user)
- println("\n\n\nstart to test jsonrpc - GetUser3")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc - GetUser3")
err = userProvider2.GetUser3()
if err != nil {
panic(err)
}
- println("succ!")
+ gxlog.CInfo("succ!")
- println("\n\n\nstart to test jsonrpc illegal method")
+ gxlog.CInfo("\n\n\nstart to test jsonrpc illegal method")
err = userProvider2.GetUser1(ctx, []interface{}{"A003"}, user)
if err == nil {
panic("err is nil")
}
- println("error: %v", err)
+ gxlog.CInfo("error: %v", err)
}
diff --git a/golang/tracing/jsonrpc/go-client/app/version.go b/golang/tracing/jsonrpc/go-client/app/version.go
index c613858..ae51f45 100755
--- a/golang/tracing/jsonrpc/go-client/app/version.go
+++ b/golang/tracing/jsonrpc/go-client/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
diff --git a/golang/tracing/jsonrpc/go-server/app/server.go b/golang/tracing/jsonrpc/go-server/app/server.go
index 6f32757..90f6042 100755
--- a/golang/tracing/jsonrpc/go-server/app/server.go
+++ b/golang/tracing/jsonrpc/go-server/app/server.go
@@ -23,7 +23,9 @@ import (
"os/signal"
"syscall"
"time"
+)
+import (
"github.com/opentracing/opentracing-go"
zipkinot "github.com/openzipkin-contrib/zipkin-go-opentracing"
"github.com/openzipkin/zipkin-go"
diff --git a/golang/tracing/jsonrpc/go-server/app/user.go b/golang/tracing/jsonrpc/go-server/app/user.go
index 8376610..e1df07a 100755
--- a/golang/tracing/jsonrpc/go-server/app/user.go
+++ b/golang/tracing/jsonrpc/go-server/app/user.go
@@ -18,7 +18,6 @@
package main
import (
- "fmt"
"time"
)
@@ -72,7 +71,3 @@ func init() {
userMap[k] = v
}
}
-
-func println(format string, args ...interface{}) {
- fmt.Printf("\033[32;40m"+format+"\033[0m\n", args...)
-}
diff --git a/golang/tracing/jsonrpc/go-server/app/user_provider.go b/golang/tracing/jsonrpc/go-server/app/user_provider.go
index 1983dc1..95d3256 100755
--- a/golang/tracing/jsonrpc/go-server/app/user_provider.go
+++ b/golang/tracing/jsonrpc/go-server/app/user_provider.go
@@ -5,7 +5,10 @@ import (
"fmt"
"strconv"
"time"
+)
+import (
+ "github.com/dubbogo/gost/log"
"github.com/opentracing/opentracing-go"
)
@@ -36,20 +39,20 @@ func (u *UserProvider) GetUser(ctx context.Context, req []interface{}, rsp *User
)
if ctx == nil {
- println("ctx is nil %v")
+ gxlog.CInfo("ctx is nil %v")
ctx = context.Background()
}
span, _ := opentracing.StartSpanFromContext(ctx, "User-Provider-non")
defer span.Finish()
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
if ctx != nil {
- println("tracing Id: %v", ctx.Value("TracingId"))
+ gxlog.CInfo("tracing Id: %v", ctx.Value("TracingId"))
}
time.Sleep(10 * time.Millisecond)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
@@ -57,7 +60,7 @@ func (u *UserProvider) GetUser(ctx context.Context, req []interface{}, rsp *User
func (u *UserProvider) GetUser0(id string, name string) (User, error) {
var err error
- println("id:%s, name:%s", id, name)
+ gxlog.CInfo("id:%s, name:%s", id, name)
user, err := u.getUser(id)
if err != nil {
return User{}, err
@@ -71,7 +74,7 @@ func (u *UserProvider) GetUser0(id string, name string) (User, error) {
func (u *UserProvider) GetUser2(ctx context.Context, req []interface{}, rsp *User) error {
var err error
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp.Id = strconv.FormatFloat(req[0].(float64), 'f', 0, 64)
rsp.Sex = Gender(MAN).String()
return err
@@ -84,18 +87,18 @@ func (u *UserProvider) GetUser3() error {
func (u *UserProvider) GetUsers(req []interface{}) ([]User, error) {
var err error
- println("req:%s", req)
+ gxlog.CInfo("req:%s", req)
t := req[0].([]interface{})
user, err := u.getUser(t[0].(string))
if err != nil {
return nil, err
}
- println("user:%v", user)
+ gxlog.CInfo("user:%v", user)
user1, err := u.getUser(t[1].(string))
if err != nil {
return nil, err
}
- println("user1:%v", user1)
+ gxlog.CInfo("user1:%v", user1)
return []User{*user, *user1}, err
}
diff --git a/golang/tracing/jsonrpc/go-server/app/user_provider1.go b/golang/tracing/jsonrpc/go-server/app/user_provider1.go
index 1557c6b..fa591a3 100755
--- a/golang/tracing/jsonrpc/go-server/app/user_provider1.go
+++ b/golang/tracing/jsonrpc/go-server/app/user_provider1.go
@@ -7,6 +7,10 @@ import (
)
import (
+ "github.com/dubbogo/gost/log"
+)
+
+import (
"github.com/apache/dubbo-go/config"
perrors "github.com/pkg/errors"
)
@@ -32,11 +36,11 @@ func (u *UserProvider1) GetUser(ctx context.Context, req []interface{}, rsp *Use
user *User
)
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
@@ -44,7 +48,7 @@ func (u *UserProvider1) GetUser(ctx context.Context, req []interface{}, rsp *Use
func (u *UserProvider1) GetUser0(id string, name string) (User, error) {
var err error
- println("id:%s, name:%s", id, name)
+ gxlog.CInfo("id:%s, name:%s", id, name)
user, err := u.getUser(id)
if err != nil {
return User{}, err
@@ -58,7 +62,7 @@ func (u *UserProvider1) GetUser0(id string, name string) (User, error) {
func (u *UserProvider1) GetUser2(ctx context.Context, req []interface{}, rsp *User) error {
var err error
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp.Id = strconv.FormatFloat(req[0].(float64), 'f', 0, 64)
rsp.Sex = Gender(MAN).String()
return err
diff --git a/golang/tracing/jsonrpc/go-server/app/user_provider2.go b/golang/tracing/jsonrpc/go-server/app/user_provider2.go
index 7d2fb80..64e0855 100755
--- a/golang/tracing/jsonrpc/go-server/app/user_provider2.go
+++ b/golang/tracing/jsonrpc/go-server/app/user_provider2.go
@@ -7,10 +7,14 @@ import (
)
import (
- "github.com/apache/dubbo-go/config"
+ "github.com/dubbogo/gost/log"
perrors "github.com/pkg/errors"
)
+import (
+ "github.com/apache/dubbo-go/config"
+)
+
func init() {
config.SetProviderService(new(UserProvider2))
}
@@ -32,11 +36,11 @@ func (u *UserProvider2) GetUser(ctx context.Context, req []interface{}, rsp *Use
user *User
)
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
- println("rsp:%#v", rsp)
+ gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
@@ -44,7 +48,7 @@ func (u *UserProvider2) GetUser(ctx context.Context, req []interface{}, rsp *Use
func (u *UserProvider2) GetUser0(id string, name string) (User, error) {
var err error
- println("id:%s, name:%s", id, name)
+ gxlog.CInfo("id:%s, name:%s", id, name)
user, err := u.getUser(id)
if err != nil {
return User{}, err
@@ -58,7 +62,7 @@ func (u *UserProvider2) GetUser0(id string, name string) (User, error) {
func (u *UserProvider2) GetUser2(ctx context.Context, req []interface{}, rsp *User) error {
var err error
- println("req:%#v", req)
+ gxlog.CInfo("req:%#v", req)
rsp.Id = strconv.FormatFloat(req[0].(float64), 'f', 0, 64)
rsp.Sex = Gender(MAN).String()
return err
@@ -71,13 +75,13 @@ func (u *UserProvider2) GetUser3() error {
func (u *UserProvider2) GetUsers(req []interface{}) ([]User, error) {
var err error
- println("req:%s", req)
+ gxlog.CInfo("req:%s", req)
t := req[0].([]interface{})
user, err := u.getUser(t[0].(string))
if err != nil {
return nil, err
}
- println("user:%v", user)
+ gxlog.CInfo("user:%v", user)
return []User{*user}, err
}
diff --git a/golang/tracing/jsonrpc/go-server/app/version.go b/golang/tracing/jsonrpc/go-server/app/version.go
index c613858..ae51f45 100755
--- a/golang/tracing/jsonrpc/go-server/app/version.go
+++ b/golang/tracing/jsonrpc/go-server/app/version.go
@@ -18,5 +18,5 @@
package main
var (
- Version = "2.6.0"
+ Version = "2.7.5"
)
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@dubbo.apache.org
For additional commands, e-mail: notifications-help@dubbo.apache.org