您当前的位置:首页 > 电脑百科 > 程序开发 > 语言 > Go语言

Go中使用sync.Map实现线程安全的缓存

时间:2023-10-24 16:05:59  来源:微信公众号  作者:技术的游戏

缓存是优化现代应用程序性能的关键方面。它允许您存储并快速检索昂贵操作的结果或经常访问的数据,减少了反复重新计算或获取数据的需要。在本文中,我们将探讨如何使用sync.Map包在Go中实现线程安全的缓存。这种缓存实现支持缓存条目的过期,确保过时的数据不会滞留在缓存中。

Go中使用sync.Map实现线程安全的缓存

为什么要费心

在我们开始实现自己的线程安全内存缓存之前,让我们考虑一下其优缺点。考虑到替代方案是使用为缓存而发明的、有长期使用和支持历史的外部库(工具),让我们思考一下优点和缺点。

使用Go的sync.Map实现自己的线程安全缓存相比使用像redis这样的外部库有几个优点,这取决于您的用例和要求。以下是使用sync.Map创建自己的缓存可能有优势的一些原因:

  • 更低的延迟:使用像sync.Map这样的内存缓存时,数据存储在应用程序的内存中。这可能导致比需要应用程序和缓存服务之间的网络通信的单独服务,如Redis,有更低的访问延迟。
  • 更简单的部署:使用基于sync.Map的缓存,无需部署、配置和维护像Redis这样的额外服务。您的缓存解决方案是应用程序的一部分,使部署过程更简单,并可能减少操作复杂性。
  • 减少资源使用:与像Redis这样的外部服务相比,使用sync.Map的内存缓存通常消耗更少的资源,从而节省了内存和CPU使用。这对于小规模的应用程序或资源紧张的应用程序可能更加经济高效。
  • 更容易集成:在Go应用程序中直接使用sync.Map实现缓存可以更容易地与现有的代码库集成。您不需要学习新的API或管理到外部服务的连接。
  • 定制性:创建自己的缓存实现时,您可以完全控制其行为和功能。您可以轻松地根据具体需求调整缓存,针对您的用例进行优化,并根据需要添加自定义过期策略或其他功能。
  • 乐趣:创建实现缓存的自己的代码段会带来很多乐趣,并帮助更好地理解提供缓存功能的外部库。更好地理解它们有助于更好地利用它们提供的所有功能。

但是,值得注意的是,使用像Redis这样的外部缓存解决方案对于较大规模的应用程序或那些有更复杂的缓存需求的应用程序有其自身的一系列优势。使用Redis的一些好处包括:

  • 可扩展性:Redis设计用于高性能,并可以水平扩展以处理大量请求和数据大小。
  • 持久性:Redis支持不同级别的数据持久性,确保您的缓存数据在重启或崩溃后仍然存在。
  • 高级功能:除了简单的键值缓存外,Redis还提供了一系列功能,如数据结构、发布/订阅消息等。

最终,选择使用sync.Map实现自己的缓存还是使用像Redis这样的外部库将取决于您的具体需求、应用程序的规模以及您在性能、复杂性和资源方面愿意做的权衡。

此外,实现您的缓存会带来乐趣并帮助更好地理解像Redis这样的更复杂的产品。因此,我们将在此文章中实现一个。

为什么我们使用sync.Map

简单地说,因为它完美地满足了我们的需要。更深入的解释 - sync.Map是Go标准库中的一个并发的、线程安全的map实现。它设计用于在多个goroutine并发访问映射的情况下使用,并且键的数量是未知的或随时间变化的。

值得注意的是,虽然sync.Map是特定用例的一个很好的选择,但它并不意味着要替换所有场景的内置map类型。特别是,sync.Map最适合以下情况:

  • 映射主要是读取密集型,偶尔写入。
  • 键的数量随时间变化或事先不知道。
  • 映射由多个goroutine并发访问。

在键的数量是固定的或事先知道的情况下,且映射可以预先分配,使用适当的同步如sync.Mutex或sync.RWMutex的内置map类型可能会提供更好的性能。

创建SafeCache

如上所述,我们的SafeCache是一个简单的、线程安全的缓存,使用Go的sync.Map存储其键值对。

首先,我们定义一个CacheEntry结构来保存值及其过期时间戳:

type CacheEntry struct {
    value      interface{}
    expiration int64
}

在SafeCache结构中嵌入了一个sync.Map,它提供了对键值对的并发安全访问:

type SafeCache struct {
    syncMap sync.Map
}

向缓存中添加值

