Golang如何使用gRPC实现双向流通信_Golang gRPC双向流应用示例

Go语言通过gRPC实现双向流通信，适用于聊天系统等实时场景。1. 定义chat.proto文件声明消息结构和BidirectionalChat服务，使用stream关键字指定双向流；2. 用protoc生成Go代码，得到.pb.go和.grpc.pb.go文件；3. 服务端实现ChatServer结构体，重写BidirectionalChat方法，循环接收客户端消息并发送响应；4. 客户端创建流后启goroutine异步接收服务端消息，同时循环发送消息；5. 运行服务端和客户端，可观察到双方持续收发消息，完成双向通信。需注意流关闭与错误处理，防止资源泄漏。

在Go语言中使用gRPC实现双向流通信，可以实现在客户端和服务端之间持续发送和接收消息。这种模式适用于聊天系统、实时数据推送等场景。下面通过一个简单示例展示如何使用gRPC定义并实现双向流通信。

1. 定义.proto文件

首先需要定义gRPC服务的接口和消息格式。创建一个chat.proto文件：

syntax = "proto3";
package chat;
// 消息结构
message Message {
string content = 1;
string user = 2;
}
// 双向流服务
service ChatService {
rpc BidirectionalChat(stream Message) returns (stream Message);
}

这个定义表示BidirectionalChat方法接收一个消息流，并返回一个消息流，即双向流。

2. 生成gRPC代码

使用Protocol Buffer编译器protoc配合Go插件生成代码：

protoc --go_out=. --go-grpc_out=. chat.proto

执行后会生成chat.pb.go和chat_grpc.pb.go两个文件，包含服务接口和数据结构。

3. 实现服务端逻辑

编写gRPC服务端，处理双向流请求：

package main
import (
"context"
"log"
"net"
"google.golang.org/grpc"
pb "your-module-path/chat" // 替换为你的模块路径
)
type ChatServer struct {
pb.UnimplementedChatServiceServer
}
// BidirectionalChat 处理双向流
func (s *ChatServer) BidirectionalChat(stream pb.ChatService_BidirectionalChatServer) error {
for {
// 接收客户端消息
msg, err := stream.Recv()
if err != nil {
return err
}
    log.Printf("收到消息: %s (用户: %s)", msg.Content, msg.User)

    // 构造响应消息
    response := &pb.Message{
        Content: "已收到: " + msg.Content,
        User:    "Server",
    }

    // 发送回客户端
    if err := stream.Send(response); err != nil {
        return err
    }
}
}
func main() {
lis, err := net.Listen("tcp", ":50051")
if err != nil {
log.Fatalf("监听失败: %v", err)
}
grpcServer := grpc.NewServer()
pb.RegisterChatServiceServer(grpcServer, &ChatServer{})

log.Println("gRPC服务器启动在 :50051")
if err := grpcServer.Serve(lis); err != nil {
    log.Fatalf("启动失败: %v", err)
}
}

4. 编写客户端代码
客户端也通过流发送和接收消息：
package main
import (
"context"
"log"
"time"
"google.golang.org/grpc"
pb "your-module-path/chat"
)
func main() {
conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure())
if err != nil {
log.Fatalf("连接失败: %v", err)
}
defer conn.Close()
client := pb.NewChatServiceClient(conn)

// 建立双向流
stream, err := client.BidirectionalChat(context.Background())
if err != nil {
    log.Fatalf("创建流失败: %v", err)
}

// 启动goroutine接收服务端消息
go func() {
    for {
        msg, err := stream.Recv()
        if err != nil {
            log.Printf("接收错误: %v", err)
            return
        }
        log.Printf("<< %s (%s)", msg.Content, msg.User)
    }
}()

// 发送消息
users := []string{"Alice", "Bob"}
for i := 0; i < 5; i++ {
    msg := &pb.Message{
        Content: "Hello " + string(rune('A'+i)),
        User:    users[i%2],
    }
    if err := stream.Send(msg); err != nil {
        log.Printf("发送失败: %v", err)
        break
    }
    time.Sleep(time.Second)
}

