扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 后端开发 > GO >Go语言基于HTTP的内存缓存服务的实现
  • 736

0
分享到

Go语言基于HTTP的内存缓存服务的实现

2024-04-02 19:04:59 736人浏览 独家记忆
摘要

目录缓存服务接口缓存服务实现定义状态信息实现Cache接口实现Http服务测试运行所有的缓存数据都存储在服务器的内存中，因此重启服务器会导致数据丢失，基于HTTP通信会将使开发变得简

所有的缓存数据都存储在服务器的内存中，因此重启服务器会导致数据丢失，基于HTTP通信会将使开发变得简单，但性能不会太好

缓存服务接口

本程序采用REST接口，支持设置(Set)、获取(Get)和删除(Del)这3个基本操作，同时还支持对缓存服务状态进行查询。Set操作是将一对键值对设置到服务器中，通过HTTP的PUT方法进行，Get操作用于查询某个键并获取其值，通过HTTP的GET方法进行，Del操作用于从缓存中删除某个键，通过HTTP的DELETE方法进行，同时用户可以查询缓存服务器缓存了多少键值对，占据了多少字节

创建一个cache包，编写缓存服务的主要逻辑

先定义了一个Cache接口类型，包含了要实现的4个方法(设置、获取、删除和状态查询)

package cache
type Cache interface {
	Set(string, []byte) error
	Get(string) ([]byte, error)
	Del(string) error
	GetStat() Stat
}

缓存服务实现

综上所述，这个缓存服务实现起来还是比较容易的，使用Go语言内置的map存储键值，使用http库来处理HTTP请求，实现REST接口

定义状态信息

定义了一个Stat结构体，表示缓存服务状态:

type Stat struct {
	Count     int64
	KeySize   int64
	ValueSize int64
}

Count表示缓存目前保存的键值对数量，KeySize和ValueSize分别表示键和值所占的总字节数

实现两个方法，用来更新Stat信息:

func (s *Stat) add(k string, v []byte) {
	s.Count += 1
	s.KeySize += int64(len(k))
	s.ValueSize += int64(len(v))
}
func (s *Stat) del(k string, v []byte) {
	s.Count -= 1
	s.KeySize -= int64(len(k))
	s.ValueSize -= int64(len(v))
}

缓存增加键值数据时，调用add函数，更新缓存状态信息，对应地，删除数据时就调用del，保持状态信息的正确

实现Cache接口

下面定义一个New函数，创建并返回一个Cache接口:

func New(typ string) Cache {
	var c Cache
	if typ == "inmemory" {
		c = newInMemoryCache()
	}
	if c == nil {
		panic("unknown cache type " + typ)
	}
	log.Println(typ, "ready to serve")
	return c
}

该函数会接收一个string类型的参数，这个参数指定了要创建的Cache接口的具体结构类型，这里考虑到以后可能不限于内存缓存，有扩展的可能。如果typ是"inmemory"代表是内存缓存，就调用newInMemoryCache，并返回

如下定义了inMemoryCache结构和对应New函数:

type inMemoryCache struct {
	c     map[string][]byte
	mutex sync.RWMutex
	Stat
}
 
func newInMemoryCache() *inMemoryCache {
	return &inMemoryCache{
		make(map[string][]byte),
		sync.RWMutex{}, Stat{}}
}

这个结构中包含了存储数据的map，和一个读写锁用于并发控制，还有一个Stat匿名字段，用来记录缓存状态

下面一一实现所定义的接口方法:

func (c *inMemoryCache) Set(k string, v []byte) error {
	c.mutex.Lock()
	defer c.mutex.Unlock()
	tmp, exist := c.c[k]
	if exist {
		c.del(k, tmp)
	}
	c.c[k] = v
	c.add(k, v)
	return nil
}
 
func (c *inMemoryCache) Get(k string) ([]byte, error) {
	c.mutex.RLock()
	defer c.mutex.RLock()
	return c.c[k], nil
}
 
func (c *inMemoryCache) Del(k string) error {
	c.mutex.Lock()
	defer c.mutex.Unlock()
	v, exist := c.c[k]
	if exist {
		delete(c.c, k)
		c.del(k, v)
	}
	return nil
}
 
func (c *inMemoryCache) GetStat() Stat {
	return c.Stat
}