然后我们定义了一个 Set 方法,该方法允许我们在缓存中存储一个带有指定生存时间(TTL,Time To Live)的值。TTL 决定了缓存条目应被认为有效的时间长度。一旦 TTL 过期,在下一个清理周期中将会移除该缓存条目。

func (sc *SafeCache) Set(key string, value interface{}, ttl time.Duration) {
    expiration := time.Now().Add(ttl).UnixNano()
    sc.syncMap.Store(key, CacheEntry{value: value, expiration: expiration})
}

从缓存中检索值

接下来需要的方法是 Get,它使用键从缓存中检索值。如果没有找到该值或该值已过期,该方法将返回 false:

func (sc *SafeCache) Get(key string) (interface{}, bool) {
    // ... (see the provided code for the full implementation)
}

在 Get 方法中重要的是从缓存加载值后进行类型断言。我们依赖于 sync.Map 的 Load 方法,该方法返回接口。

entry, found := sc.syncMap.Load(key)
 if !found {
  return nil, false
 }
 // Type assertion to CacheEntry, as entry is an interface{}
 cacheEntry := entry.(CacheEntry)

从缓存中移除值

当然,我们还需要一个 Delete 方法,使我们能够从缓存中移除一个值:

func (sc *SafeCache) Delete(key string) {
    sc.syncMap.Delete(key)
}

清理过期条目

我们通过 CleanUp 方法扩展了缓存,该方法负责定期从缓存中删除过期的条目。它使用 sync.Map 提供的 Range 方法遍历缓存中的所有键值对,并删除那些TTL已过期的条目:

func (sc *SafeCache) CleanUp() {
    // ... (see the provided code for the full implementation)
}

要运行 CleanUp 方法,我们可以在初始化缓存时启动一个单独的 Goroutine:

cache := &SafeCache{}
go cache.CleanUp()

完整的代码片段

package cache

import (
 "sync"
 "time"
)

// CacheEntry is a value stored in the cache.
type CacheEntry struct {
 value      interface{}
 expiration int64
}

// SafeCache is a thread-safe cache.
type SafeCache struct {
 syncMap sync.Map
}

// Set stores a value in the cache with a given TTL
// (time to live) in seconds.
func (sc *SafeCache) Set(key string, value interface{}, ttl time.Duration) {
 expiration := time.Now().Add(ttl).UnixNano()
 sc.syncMap.Store(key, CacheEntry{value: value, expiration: expiration})
}

// Get retrieves a value from the cache. If the value is not found
// or has expired, it returns false.
func (sc *SafeCache) Get(key string) (interface{}, bool) {
 entry, found := sc.syncMap.Load(key)
 if !found {
  return nil, false
 }
 // Type assertion to CacheEntry, as entry is an interface{}
 cacheEntry := entry.(CacheEntry)
 if time.Now().UnixNano() > cacheEntry.expiration {
  sc.syncMap.Delete(key)
  return nil, false
 }
 return cacheEntry.value, true
}

// Delete removes a value from the cache.
func (sc *SafeCache) Delete(key string) {
 sc.syncMap.Delete(key)
}

// CleanUp periodically removes expired entries from the cache.
func (sc *SafeCache) CleanUp() {
 for {
  time.Sleep(1 * time.Minute)
  sc.syncMap.Range(func(key, entry interface{}) bool {
   cacheEntry := entry.(CacheEntry)
   if time.Now().UnixNano() > cacheEntry.expiration {
    sc.syncMap.Delete(key)
   }
   return true
  })
 }
}

最后,你可以运行以下的 mAIn.go 程序来检查缓存是否工作。我们创建了一个HTTP服务器,它在“/compute”端点监听请求。该服务器接受一个整数n作为查询参数,并返回昂贵计算的结果(在这种情况下,带有模拟延迟的简单平方操作)。服务器首先检查缓存,看看给定输入的结果是否已经被缓存;如果没有,它会计算结果,将其存储在缓存中,并将其返回给客户端。

要测试服务器,运行代码并请求http://localhost:8080/compute?n=5。第一个请求会花费更长的时间(由于模拟的延迟),但具有相同n的后续请求将立即返回缓存的结果。

package main

import (
 "fmt"
 "log"
 ".NET/http"
 "safe-cache/cache"
 "strconv"
 "time"
)


func expensiveComputation(n int) int {
 // Simulate an expensive computation
 time.Sleep(2 * time.Second)
 return n * n
}

