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

z9zf31ra  于 2021-06-10  发布在  Redis
关注(0)|答案(1)|浏览(296)

我有一个服务器,它对网络请求和刮取执行相对昂贵的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)
        }
    }
smdnsysy

smdnsysy1#

听起来像是第三方队列/消息传递机制/项目的一个很好的用例:
Apache·Kafka
兔子MQ
纳茨
mqtt公司
消息中间件

云供应商也有自己的产品:
aws sqs公司
aws运动
谷歌发布/订阅
azure服务总线

相关问题