Set函数的作用是设置键值到map中，这要在上锁的情况下进行，首先判断map中是否已有此键，之后用新值覆盖，过程中要更新状态信息

Get函数的作用是获取指定键对应的值，使用读锁即可

Del同样须要互斥，先判断map中是否有指定的键，如果有则删除，并更新状态信息

实现HTTP服务

接下来实现HTTP服务，基于Go语言的标准HTTP包来实现，在目录下创建一个http包

先定义Server相关结构、监听函数和New函数:

type Server struct {
	cache.Cache
}
 
func (s *Server) Listen() error {
	http.Handle("/cache/", s.cacheHandler())
	http.Handle("/status", s.statusHandler())
	err := http.ListenAndServe(":9090", nil)
	if err != nil {
		log.Println(err)
		return err
	}
	return nil
}
 
func New(c cache.Cache) *Server {
	return &Server{c}
}

Server结构体内嵌了cache.Cache接口，这意味着http.Server也要实现对应接口，为Server定义了一个Listen方法，其中会调用http.Handle函数，会注册两个Handler分别用来处理/cache/和status这两个http协议的端点

Server.cacheHandler和http.statusHandler返回一个http.Handler接口，用于处理HTTP请求，相关实现如下:

要实现http.Handler接口就要实现ServeHTTP方法，是真正处理HTTP请求的逻辑，该方法使用switch-case对请求方式进行分支处理，处理PUT、GET、DELETE请求，其他都丢弃

package http
 
import (
	"io/ioutil"
	"log"
	"net/http"
	"strings"
)
 
type cacheHandler struct {
	*Server
}
 
func (h *cacheHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
	key := strings.Split(r.URL.EscapedPath(), "/")[2]
	if len(key) == 0 {
		w.WriteHeader(http.StatusBadRequest)
		return
	}
	switch r.Method {
	case http.MethodPut:
		b, _ := ioutil.ReadAll(r.Body)
		if len(b) != 0 {
			e := h.Set(key, b)
			if e != nil {
				log.Println(e)
				w.WriteHeader(http.StatusInternalServerError)
			}
		}
		return
	case http.MethodGet:
		b, e := h.Get(key)
		if e != nil {
			log.Println(e)
			w.WriteHeader(http.StatusInternalServerError)
			return
		}
		if len(b) == 0 {
			w.WriteHeader(http.StatusNotFound)
			return
		}
		w.Write(b)
		return
	case http.MethodDelete:
		e := h.Del(key)
		if e != nil {
			log.Println(e)
			w.WriteHeader(http.StatusInternalServerError)
		}
		return
	default:
		w.WriteHeader(http.StatusMethodNotAllowed)
	}
}
 
func (s *Server) cacheHandler() http.Handler {
	return &cacheHandler{s}
}

同理，statusHandler实现如下:

package http
 
import (
	"encoding/JSON"
	"log"
	"net/http"
)
 
type statusHandler struct {
	*Server
}
 
func (h *statusHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
	if r.Method != http.MethodGet {
		w.WriteHeader(http.StatusMethodNotAllowed)
		return
	}
	b, e := json.Marshal(h.GetStat())
	if e != nil {
		log.Println(e)
		w.WriteHeader(http.StatusInternalServerError)
		return
	}
	w.Write(b)
}
 
func (s *Server) statusHandler() http.Handler {
	return &statusHandler{s}
}

该方法只处理GET请求，调用GetStat方法得到缓存状态信息，将其序列化为JSON数据后写回

测试运行

编写一个main.main，作为程序的入口:

package main
import (
	"cache/cache"
	"cache/http"
	"log"
)
 
func main() {
	c := cache.New("inmemory")
	s := http.New(c)
	err := s.Listen()
	if err != nil {
		log.Fatalln(err)
	}
}

发起PUT请求，增加数据:

