直连访问

在明确要访问某个下游地址时，Kitex 可以选择直连访问的方式，不需要经过服务发现。

指定 IP 和 Port 进行调用

在进行调用时，可以通过 callopt.WithHostPort 指定，支持两种参数:

  • 普通 IP 地址，形式为 “host:port”，支持 IPv6
  • sock 文件地址，通过 UDS (Unix Domain Socket) 通信
import "github.com/cloudwego/kitex/client/callopt"
...
resp, err := cli.Echo(context.Background(), req, callopt.WithHostPort("127.0.0.1:8888"))
if err != nil {
   log.Fatal(err)
}

指定 URL 进行调用

在进行调用时，可以通过 callopt.WithURL 指定，通过该 option 指定的 URL，会经过默认的 DNS resolver 解析后拿到 host 和 port，此时其等效于 callopt.WithHostPort。

import "github.com/cloudwego/kitex/client/callopt"
...
url := callopt.WithURL("http://myserverdomain.com:8888")
resp, err := cli.Echo(context.Background(), req, url)
if err != nil {
   log.Fatal(err)
}

自定义 DNS resolver

此外也可以自定义 DNS resolver

resolver 定义如下 (pkg/http)：

type Resolver interface {
   Resolve(string) (string, error)
}

参数为 URL，返回值为访问的 server 的 “host:port”。

通过 client.WithHTTPResolver 指定用于 DNS 解析的 resolver。

import "github.com/cloudwego/kitex/client/callopt"
...
dr := client.WithHTTPResolver(myResolver)
cli, err := echo.NewClient("echo", dr)
if err != nil {
   log.Fatal(err)
}

最后修改 March 19, 2024 : chore: slack to discord (#1044) (4c2f994)