func main() {
 safeCache := &cache.SafeCache{}
 // Start a goroutine to periodically clean up the cache
 go safeCache.CleanUp()

 http.HandleFunc("/compute", func(w http.ResponseWriter, r *http.Request) {
  query := r.URL.Query()
  n, err := strconv.Atoi(query.Get("n"))
  if err != nil {
   http.Error(w, "Invalid input", http.StatusBadRequest)
   return
  }

  cacheKey := fmt.Sprintf("result_%d", n)
  cachedResult, found := safeCache.Get(cacheKey)
  var result int
  if found {
   result = cachedResult.(int)
  } else {
   result = expensiveComputation(n)
   safeCache.Set(cacheKey, result, 1*time.Minute)
  }

  _, err = fmt.Fprintf(w, "Result: %dn", result)
  if err != nil {
   return
  }
 })

 log.Fatal(http.ListenAndServe(":8080", nil))
}

结论

在本文中,我们展示了如何使用sync.Map包在Go中实现一个简单、线程安全的缓存。

这个缓存实现支持基于TTL的过期的键值存储,并可以轻松地集成到你的Go应用中,以提高性能并减少对你的数据源或计算资源的负载。



Tags:Go   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,不构成投资建议。投资者据此操作,风险自担。如有任何标注错误或版权侵犯请与我们联系,我们将及时更正、删除。
▌相关推荐
机械设备B2B工厂外贸网站如何做Google谷歌SEO优化关键字排名?
在今天的全球化市场中,机械设备行业正面临着激烈的竞争。要在这一领域脱颖而出,拥有一个优化良好的B2B外贸网站至关重要。通过精准的谷歌SEO关键字排名,您的网站可以吸引更多海...【详细内容】
2024-04-08  Search: Go  点击:(5)  评论:(0)  加入收藏
Google搜索引擎索引的网页数量有多少?谷歌官方提供数据进行参考
Google搜索引擎索引的网页数量有多少?二十世纪九十年代,网页的索引数量成了一个各大搜索引擎相互对比的指标。小编记得2000年谷歌搜索引擎的首页搜索框上方,还标记着谷歌索引的...【详细内容】
2024-03-27  Search: Go  点击:(12)  评论:(0)  加入收藏
在Java应用程序中释放峰值性能:配置文件引导优化(PGO)概述
译者 | 李睿审校 | 重楼在Java开发领域,优化应用程序的性能是开发人员的持续追求。配置文件引导优化(Profile-Guided Optimization,PGO)是一种功能强大的技术,能够显著地提高Ja...【详细内容】
2024-03-18  Search: Go  点击:(24)  评论:(0)  加入收藏
宝藏级Go语言开源项目——教你自己动手开发互联网搜索引擎
DIYSearchEngine 是一个能够高速采集海量互联网数据的开源搜索引擎,采用 Go 语言开发。Github 地址:https://github.com/johnlui/DIYSearchEngine运行方法首先,给自己准备一杯...【详细内容】
2024-03-12  Search: Go  点击:(18)  评论:(0)  加入收藏
Go Gin框架实现优雅地重启和停止
在Web应用程序中,有时候我们需要重启或停止服务器,无论是因为更新代码还是进行例行维护。在这种情景下,我们需要保证应用程序的可用性和数据的一致性。这就需要优雅地关闭和重...【详细内容】
2024-01-30  Search: Go  点击:(67)  评论:(0)  加入收藏
如何让Go程序以后台进程或daemon方式运行
本文探讨了如何通过Go代码实现在后台运行的程序。最近我用Go语言开发了一个WebSocket服务,我希望它能在后台运行,并在异常退出时自动重新启动。我的整体思路是将程序转为后台...【详细内容】
2024-01-26  Search: Go  点击:(60)  评论:(0)  加入收藏
深入Go底层原理,重写Redis中间件实战
Go语言以其简洁、高效和并发性能而闻名,深入了解其底层原理可以帮助我们更好地利用其优势。在本文中,我们将探讨如何深入Go底层原理,以及如何利用这些知识重新实现一个简单的Re...【详细内容】
2024-01-25  Search: Go  点击:(66)  评论:(0)  加入收藏
支付宝宣布更换Logo
鞭牛士 1月19日消息,今日,支付宝宣布更新Logo,此次最大的变化在于去掉了外框与文字,仅保留最具辨识度的“支”字标识。据了解,这是支付宝时隔4年再次更换Logo。支付宝App目前已用...【详细内容】
2024-01-19  Search: Go  点击:(71)  评论:(0)  加入收藏
Go 内存优化与垃圾收集
Go提供了自动化的内存管理机制,但在某些情况下需要更精细的微调从而避免发生OOM错误。本文将讨论Go的垃圾收集器、应用程序内存优化以及如何防止OOM(Out-Of-Memory)错误。Go...【详细内容】
2024-01-15  Search: Go  点击:(61)  评论:(0)  加入收藏
Go函数指针是如何让你的程序变慢的?
导读Go 语言的常规优化手段无需赘述,相信大家也能找到大量的经典教程。但基于 Go 的函数值问题,业界还没有太多深度讨论的内容分享。本文作者根据自己对 Go 代码的使用与调优...【详细内容】
2024-01-15  Search: Go  点击:(86)  评论:(0)  加入收藏
▌简易百科推荐
宝藏级Go语言开源项目——教你自己动手开发互联网搜索引擎
DIYSearchEngine 是一个能够高速采集海量互联网数据的开源搜索引擎,采用 Go 语言开发。Github 地址:https://github.com/johnlui/DIYSearchEngine运行方法首先,给自己准备一杯...【详细内容】
2024-03-12  OSC开源社区    Tags:Go语言   点击:(18)  评论:(0)  加入收藏
Go Gin框架实现优雅地重启和停止
在Web应用程序中,有时候我们需要重启或停止服务器,无论是因为更新代码还是进行例行维护。在这种情景下,我们需要保证应用程序的可用性和数据的一致性。这就需要优雅地关闭和重...【详细内容】
2024-01-30  源自开发者  微信公众号  Tags:Go   点击:(67)  评论:(0)  加入收藏
如何让Go程序以后台进程或daemon方式运行
本文探讨了如何通过Go代码实现在后台运行的程序。最近我用Go语言开发了一个WebSocket服务,我希望它能在后台运行,并在异常退出时自动重新启动。我的整体思路是将程序转为后台...【详细内容】
2024-01-26  Go语言圈  微信公众号  Tags:Go程序   点击:(60)  评论:(0)  加入收藏
深入Go底层原理,重写Redis中间件实战
Go语言以其简洁、高效和并发性能而闻名,深入了解其底层原理可以帮助我们更好地利用其优势。在本文中,我们将探讨如何深入Go底层原理,以及如何利用这些知识重新实现一个简单的Re...【详细内容】
2024-01-25  547蓝色星球    Tags:Go   点击:(66)  评论:(0)  加入收藏
Go 内存优化与垃圾收集
Go提供了自动化的内存管理机制,但在某些情况下需要更精细的微调从而避免发生OOM错误。本文将讨论Go的垃圾收集器、应用程序内存优化以及如何防止OOM(Out-Of-Memory)错误。Go...【详细内容】
2024-01-15  DeepNoMind  微信公众号  Tags:Go   点击:(61)  评论:(0)  加入收藏
Go函数指针是如何让你的程序变慢的?
导读Go 语言的常规优化手段无需赘述,相信大家也能找到大量的经典教程。但基于 Go 的函数值问题,业界还没有太多深度讨论的内容分享。本文作者根据自己对 Go 代码的使用与调优...【详细内容】
2024-01-15  腾讯云开发者  微信公众号  Tags:Go函数   点击:(86)  评论:(0)  加入收藏
Go编程中调用外部命令的几种场景
在很多场合, 使用Go语言需要调用外部命令来完成一些特定的任务, 例如: 使用Go语言调用Linux命令来获取执行的结果,又或者调用第三方程序执行来完成额外的任务。在go的标准库...【详细内容】
2024-01-09  suntiger    Tags:Go编程   点击:(101)  评论:(0)  加入收藏
Go 语言不支持并发读写 Map,为什么?
Go语言的map类型不支持并发读写的主要原因是并发读写会导致数据竞态(data race),这意味着多个 goroutine 可能同时访问并修改同一个 map,从而引发不确定的结果。在Go语言的设计...【详细内容】
2024-01-05  Go语言圈  微信公众号  Tags:Go 语言   点击:(77)  评论:(0)  加入收藏
Go微服务入门到容器化实践
Go微服务入门到容器化实践Go 是一门高效、现代化、快速增长的编程语言,非常适合构建 Web 应用程序。而 Docker 是一种轻量级的容器化技术,能够使得您的应用程序在任何地方运行...【详细内容】
2024-01-01  大雷家吃饭    Tags:Go微服务   点击:(62)  评论:(0)  加入收藏
你是否想知道如何应对高并发?Go语言为你提供了答案!
并发编程是当前软件领域中不可忽视的一个关键概念。随着CPU等硬件的不断发展,我们都渴望让我们的程序运行速度更快、更快。而Go语言在语言层面天生支持并发,充分利用现代CPU的...【详细内容】
2023-12-29  灵墨AI探索室  微信公众号  Tags:Go语言   点击:(107)  评论:(0)  加入收藏
站内最新
站内热门
站内头条