$ curl -v localhost:9090/cache/key -XPUT -d value
*   Trying 127.0.0.1:9090...
* tcp_nodeLAY set
* Connected to localhost (127.0.0.1) port 9090 (#0)
> PUT /cache/key HTTP/1.1
> Host: localhost:9090
> User-Agent: curl/7.68.0
> Accept: */*
> Content-Length: 5
> Content-Type: application/x-www-fORM-urlencoded
> 
* upload completely sent off: 5 out of 5 bytes
* Mark bundle as not supporting multiuse
< HTTP/1.1 200 OK
< Date: Thu, 25 Aug 2022 03:19:47 GMT
< Content-Length: 0
< 
* Connection #0 to host localhost left intact

查看状态信息:

$ curl localhost:9090/status
{"Count":1,"KeySize":3,"ValueSize":5}

查询:

$ curl localhost:9090/cache/key
value

到此这篇关于Go语言基于HTTP的内存缓存服务的文章就介绍到这了,更多相关Go内存缓存服务内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！

您可能感兴趣的文档:

--结束END--

本文标题: Go语言基于HTTP的内存缓存服务的实现

本文链接: https://lsjlt.com/news/121055.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • Go语言基于HTTP的内存缓存服务的实现
    目录缓存服务接口缓存服务实现定义状态信息实现Cache接口实现HTTP服务测试运行所有的缓存数据都存储在服务器的内存中，因此重启服务器会导致数据丢失，基于HTTP通信会将使开发变得简...
    99+
    2024-04-02
  • Go语言如何实现LeetCode缓存响应？
    在LeetCode上提交代码时，我们通常需要等待一段时间才能获得响应，这是因为LeetCode服务器需要编译和运行我们的代码。这个过程可能会非常耗时，如果我们频繁提交同样的代码，那么等待时间就会变得很长。 为了解决这个问题，我们可以使用缓...
    99+
    2023-09-14
    leetcode 缓存 响应
  • Go 语言中，如何实现同步缓存？
    在 Go 语言中，实现同步缓存是一项非常常见的任务。在这篇文章中，我们将介绍如何使用 Go 语言的 sync 包实现同步缓存。 缓存是一个用于存储临时数据的区域，可以让应用程序更快地访问和操作数据。在许多应用程序中，缓存被广泛使用，以提高性...
    99+
    2023-06-28
    关键字 同步 缓存
  • 使用Go实现健壮的内存型缓存的方法
    目录使用Go实现健壮的内存型缓存由来Demo应用字节 VS 结构体Native 缓存并发更新后台更新同步过期缓存错误故障转移模式缓存传输锁竞争和底层性能内存管理基准测试开发者友好总结...
    99+
    2024-04-02
  • 怎么使用Go实现健壮的内存型缓存
    本篇内容介绍了“怎么使用Go实现健壮的内存型缓存”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！使用Go实现健壮的内存型缓存本文介绍了缓存的常...
    99+
    2023-06-30
  • 如何在Go语言中实现高效的并发缓存？
    在计算机科学中，缓存是一种常见的技术，它用于存储计算机系统中频繁访问的数据，以便快速访问。在高并发系统中，缓存可以提高系统的性能和响应速度。在本文中，我们将介绍如何在Go语言中实现高效的并发缓存。 一、并发缓存的需求 在高并发系统中，缓存...
    99+
    2023-06-06
    数组 并发 缓存
  • 如何使用GO语言实现高效的响应缓存？
    随着Web应用程序的发展，缓存已经成为了提高应用性能的重要手段之一。在Web开发中，缓存是指将一些需要频繁访问的数据或计算结果存储在内存或磁盘中，以便下次访问时能够更快地获取到数据或计算结果。在实际的应用场景中，缓存可以用来加快响应速度、...
    99+
    2023-10-29
    响应 教程 缓存
  • 如何在Go语言中实现路由的请求缓存
    如何在Go语言中实现路由的请求缓存在Web开发中，路由是一个非常重要的概念，用于将客户端请求映射到相应的处理程序。在高并发的情况下，频繁地处理请求可能会导致服务器性能下降。为了减轻服务器的负载和提高响应速度，可以对路由的请求进行缓存。在Go...
    99+
    2023-12-17
    Go语言 路由 请求缓存
  • Go语言内存管理的最佳实践
    Go语言是一种开源编程语言，由Google开发，以其高效的并发支持和简单易用的语法而闻名。作为一种静态类型语言，Go语言在编写高性能应用程序时表现出色。然而，对于一些开发者来说，Go语...
    99+
    2024-04-02
  • 如何用Go语言和Redis实现数据缓存
    如何用Go语言和Redis实现数据缓存随着互联网应用的迅速发展，数据缓存成为提高系统性能和响应速度的重要手段之一。而Go语言作为一门高效、可靠的编程语言，搭配Redis这个高性能的缓存数据库，可以实现快速的数据缓存。本文将介绍如何使用Go语...
    99+
    2023-10-27
    Go语言 redis 数据缓存
  • 不同语言中内存管理与Go语言内存管理的差异
    go 语言的内存管理与传统语言（如 c++++、java）不同：传统语言：采用手动内存管理，程序员负责分配和释放内存块。go 语言：采用垃圾回收（gc），自动管理内存，程序员无需手动管理...
    99+
    2024-04-11
    go语言 内存管理 c++
  • 基于Go语言的微服务架构设计与实现
    随着云计算和容器化技术的快速发展，微服务架构已经成为了构建大型分布式系统的首选架构之一。微服务架构的核心理念是将复杂的单体应用拆分成一系列小而独立的服务，通过轻量级的通信方式进行交互，从而提高系统的可伸缩性、可靠性和可维护性。而Go语言作为...
    99+
    2023-11-20
    微服务 实现 架构设计
  • JavaScript中的缓存机制与GO语言的缓存机制有何区别？
    在现代程序开发中，缓存机制是非常常见的一种优化方法。缓存可以大幅度提高程序的运行效率，减少资源的消耗，提高用户体验。在JavaScript和GO语言中，缓存机制也得到了广泛的应用。本文将从JavaScript和GO语言的角度探讨缓存机制的...
    99+
    2023-11-13
    数据类型 缓存 javascript
  • GO语言中的缓存技术有哪些？
    在现代软件开发中，缓存技术是极为重要的一项技术。缓存技术可以大大提高程序的性能，减少对后端数据源的访问，从而减轻服务器的负担。GO语言作为一种高性能、高并发的编程语言，自然也有自己的缓存技术。本文将介绍GO语言中的几种常用的缓存技术。 一...
    99+
    2023-11-13
    数据类型 缓存 javascript
  • 如何利用Redis和Go语言实现缓存功能
    如何利用Redis和Go语言实现缓存功能缓存是一种常见的性能优化技术，它通过将数据存储在高速读取的介质中，例如内存中，来提高数据访问速度。Redis是一种高性能的键值存储数据库，Go语言是一种轻量级并发编程语言，两者的结合可以实现高效的缓存...
    99+
    2023-10-22
    Go语言 redis 缓存功能
  • Go语言如何实现云上数据缓存操作？
    在当今云计算和大数据时代，高效地进行数据缓存操作已成为许多企业云上应用架构中不可或缺的一部分。而Go语言作为一种高效、简单、可靠的编程语言，正逐渐被越来越多的企业用于处理高并发的云端应用。本文将介绍使用Go语言在云上实现数据缓存的方法和技巧...
    99+
    2023-05-17
    Go语言 云上数据 缓存操作
  • 如何用Go语言和Redis实现分布式缓存
    如何用Go语言和Redis实现分布式缓存引言：随着互联网的发展和应用程序的复杂性增加，缓存已经成为了提高应用性能的重要手段之一。而分布式缓存则更加适用于大规模应用系统，能够提供高效的数据存储和访问。本文将介绍如何使用Go语言和Redis实现...
    99+
    2023-10-27
    Go语言 redis 分布式缓存
  • LeetCode响应缓存：用Go语言实现的最佳实践是什么？
    在现代Web应用程序中，缓存是提高性能的关键。LeetCode是一家在线编程网站，它提供了一系列的编程题目供用户练习。在这个网站上，我们可以看到很多的题目，每个题目都有一个唯一的标识符和一些输入参数。当我们提交答案时，LeetCode会给...
    99+
    2023-09-14
    leetcode 缓存 响应
  • Go语言分布式缓存实现有哪些可行的方案？
    随着互联网应用的不断发展，缓存成为了提高应用性能的重要手段之一。而分布式缓存则是为了应对高并发、大流量、高可用性等问题而出现的。Go语言作为一门高效、简洁、并发性能优秀的语言，被越来越多的人用来实现分布式缓存。那么，Go语言分布式缓存实现...
    99+
    2023-10-20
    缓存 日志 分布式
  • 如何使用 Go 语言实现高可扩展的缓存系统
    随着互联网的发展，缓存系统在分布式系统中的应用越来越广泛。在分布式系统中，缓存系统扮演着重要的角色，它可用来降低系统的延迟和提高吞吐量，并减轻后端数据库的负担。在本文中，我们将重点介绍...
    99+
    2024-04-02
软考高级职称资格查询
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作