分割策略在 Goroutine 的应用

在Golang实战开发的过程中，我们经常会遇到一些这样那样的问题，然后要卡好半天，等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《分割策略在 Goroutine 的应用》，聊聊，希望可以帮助到正在努力赚钱的你。

在一个实时项目中，我有一个基于标准事件的前端服务从消息队列代理接收消息。该服务旨在向其他少数人提供相关信息。 基本上，该服务在接收方法上循环，解组数据包（例如 protobuf），更新/控制一些参数，编组为另一种格式（例如 json），然后推送到下一个服务。

问题是：如何启动 goroutine 以获得最有效的总体带宽，并优先处理传入数据？

今天，我的观点是，最耗时的操作是解组/编组过程。因此，在接收到任何事件（不需要 ack）后，我会像这样触发 goroutine：

[...]
var rcvBuffer []byte
for {
   err := evt.Receive(ctx, rcvBuffer)
   go convertAndPush(rcvBuffer)
}

[...]
func convertAndPush(rcvBuffer []byte) {
   // unmarshall rcvBuffer
   // control
   // marshall to JSONpack
   JSONpack := json.Marshal(rcvBuffer)
   // fan out to another goroutine communicating with other services...
   pushch <- JSONpack
}

我的重点是接收数据包，不会因为 io 请求（无论是输入还是输出）而阻塞 cpu，也不会因为应用程序中 cpu 成本最高的操作而阻塞 io。

这种设计应用程序的方式正确吗？我可能会错过什么？

btw，消息接收函数不会触发 goroutine。

解决方案

采用 Paul Hankin 的方法+1。

根据我的经验，限制 convertAndPush 的并发也是最佳实践。这可以使用信号量或通道以及工作池模式轻松完成。这还提供了一个在负载测试期间切换的变量（工作池大小）。

如果目标是尽快接收数据包，通道/工作池模式可能会更好，因为它可以配置通道大小来缓冲请求并保持读取路径的低吞吐量。与信号量相比，信号量满载时会阻塞读取路径。

本篇关于《分割策略在 Goroutine 的应用》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！