// 关闭发送流
stream.CloseSend()
time.Sleep(2 * time.Second) // 等待接收剩余消息
}

5. 运行与测试
依次执行以下步骤：

启动服务端：go run server.go

运行客户端：go run client.go


观察输出，可以看到客户端和服务端交替收发消息，实现真正的双向通信。
基本上就这些。只要定义好proto接口，正确实现流读写逻辑，就能轻松构建高效的gRPC双向通信应用。注意处理好流的生命周期和错误，避免goroutine泄漏。
 
		


# go 
# golang 
# go语言 
# ai 
# stream 
# google 
# if 
# for 
# Error 
# 结构体 
# 循环 
# 数据结构 
# 接口 
# Struct 
 




相关文章：
如何用搬瓦工VPS快速搭建个人网站？ 
 公众号网站制作网页,微信公众号怎么制作？ 
如何彻底删除建站之星生成的Banner？ 
 深圳网站制作培训,深圳哪些招聘网站比较好？ 
浅谈Javascript中的Label语句 
 南宁网站建设制作定制,南宁网站建设可以定制吗？ 
广州建站公司哪家好？十大优质服务商推荐 
如何注册花生壳免费域名并搭建个人网站？ 
 金*站制作公司有哪些,金华教育集团官网？ 
 网页设计与网站制作内容,怎样注册网站？ 
如何快速搭建自助建站会员专属系统？ 
如何快速查询网址的建站时间与历史轨迹？ 
 教学网站制作软件,学习*后期制作的网站有哪些？ 
 ui设计制作网站有哪些,手机UI设计网址吗？ 
如何在云主机上快速搭建网站？ 
 广州网站设计制作一条龙,广州巨网网络科技有限公司是干什么的？ 
建站之星如何实现PC+手机+微信网站五合一建站？ 
 制作旅游网站html,怎样注册旅游网站？ 
Dapper的Execute方法的返回值是什么意思 Dapper Execute返回值详解 
 家具网站制作软件,家具厂怎么跑业务？ 
 网站制作和推广的区别,想自己建立一个网站做推广，有什么快捷方法马上做好一个网站？ 
如何在宝塔面板中修改默认建站目录？ 
 智能起名网站制作软件有哪些,制作logo的软件？ 
GML (Geography Markup Language)是什么，它如何用XML来表示地理空间信息？ 
 打鱼网站制作软件,波克捕鱼官方号怎么注册？ 
如何用景安虚拟主机手机版绑定域名建站？ 
如何在阿里云通过域名搭建网站？ 
 在线流程图制作网站手机版,谁能推荐几个好的CG原画资源网站么？ 
 企业宣传片制作网站有哪些,传媒公司怎么找企业宣传片项目？ 
 视频网站app制作软件,有什么好的视频聊天网站或者软件？ 
 深圳网站制作的公司有哪些,dido官方网站？ 
Swift中swift中的switch 语句 
 网站网页制作专业公司,怎样制作自己的网页？ 
 行程制作网站有哪些,第三方机票电子行程单怎么开？ 
如何用PHP快速搭建高效网站？分步指南 
 公司网站设计制作厂家,怎么创建自己的一个网站？ 
 大连网站制作公司哪家好一点,大连买房网站哪个好？ 
建站主机选哪种环境更利于SEO优化？ 
如何获取上海专业网站定制建站电话？ 
如何选择建站程序？包含哪些必备功能与类型？ 
 南京做网站制作公司,南京哈发网络有限公司，公司怎么样，做网页美工DIV+CSS待遇怎么样？ 
如何配置IIS站点权限与局域网访问？ 
 一键网站制作软件,义乌购一件代发流程？ 
JS中使用new Date(str)创建时间对象不兼容firefox和ie的解决方法(两种) 
建站之星安装模板失败：服务器环境不兼容？ 
为什么Go需要go mod文件_Go go mod文件作用说明 
 临沂网站制作企业,临沂第三中学官方网站？ 
 合肥制作网站的公司有哪些,合肥聚美网络科技有限公司介绍？ 
如何在IIS服务器上快速部署高效网站？ 
 网站专业制作公司有哪些,做一个公司网站要多少钱？