代码拉取完成,页面将自动刷新
go get -u github.com/SkyAMP/go2sky-plugins/dubbo-go
Server:
import (
_ "dubbo.apache.org/dubbo-go/v3/cluster/cluster_impl"
_ "dubbo.apache.org/dubbo-go/v3/cluster/loadbalance"
"dubbo.apache.org/dubbo-go/v3/common/logger"
_ "dubbo.apache.org/dubbo-go/v3/common/proxy/proxy_factory"
"dubbo.apache.org/dubbo-go/v3/config"
_ "dubbo.apache.org/dubbo-go/v3/filter/filter_impl"
_ "dubbo.apache.org/dubbo-go/v3/protocol/dubbo"
_ "dubbo.apache.org/dubbo-go/v3/registry/protocol"
_ "dubbo.apache.org/dubbo-go/v3/registry/zookeeper"
"github.com/SkyAPM/go2sky"
"github.com/SkyAPM/go2sky/reporter"
hessian "github.com/apache/dubbo-go-hessian2"
dubbo_go "github.com/SkyAPM/go2sky-plugins/dubbo-go"
"github.com/SkyAPM/go2sky-plugins/dubbo-go/test/server/pkg"
)
// set dubbogo configs ...
// setup reporter, use gRPC reporter for production
report, err := reporter.NewLogReporter()
if err != nil {
log.Fatalf("new reporter error: %v \n", err)
}
// setup tracer
tracer, err := go2sky.NewTracer(serviceName, go2sky.WithReporter(report))
if err != nil {
log.Fatalf("crate tracer error: %v \n", err)
}
// set dubbogo plugin server tracer
err = dubbo_go.SetServerTracer(tracer)
if err != nil {
log.Fatalf("set tracer error: %v \n", err)
}
// set extra tags and report tags
dubbo_go.SetServerExtraTags("extra-tags", "server")
dubbo_go.SetServerReportTags("release")
Client:
import (
_ "dubbo.apache.org/dubbo-go/v3/cluster/cluster_impl"
_ "dubbo.apache.org/dubbo-go/v3/cluster/loadbalance"
_ "dubbo.apache.org/dubbo-go/v3/common/proxy/proxy_factory"
"dubbo.apache.org/dubbo-go/v3/config"
_ "dubbo.apache.org/dubbo-go/v3/filter/filter_impl"
_ "dubbo.apache.org/dubbo-go/v3/protocol/dubbo"
_ "dubbo.apache.org/dubbo-go/v3/registry/protocol"
_ "dubbo.apache.org/dubbo-go/v3/registry/zookeeper"
"github.com/SkyAPM/go2sky"
"github.com/SkyAPM/go2sky/reporter"
hessian "github.com/apache/dubbo-go-hessian2"
dubbo_go "github.com/SkyAPM/go2sky-plugins/dubbo-go"
"github.com/SkyAPM/go2sky-plugins/dubbo-go/test/client/pkg"
)
// set dubbogo configs ...
// setup reporter, use gRPC reporter for production
report, err := reporter.NewLogReporter()
if err != nil {
log.Fatalf("new reporter error: %v \n", err)
}
// setup tracer
tracer, err := go2sky.NewTracer(serviceName, go2sky.WithReporter(report))
if err != nil {
log.Fatalf("crate tracer error: %v \n", err)
}
// set dubbogo plugin client tracer
err = dubbo_go.SetClientTracer(tracer)
if err != nil {
log.Fatalf("set tracer error: %v \n", err)
}
// set extra tags and report tags
dubbo_go.SetClientExtraTags("extra-tags", "client")
dubbo_go.SetClientReportTags("release")
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。