如何让突发的多个请求等待第一个完成（分布式）

大家好，我们又见面了啊~本文《如何让突发的多个请求等待第一个完成（分布式）》的内容中将会涉及到等等。如果你正在学习Golang相关知识，欢迎关注我，以后会给大家带来更多Golang相关文章，希望我们能一起进步！下面就开始本文的正式内容~

我的服务器通过网络请求和抓取执行相对昂贵的 cpu 操作，因此我使用缓存来优化性能，同时也为了防止同一项目的突发请求的开销，我创建了一个“等候室”它接受第一个请求，一旦第一个请求完成，其余的就会收到响应。这在运行一个实例时效果很好。但如果我想将其扩展到 3 个节点的集群，我该如何解决这个问题？

cached, err := exists(item)
handleErr(err)
if cached == true {
    cachedReport := getCachedRecord(item)
    fmt.Println("found in cache, sending")
    w.Write(cachedReport)
} 
else {
    fmt.Println("got request for ", item)
    if group, ok := bmap[item]; ok {
        fmt.Println("joining group for " + item)
        member := group.Join()
        val := member.Recv()

        if b, ok := val.([]byte); ok {
            fmt.Println("received from waitng, sending")
            elapsed := time.Since(start)
            log.Printf("Request for %s took %s", ticker, elapsed)
            w.Write(b)
        }
    }

解决方案

听起来像是第三方排队/消息传递机制/项目的一个很好的用例：

• Apache Kafka
• RabbitMQ
• NATS
• MQTT
• ActiveMQ
• 等等

云供应商也有他们的产品：

• AWS SQS
• AWS Kinesis
• Google Pub/Sub
• Azure Service Bus
• 等等

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。