基于知名微服务框架go-micro开发gRPC应用程序2

简介: 基于知名微服务框架go-micro开发gRPC应用程序2

5、编写gRPC服务端程序


这里先上代码:

package main
import (
  "context"
  "fmt"
  "grpchello/proto"
  "log"
  "time"
  "github.com/asim/go-micro/plugins/server/grpc/v4"
  "go-micro.dev/v4"
  "go-micro.dev/v4/server"
)
type Hello struct{}
func (s *Hello) Say(ctx context.Context, req *proto.SayRequest, rsp *proto.SayResponse) error {
  fmt.Println("request:", req.Name)
  rsp.Message = "Hello " + req.Name
  return nil
}
func main() {
  grpcServer := grpc.NewServer()
  service := micro.NewService(
    micro.Server(grpcServer),
    micro.Name("grpchello.service"),
    micro.Address("0.0.0.0:8001"),
    micro.RegisterTTL(time.Second*30),
    micro.RegisterInterval(time.Second*10),
  )
  // optionally setup command line usage
  service.Init()
  // Register Handlers
  proto.RegisterHelloHandler(service.Server(), &Hello{})
  // Run server
  if err := service.Run(); err != nil {
    log.Fatal(err)
  }
}

整个过程如下:

先定义一个名为 Hello 的类型,它去实现hello.pb.micro.go中生成的HelloHandler接口,也就是编写具体的业务实现。

然后通过grpc.NewServer创建一个gRPC服务器,这里决定go-micro底层通信使用gPRC;

然后通过micro.NewService创建一个micro服务,这里需要传入上面创建的grpc server,还要设置服务的名称、监听端口,以及保持服务健康用的TTL和上报周期。go-mico当前默认的服务发现机制是mdns,不用额外部署服务发现工具,不过一般只建议在开发环境使用,生产环境建议使用etcd;

通过上面的步骤对服务进行一些初始化之后,再将Hello类型的实例注册到grpc server;

最后启动服务,就可以开始接客了。

如果直接粘贴这段代码的话,会有很多包没有引用进来,可以通过 go get 获取这些包,也可以执行命令:go mod tidy 来引入需要的包。

这里边还import了一个 grpchello/proto ,这个是我这边项目的mod是 grpchello,gRPC代理程序的package是proto,如果你的不一样,需要修改下。


6、编写gRPC客户端程序


访问gRPC服务也是通过 hello.pb.micro.go 中生成的方法,直接上代码:

package main
import (
  "bufio"
  "context"
  "fmt"
  "grpchello/proto"
  "os"
  "github.com/asim/go-micro/plugins/client/grpc/v4"
  "go-micro.dev/v4"
)
func main() {
  service := micro.NewService(
    micro.Client(grpc.NewClient()),
  )
  service.Init()
  client := proto.NewHelloService("grpchello.service", service.Client())
  rsp, err := client.Say(context.TODO(), &proto.SayRequest{Name: "BOSSMA"})
  if err != nil {
    fmt.Println(err)
  }
  fmt.Println(rsp)
  fmt.Println("按回车键退出程序...")
  in := bufio.NewReader(os.Stdin)
  _, _, _ = in.ReadLine()
}

上面的程序使用了 grpc.NewClient , 这决定了底层通信采用gRPC;然后再使用生成的代码 proto.NewHelloService 创建客户端代理,这里指定的服务名字必须是服务端注册的名字;最后使用这个客户端代理调用相应的方法。


7、运行程序


可以使用 go run xxx.go 来编译并运行程序。这里为了方便测试,先使用 go build 将它们编译为exe,然后再双击运行。实际运行效果如下:

1689143067913.png

以上就是本文的主要内容了,完整代码示例已经上传到 Github:github.com/bosima/go-d…

