双向流 BidiStreamForClient 的问题

[zhangcunli]

1. 我在使用 dubbo-go 的时候发现一个问题，请教一下：
   client: dubbo-go: v3.2.0-rc2
   server: dubbo v3.3.0
   registry: zookeeper

2. 双向流模式：CallBidiStream

3. client: dubbo.NewInstance 方式创建客户端

4. 客户端代码： 其中 biStream 类型为：*triple_protocol.BidiStreamForClient
   for ; ; { //1.receive triple server msg err := biStream.Receive(response) if err != nil { break } }

5. 问题 1：biStream 客户端没有关闭长连接的接口；如果服务端不调用 onCompleted，那么 Receive 会永久 block；
   客户端应当具有主动 Close 能力才对，底层使用的是 grpc，而 grpc 客户端是能够主动关闭连接的。

   问题 2：Java 服务端调用 onCompleted() 后，biStream.Receive 返回 EOF
   但是和服务端的 TCP 连接仍然存在；我知道 dubbo client 内部是连接池，但是我测试了一下，TCP 连接似乎并没有被复用

[No-SilverBullet]

[zhangcunli]

please add my wechat,wxfowen, we can discuss your issues on weekly meeting

OK. 已加，最近略忙，提了 discussion 后没有关注，错过了 12.15 的讨论；再讨论的时候发消息给我

[AlexStocks]

zhangcunli:
1 连接 gRPC 不能 close request https://github.com/apache/dubbo-go/issues/2755；
2 client 连接数不断增长，到 1k 多，没有复用；

有待 cunli 提供最小可验证测试方案。

[AlexStocks]

apache/dubbo-go-pixiu#645

[zhangcunli]

写了个最小验证 demo: [email protected]:zhangcunli/triple-stream-test.git
也许是我使用的方式不正确，按我的 demo，结论如下：

测试 1：testReuseCli()： 复用 *client.Client，那么每创建一个 greet.NewGreetService
都会新一个新的 TCP 连接，TCP 连接不会复用；
测试 2：testReuseSvc()：复用greet.NewGreetService，TCP 连接只会有一个

所以，最佳用法是像 testReuseSvc() 中复用 GreetService，然后用户自己维护一个 GreetService 池吗？这样用起来有些麻烦。

[AlexStocks]

@zhangcunli 反馈：1 如何 close request/response 感觉不自然; 2 tcp 连接池复用问题.

测试案例：https://github.com/zhangcunli/triple-stream-test

[zhangcunli]

@zhangcunli 反馈：1 如何 close request/response 感觉不自然; 2 tcp 连接池复用问题.

测试案例：https://github.com/zhangcunli/triple-stream-test

1. 双向流使用问题：
   #dubbo-go: v3.2.0-rc2;
   dubbo-go, 双向流 client 接口如下：关闭流需要调用两个接口CloseRequest、CloseResponse 才行；
   而且如果 server 是 java server(v3.3.0)，则 CloseResponse 依赖 server 端调用 onComplete，否则会卡死

#proto 生成
type GreetService_GreetStreamClient interface {
	Spec() triple_protocol.Spec
	Peer() triple_protocol.Peer
	Send(*GreetStreamRequest) error
	RequestHeader() http.Header
	CloseRequest() error
	Recv() (*GreetStreamResponse, error)
	ResponseHeader() http.Header
	ResponseTrailer() http.Header
	CloseResponse() error
}

如下是 grpc 双向流 client 接口：直接调用 CloseSend() 就可以关闭双向流

type ClientStream interface {
	Header() (metadata.MD, error)
	Trailer() metadata.MD
	CloseSend() error
	Context() context.Context
	SendMsg(m any) error
	RecvMsg(m any) error
}

2.tcp 连接问题，参考上面的 demo 即可