Skip to content

Commit

Permalink
update example and readme
Browse files Browse the repository at this point in the history
  • Loading branch information
whalecold committed Aug 14, 2023
1 parent 30c00e6 commit b44f57d
Show file tree
Hide file tree
Showing 3 changed files with 138 additions and 6 deletions.
61 changes: 60 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,66 @@ Nacos as config centre.

#### Server

TODO
```go
import (
"context"
"log"
"time"

"github.com/cloudwego/kitex-examples/kitex_gen/api"
"github.com/cloudwego/kitex-examples/kitex_gen/api/echo"
"github.com/cloudwego/kitex/pkg/klog"
"github.com/cloudwego/kitex/pkg/rpcinfo"
"github.com/cloudwego/kitex/server"

"github.com/kitex-contrib/registry-nacos/registry"
"github.com/kitex-contrib/config-nacos/nacos"
nacosserver "github.com/kitex-contrib/config-nacos/server"
)

var _ api.Echo = &EchoImpl{}

// EchoImpl implements the last service interface defined in the IDL.
type EchoImpl struct{}

// Echo implements the Echo interface.
func (s *EchoImpl) Echo(ctx context.Context, req *api.Request) (resp *api.Response, err error) {
klog.Info("echo called")
time.Sleep(2 * time.Second)
return &api.Response{Message: req.Message}, nil
}

func main() {
r, err := registry.NewDefaultNacosRegistry()
if err != nil {
panic(err)
}
nacosClient, err := nacos.DefaultClient()
if err != nil {
panic(err)
}

serviceName := "echo"

opts := []server.Option{
server.WithServerBasicInfo(&rpcinfo.EndpointBasicInfo{ServiceName: serviceName}),
server.WithRegistry(r),
}

opts = append(opts, nacosserver.NewSuite(serviceName, nacosClient).Options()...)

svr := echo.NewServer(
new(EchoImpl),
opts...,
)
if err := svr.Run(); err != nil {
log.Println("server stopped with error:", err)
} else {
log.Println("server stopped")
}
}

```

#### Client

Expand Down
63 changes: 63 additions & 0 deletions README_CN.md
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,69 @@

### 基本使用

#### 服务端

```go
import (
"context"
"log"
"time"

"github.com/cloudwego/kitex-examples/kitex_gen/api"
"github.com/cloudwego/kitex-examples/kitex_gen/api/echo"
"github.com/cloudwego/kitex/pkg/klog"
"github.com/cloudwego/kitex/pkg/rpcinfo"
"github.com/cloudwego/kitex/server"

"github.com/kitex-contrib/registry-nacos/registry"
"github.com/kitex-contrib/config-nacos/nacos"
nacosserver "github.com/kitex-contrib/config-nacos/server"
)

var _ api.Echo = &EchoImpl{}

// EchoImpl implements the last service interface defined in the IDL.
type EchoImpl struct{}

// Echo implements the Echo interface.
func (s *EchoImpl) Echo(ctx context.Context, req *api.Request) (resp *api.Response, err error) {
klog.Info("echo called")
time.Sleep(2 * time.Second)
return &api.Response{Message: req.Message}, nil
}

func main() {
r, err := registry.NewDefaultNacosRegistry()
if err != nil {
panic(err)
}
nacosClient, err := nacos.DefaultClient()
if err != nil {
panic(err)
}

serviceName := "echo"

opts := []server.Option{
server.WithServerBasicInfo(&rpcinfo.EndpointBasicInfo{ServiceName: serviceName}),
server.WithRegistry(r),
}

opts = append(opts, nacosserver.NewSuite(serviceName, nacosClient).Options()...)

svr := echo.NewServer(
new(EchoImpl),
opts...,
)
if err := svr.Run(); err != nil {
log.Println("server stopped with error:", err)
} else {
log.Println("server stopped")
}
}

```

#### 客户端

```go
Expand Down
20 changes: 15 additions & 5 deletions example/server/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,10 +24,11 @@ import (

"github.com/cloudwego/kitex-examples/kitex_gen/api"
"github.com/cloudwego/kitex-examples/kitex_gen/api/echo"
"github.com/cloudwego/kitex-examples/middleware/mymiddleware"
"github.com/cloudwego/kitex/pkg/klog"
"github.com/cloudwego/kitex/pkg/rpcinfo"
"github.com/cloudwego/kitex/server"
"github.com/kitex-contrib/config-nacos/nacos"
nacosserver "github.com/kitex-contrib/config-nacos/server"
)

var _ api.Echo = &EchoImpl{}
Expand All @@ -47,12 +48,21 @@ func main() {
if err != nil {
panic(err)
}
svr := echo.NewServer(
new(EchoImpl),
nacosClient, err := nacos.DefaultClient()
if err != nil {
panic(err)
}

opts := []server.Option{
server.WithServerBasicInfo(&rpcinfo.EndpointBasicInfo{ServiceName: "echo"}),
server.WithRegistry(r),
server.WithMiddleware(mymiddleware.CommonMiddleware),
server.WithMiddleware(mymiddleware.ServerMiddleware),
}

opts = append(opts, nacosserver.NewSuite("echo", nacosClient).Options()...)

svr := echo.NewServer(
new(EchoImpl),
opts...,
)
if err := svr.Run(); err != nil {
log.Println("server stopped with error:", err)
Expand Down

0 comments on commit b44f57d

Please sign in to comment.