目录
打赏
0
1
1
0
36
分享
相关文章
Go通道机制与应用详解
本文全面解析了Go语言中的通道(Channel),从基础概念到高级应用,涵盖创建、操作、垃圾回收及实际场景使用。通道作为Go并发模型的核心,支持协程间安全高效的数据通信与同步。文章介绍了无缓冲和有缓冲通道的特性,以及发送、接收、关闭等操作,并探讨了`select`语句、超时处理、遍历通道等高级用法。此外,还深入分析了通道的垃圾回收机制,包括引用计数、生命周期管理和循环引用问题。最后通过数据流处理、任务调度和状态监控等实例,展示了通道在实际开发中的广泛应用。理解通道不仅有助于构建高并发系统,还能优化资源管理,提升程序性能。
102 31
Go 网络编程:HTTP服务与客户端开发
Go 语言的 `net/http` 包功能强大,可快速构建高并发 HTTP 服务。本文从创建简单 HTTP 服务入手,逐步讲解请求与响应对象、URL 参数处理、自定义路由、JSON 接口、静态文件服务、中间件编写及 HTTPS 配置等内容。通过示例代码展示如何使用 `http.HandleFunc`、`http.ServeMux`、`http.Client` 等工具实现常见功能,帮助开发者掌握构建高效 Web 应用的核心技能。
150 61
|
2月前
|
使用 Uber automaxprocs 正确设置 Go 程序线程数
`automaxprocs` 包就是专门用来解决此问题的,并且用法非常简单,只需要使用匿名导入的方式 `import _ "go.uber.org/automaxprocs"` 一行代码即可搞定。
200 78
监控局域网其他电脑:Go 语言迪杰斯特拉算法的高效应用
在信息化时代,监控局域网成为网络管理与安全防护的关键需求。本文探讨了迪杰斯特拉(Dijkstra)算法在监控局域网中的应用,通过计算最短路径优化数据传输和故障检测。文中提供了使用Go语言实现的代码例程,展示了如何高效地进行网络监控,确保局域网的稳定运行和数据安全。迪杰斯特拉算法能减少传输延迟和带宽消耗,及时发现并处理网络故障,适用于复杂网络环境下的管理和维护。
无感改造,完美监控:Docker 多阶段构建 Go 应用无侵入观测
本文将介绍一种基于 Docker 多阶段构建的无侵入 Golang 应用观测方法,通过此方法用户无需对 Golang 应用源代码或者编译指令做任何改造,即可零成本为 Golang 应用注入可观测能力。
234 85
员工上网行为监控中的Go语言算法:布隆过滤器的应用
在信息化高速发展的时代,企业上网行为监管至关重要。布隆过滤器作为一种高效、节省空间的概率性数据结构,适用于大规模URL查询与匹配,是实现精准上网行为管理的理想选择。本文探讨了布隆过滤器的原理及其优缺点,并展示了如何使用Go语言实现该算法,以提升企业网络管理效率和安全性。尽管存在误报等局限性,但合理配置下,布隆过滤器为企业提供了经济有效的解决方案。
145 8
员工上网行为监控中的Go语言算法:布隆过滤器的应用
颠覆开发效率!国内首个微服务编排框架Juggle开源啦!
Juggle是国内首个开源的微服务编排框架,专注于解决企业微服务进程中接口重复开发、系统对接复杂等问题。它提供零代码、低代码和AI增强功能,通过可视化拖拽快速组装简单API为复杂接口,支持多协议、多语言脚本和流程多版本管理。相比国外框架如Conductor,Juggle更贴合国内需求,具备高效开发、企业级可靠性及信创适配等优势,助力企业实现敏捷创新与数字化转型。
颠覆开发效率!国内首个微服务编排框架Juggle开源啦!
Go开发遇见的一次Data Race
本文通过一段 Go 语言代码示例,分析了并发编程中的数据竞争(Data Race)问题。代码实现了一个带缓存的内存存储系统,包含 `LRUCache` 和 `MemoryCache` 两个核心组件。尽管在 `MemoryCache` 的 `Set` 方法中加了锁保护,但由于直接调用 `LRUCache` 的 `GetLength` 方法时未加锁,导致底层数据结构在多 goroutine 环境下被同时读写,从而触发 Data Race。文章详细解析了问题根源,并提出了解决方案:为 `LRUCache` 的 `Add` 方法添加锁保护,确保并发安全。
1 行命令引发的Go应用崩溃
这篇文章分析了Go编译时插桩工具导致go build -race竞态检测产生崩溃的原因。
611 179
MCP 实战:用 Go 语言开发一个查询 IP 信息的 MCP 服务器
随着 MCP 的快速普及和广泛应用,MCP 服务器也层出不穷。大多数开发者使用的 MCP 服务器开发库是官方提供的 typescript-sdk,而作为 Go 开发者,我们也可以借助优秀的第三方库去开发 MCP 服务器,例如 ThinkInAIXYZ/go-mcp。 本文将详细介绍如何在 Go 语言中使用 go-mcp 库来开发一个查询 IP 信息的 MCP 服务器。
178 0

热门文章

最新文章

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问