go gRPC 服务端推送把客户端流demo
syntax = "proto3";
option go_package = "./;pb";
package pb;
service Greeter{
rpc GetStream (StreamReqData) returns (stream StreamResData) {}
}
// 请求数据格式
message StreamReqData{
string data = 1;
}
// 返回数据格式
message StreamResData{
string data = 1;
}
client/main.go:
package main
import (
"context"
pb "demo01/pb"
"log"
"谷歌.golang.org/grpc"
_ "谷歌.golang.org/grpc/balancer/grpclb"
)
const (
ADDRESS = "localhost:50051"
)
func main(){
// 建立连接
conn, err := grpc.Dial(ADDRESS, grpc.WithInsecure())
if err != nil {
return
}
defer conn.Close()
// 通过刚才的链接 生成一个client对象
c := pb.NewGreeterClient(conn)
// 通过服务端推送流
reqstreamData := &pb.StreamReqData{Data:"aaa"}
res, _ := c.GetStream(context.Background(),reqstreamData)
for {
aa, err := res.Recv()
if err != nil {
log.Println(err)
return
}
log.Println(aa)
}
}
server/main.go:
package main
import (
pb "demo01/pb"
"fmt"
"net"
"time"
"谷歌.golang.org/grpc"
)
const (
port = ":50051"
)
// 服务对象
type server struct {
pb.UnimplementedGreeterServer
}
func (s *server) GetStream(req *pb.StreamReqData,res pb.Greeter_GetStreamServer) error{
i := 0
for {
i
res.Send(&pb.StreamResData{Data: fmt.Sprintf("%v",time.Now().Unix())})
time.Sleep(time.Second)
if i > 10 {
break
}
}
return nil
}
func main(){
lis, err := net.Listen("tcp", port)
if err != nil {
return
}
// 创建一个grpc 服务器
s := grpc.NewServer()
// 注册事件
pb.RegisterGreeterServer(s, &server{})
// 处理链接
s.Serve(lis)
}
这篇好文章是转载于:学新通技术网
- 版权申明: 本站部分内容来自互联网,仅供学习及演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,请提供相关证据及您的身份证明,我们将在收到邮件后48小时内删除。
- 本站站名: 学新通技术网
- 本文地址: /boutique/detail/tanhgfbfgj
系列文章
更多
同类精品
更多
-
photoshop保存的图片太大微信发不了怎么办
PHP中文网 06-15 -
Android 11 保存文件到外部存储,并分享文件
Luke 10-12 -
《学习通》视频自动暂停处理方法
HelloWorld317 07-05 -
word里面弄一个表格后上面的标题会跑到下面怎么办
PHP中文网 06-20 -
photoshop扩展功能面板显示灰色怎么办
PHP中文网 06-14 -
微信公众号没有声音提示怎么办
PHP中文网 03-31 -
excel下划线不显示怎么办
PHP中文网 06-23 -
excel打印预览压线压字怎么办
PHP中文网 06-22 -
怎样阻止微信小程序自动打开
PHP中文网 06-13 -
TikTok加速器哪个好免费的TK加速器推荐
TK小达人 10-01