大家好,我们又见面了啊~本文《如何让突发的多个请求等待第一个完成(分布式)》的内容中将会涉及到等等。如果你正在学习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的相关知识,也可关注编程网公众号。