云服务器内容精选

华为云首页用户手册

ServiceComb引擎托管应用

微服务引擎 CSE-托管Kitex应用:代码接入

代码接入 Provider端： import ( "context" "log" "net" "github.com/cloudwego/kitex-examples/hello/kitex_gen/api" "github.com/cloudwego/kitex-examples/hello/kitex_gen/api/hello" "github.com/cloudwego/kitex/pkg/rpcinfo" "github.com/cloudwego/kitex/server" "github.com/kitex-contrib/registry-servicecomb/registry" ) type HelloImpl struct{} func (h *HelloImpl) Echo(_ context.Context, req *api.Request) (resp *api.Response, err error) { resp = &api.Response{ Message: req.Message, } return } func main() { // **初始化ServiceComb注册中心，默认从环境变量读取配置** r, err := registry.NewDefaultSCRegistry() if err != nil { panic(err) } svr := hello.NewServer( new(HelloImpl), server.WithRegistry(r), server.WithServerBasicInfo(&rpcinfo.EndpointBasicInfo{ServiceName: "Hello"}), server.WithServiceAddr(&net.TCPAddr{IP: net.IPv4(0, 0, 0, 0), Port: 8080}), ) if err := svr.Run(); err != nil { log.Println("server stopped with error:", err) } else { log.Println("server stopped") } } Consumer端： import ( "context" "log" "time" "github.com/cloudwego/kitex-examples/hello/kitex_gen/api" "github.com/cloudwego/kitex-examples/hello/kitex_gen/api/hello" "github.com/cloudwego/kitex/client" "github.com/kitex-contrib/registry-servicecomb/resolver" ) func main() { // **初始化ServiceComb注册中心，默认从环境变量读取配置** r, err := resolver.NewDefaultSCResolver() if err != nil { panic(err) } newClient := hello.MustNewClient( "Hello", client.WithResolver(r), client.WithRPCTimeout(time.Second*3), ) for { resp, err := newClient.Echo(context.Background(), &api.Request{Message: "Hello"}) if err != nil { log.Fatal(err) } log.Println(resp) time.Sleep(time.Second) } }

微服务引擎 CSE ServiceComb引擎托管应用
微服务引擎 CSE-托管Kitex应用:验证

验证部署成功后，登录微服务引擎控制台，在左侧导航栏选择“ServiceComb引擎专享版”，单击前提条件创建的ServiceComb引擎，选择“微服务目录”，单击微服务名称，在“实例列表”页签查看服务实例是否已经成功注册。您也可以验证Consumer调用Provider能够正常调用。设置环境变量serverAddr和serverPort为ServiceComb引擎服务注册发现地址的ip和port。运行consumer。说明成功从ServiceComb引擎的服务中心获取了provider的ip和port，并调用了provider。

微服务引擎 CSE ServiceComb引擎托管应用