kratos中正确实现grpc流式接口须在.proto中声明stream关键字，且proto路径、package名、生成命令必须严格匹配；否则代码无法编译或运行时panic。
要在Kratos中正确实现gRPC流式接口，必须在.proto文件中明确声明stream关键字，且服务端或客户端流式方法的生成结果依赖于proto路径、package命名与代码生成命令的严格匹配，否则生成的Go代码无法编译或运行时panic。
定义流式服务接口
在api/xxx/xxx.proto中编写service方法时，必须使用stream关键字标注请求或响应类型。单向流写法如rpc StreamSayHello (stream HelloRequest) returns (HelloReply);，双向流写法如rpc Chat (stream ChatMessage) returns (stream ChatReply);。
注意：流式方法不能混用普通类型与stream类型作为非stream端——比如rpc BadMethod (HelloRequest) returns (stream HelloReply);是合法的（服务端流），但rpc BadMethod (stream HelloRequest) returns (stream HelloReply);必须两端都带stream才构成双向流，少一个关键字会导致生成代码缺失RecvMsg/SendMsg调用逻辑。
【proto文件必须放在api/子目录下，且package名需与目录深度一致】。例如api/chat/v1/chat.proto对应package chat.v1;，若错写为package chat;，则生成的Go结构体将嵌入错误的包路径，导致pb.RegisterChatServer参数类型不匹配。
生成流式服务端骨架
执行以下命令生成服务端代码：
kratos proto server api/chat/v1/chat.proto -t internal/service
生成的chat_service.go中，流式方法签名已自动展开为func (*ChatService) StreamSayHello(srv pb.Chat_StreamSayHelloServer) error这类形式，其中srv参数实现了Send() / Recv() / SendAndClose()等流控方法。
这一步不会自动注册服务——你必须手动在internal/server/grpc.go中调用pb.RegisterChatServer(grpcServer, &service.ChatService{})，否则启动时gRPC Server根本不识别该服务。
如果删掉自动生成的var _ pb.ChatServer = (*ChatService)(nil)断言行，编译仍能通过，但运行时调用未实现的流式方法会直接panic：“missing implementation for StreamSayHello”。
生成流式客户端代码
方法一：使用Kratos CLI生成Go客户端
kratos proto client api/chat/v1/chat.proto
该命令输出api/chat/v1/chat_grpc.pb.go，其中包含ChatClient接口及StreamSayHello(ctx)等工厂方法，返回Chat_StreamSayHelloClient实例，支持Send() / CloseAndRecv() / Recv()等调用。
方法二：手动构造流式调用（适用于调试）
在测试代码中，先建立连接：conn, _ := grpc.Dial("127.0.0.1:9000", grpc.WithTransportCredentials(insecure.NewCredentials()))；再获取client：c := pb.NewChatClient(conn)；最后调用stream, _ := c.StreamSayHello(ctx)开启流。
【本地开发必须显式传入insecure.NewCredentials()】，否则grpc.Dial会因缺少传输凭据而阻塞直至context deadline exceeded，且无明确错误提示。
实现双向流式业务逻辑
第一步：在internal/service/chat_service.go中找到ChatService.Chat方法签名
第二步：在方法体内使用for {循环持续调用srv.Recv()读取客户端消息，每次读取后立即用srv.Send()返回响应
第三步：当srv.Recv()返回io.EOF时跳出循环，表示客户端关闭发送流；此时可调用srv.SendAndClose()或继续发送直到完成
第四步：务必检查每次Send()的返回值，若客户端提前断开，Send()会返回rpc error: code = Canceled等错误，不处理会导致goroutine泄漏
