我有一个服务器,它对网络请求和刮取执行相对昂贵的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)
}
}
1条答案
按热度按时间smdnsysy1#
听起来像是第三方队列/消息传递机制/项目的一个很好的用例:
Apache·Kafka
兔子MQ
纳茨
mqtt公司
消息中间件
等
云供应商也有自己的产品:
aws sqs公司
aws运动
谷歌发布/订阅
azure服务总线
等