当前位置: 首页 > news >正文

GO EASY 游戏框架 之 GRPC 扩展篇 04

1 Overview

此章节是对第三章的一个补充。同样属于RPC的篇章。是专门为了类似游戏服务这种需要指定RPC服务端具体地址,也就是具体是哪台机器的某应用进程,通信的方式。笔者简单的封装了下保证基本的服务稳定,且具备服务发现的属性即可,因此也仅仅对GRPC的客户端进行一次壳子的封装。

2 客户端初始化

外表看着几乎与03章节的 客户端初始化代码基本一致;

GRPC的初始化类名不同变为了NewGameGrpcCluster 而已;

这里没表现出来的,就是绑定Proto接口的方式发生了变化;

    etcd.NewWithOption(option.OptionWith(nil).Default(option.OptionFunc(func() (string, any) {return "Endpoints", strings.Split(etcdAddr, ";")}),))client := cgrpc.NewGameGrpcCluster(option.OptionWith(&struct {PathName  stringNamespace string}{"server1", namespace}))//client.Start()// do your thingstestHandle(client)// just for testclient.Wait()// closeclient.Close()

3 调用Proto服务接口

为了方便后续调用,以及简化代码,我们在使用grpc.ClientConn 时的部分进行了一个函数封装。这与经常见过GRPC调用的方式是一样的。


func handleSay(clientConn grpc.ClientConnInterface) {c := helloworld.NewGreeterClient(clientConn)resp1, err := c.SayHello(context.Background(),&helloworld.HelloRequest{Name: fmt.Sprintf("xiaoming-%d", 9)},)if err != nil {log.Fatal("Say Hello error:%v", err)return}log.Info("SayHello Response:%s\n ", resp1.Message)}

4 指定GRPC服务的invoke

  • 关键点就是一个client.Handle;
  • 它的参数是一个匿名函数;
  • handle参数匿名函数 传递一个[]*cgrpc.GameGrpcConn的切片;
  • cgrpc.GameGrpcConn 是继承于grpc.ClientConn

func testHandle(client *cgrpc.GameRpcCluster) {ticker := time.NewTicker(time.Second)for {<-ticker.Cclient.Handle(func(gconns []*cgrpc.GameGrpcConn) {log.Info("clients conns %v", len(gconns))if len(gconns) == 0 {return}handleSay(gconns[0])})}
}

handle参数匿名函数拿到了grpc链接列表;致于如何获取某一个链接。就是路由的事情了,可以单独做一个小模块,与它结合起来。这里我们暂时没有做。

不过只要知道GameGrpcConn的另外一个参数你就很容易策略做这件事了。看看它的定义


type GameGrpcConn struct {*grpc.ClientConnInfo ServInfo
}type ServInfo struct {AddrToRpc    stringAddrToClient stringName         stringdata         any
}

知道了链接地址,和名字,怎么选择,可以随意开发策略,是随机,是按地址选择,按服务名选择也好。

需要知道用户在哪台游戏服的,或哪台聊天服的业务场景中,可以轻松实现。

http://www.lryc.cn/news/258882.html

相关文章:

  • 【JavaScript】JavaScript中的GC算法
  • 从互联网到云计算再到 AI 原生,百度智能云数据库的演进
  • C# | CountdownEvent使用教程 (通过与ManualResetEvent对比,快速了解其特性)
  • 2、LLVM 函数名称加密 及3种PASS的实现
  • Python网络爬虫的基础理解-对应的自我理解误区
  • 基于ssm的家庭财务管理系统设计与实现论文
  • 前端知识(八)———前端需要掌握的技术有哪些方面
  • 【九】spring、springmvc、springboot、springcloud
  • Core Web Vitals 是排名因素吗?
  • “蒙企通”线上平台升级 助力内蒙古自治区民营经济发展
  • 电商早报 | 12月13日| 2023胡润男企业家榜发布:黄铮位于第三
  • Terraform实战(二)-terraform创建阿里云资源
  • ELADMIN - 免费开源 admin 后台管理系统,基于 Spring Boot 和 Vue ,包含前端和后端源码
  • Centos安装docker显示 No Package Docker-Ce Available
  • 如何使用玻璃材质制作3D钻石模型
  • 工具:Jupyter
  • 即时通讯技术文集(第27期):实时音视频技术合集(Part2) [共17篇]
  • synchronized关键字的使用和原理
  • 【PHP】php发送邮箱验证码格式美化,样式美化
  • 【EI会议征稿中】2024年第四届人工智能、自动化与高性能计算国际会议(AIAHPC 2024)
  • 数据库设计规范编制文档
  • RocketMq集成SpringBoot(待完善)
  • 刚学Python有点难怎么办?这是好事啊!
  • LNMP网站架构分布式搭建部署
  • lwIP 细节之六:connected、sent、poll 回调函数是何时调用的
  • C语言搭建项目-学生管理系统(非链表)
  • 美易官方:投资美股证券投资组合的优势及快速上手指南
  • centos日常运维随记
  • 设计模式之观察者模式(主题对象发生变化,通知各个观察者)
  • vue+高德,百度地图