Go 简单实现多租户设计

简介: 在 SaaS 系统中多租户是一个很重要的架构,在服务上仅需运行一个软件实例就能够支持每个租户的功能,它们之间的数据互相隔离。就比如 Gitee ,每个用户或组织都拥有自己的空间。它们自己的数据仅在自己的空间内流通,彼此之间互不影响。多租户其实就是一种软件设计结构。所以。租户模型其实就是分离数据的方式:• 单租户:一个应用一个数据库。其实就是应用分离,数据分离。• 多租户:一个应用多个数据库。就是同一个应用不同数据库。

多租户

在 SaaS 系统中多租户是一个很重要的架构,在服务上仅需运行一个软件实例就能够支持每个租户的功能,它们之间的数据互相隔离。就比如 Gitee ,每个用户或组织都拥有自己的空间。它们自己的数据仅在自己的空间内流通,彼此之间互不影响。多租户其实就是一种软件设计结构。

所以。租户模型其实就是分离数据的方式:

  • 单租户:一个应用一个数据库。其实就是应用分离,数据分离。
  • 多租户:一个应用多个数据库。就是同一个应用不同数据库。

为什么需要多租户?

刚毕业第一家公司,接触的第一个项目的内容主要帮助客户提高生产力。每次有一个很大的问题就是,合作一个客户,项目复制一份出来,然后改成该客户定制的功能需求。这样就导致相同功能要更新多份代码,还要注意可能会出现因不同客户的不同需求问题。整个过程就导致了一个很大的维护成本的支出。

多租户应用程序的维护更容易,只需根据每个租户专属标志,然后提供不同的功能,且公共的功能可以集中更新升级。

数据隔离方式

在 SaaS 系统中一般分离租户的数据有两种模型:

  • 数据的逻辑分离:所有租户只使用一个数据库。它们的数据通过为每个租户使用一个唯一标识符来分隔。
  • 数据的物理分离:一个租户分配一个数据库。就是一个应用对应多个数据库。每个数据库就是一个租户。这种方式在客户的增长时扩展了应用的功能,也方便扩展数据库

物理分离详细实现

目标:每个请求过来,应用程序能够识别租户,并从该租户数据库中进行提供数据。

  • 公共数据库:存储所有租户相关全局配置和所有租户数据库信息。
  • 租户数据库:每个租户独立的的数据库,根据租户需要保存数据。

启动服务

创建 main 文件,并使用 Gin 框架。初始化一个简单的应用程序并创建基本的路由。

func main() {

r := gin.Default()

r.GET("/ping", func(c *gin.Context) {

c.JSON(http.StatusOK, gin.H{

  "message": "pong",

})

})

r.Run()

}


数据库配置

在公共数据库创建一个保存租户数据库信息表并添加上租户的数据库。

Create Table db_tenant (

id int primary key,

db_name varchar(100) unique not null,

db_domain  varchar(100) unique not null,

conn_str varchar(200) not null,

remark varchar(1000) ,

)

在配置文件中加入一个公共数据库的连接配置,这样就可以在服务启动时第一次连接的是公共数据库。接着需要实现根据请求连接到正确的租户数据库。主要使用 gorm 的 DBResolver ,多个数据库的连接支持

func allDbConnect(db *db.gorm) (allDbs map[string]) {

 db.Model(&db_tenant).Find(&allDbs)


   var gconn []gorm.Dialector

  for _,connStr := range allDbs {

      db :=mysql.Open(connStr)

  gconn = append(gconn,db)

   }

db.Use(dbresolver.Register(dbresolver.Config{

 Sources:  gconn,

 // sources/replicas 负载均衡策略

 Policy: dbresolver.RandomPolicy{},

})

  return allDbs

}

通过使用中间件来解析每个请求连接,从而确定整个请求是由哪个租户数据库来提供数据读写。中间件中主要的处理方式是得到租户对应的数据库连接名,然后从连接池中拿到该连接并设置在全局变量中。在业务逻辑处理中从全局拿到数据库连接,就可以进行数据库读写。

r.Use(middlerware.dbResolve)


func dbResolve(ctx *gin.Context) {

dbName := ctx.Query("dbName")


setGlobalDb(dbName)

 

}


func dbOperater(){

db := getDb()

 var users []User

 db.Clauses(dbresolver.Use(dbName)).First(&users)

}


这样就可以启动项目,然后访问 localhost:8003?dbName=db1 ,这样就可以正常进行数据读写。

其实可以从域名上解析对应的数据库连接。这里最重要就是对数据库的解析。这里的例子只是实验使用,其中还有很多可优化的点。比如可以考虑使用连接池,这样就不用在项目启动时都全部创建数据库连接,造成浪费。

目录
相关文章
|
Go
go 简单实现分布式锁
单一执行,通过分布式锁实现
614 0
|
消息中间件 Go
rabbitMQ go语言简单实现
rabbitMQ go语言简单实现
93 0
|
Go
go语言简单实现加载ini文件
go语言简单实现加载ini文件
152 0
go语言简单实现加载ini文件
|
8月前
|
编译器 Go
揭秘 Go 语言中空结构体的强大用法
Go 语言中的空结构体 `struct{}` 不包含任何字段,不占用内存空间。它在实际编程中有多种典型用法:1) 结合 map 实现集合(set)类型;2) 与 channel 搭配用于信号通知;3) 申请超大容量的 Slice 和 Array 以节省内存;4) 作为接口实现时明确表示不关注值。此外,需要注意的是,空结构体作为字段时可能会因内存对齐原因占用额外空间。建议将空结构体放在外层结构体的第一个字段以优化内存使用。
|
8月前
|
运维 监控 算法
监控局域网其他电脑:Go 语言迪杰斯特拉算法的高效应用
在信息化时代,监控局域网成为网络管理与安全防护的关键需求。本文探讨了迪杰斯特拉(Dijkstra)算法在监控局域网中的应用,通过计算最短路径优化数据传输和故障检测。文中提供了使用Go语言实现的代码例程,展示了如何高效地进行网络监控,确保局域网的稳定运行和数据安全。迪杰斯特拉算法能减少传输延迟和带宽消耗,及时发现并处理网络故障,适用于复杂网络环境下的管理和维护。
|
2月前
|
数据采集 Go API
Go语言实战案例:多协程并发下载网页内容
本文是《Go语言100个实战案例 · 网络与并发篇》第6篇,讲解如何使用 Goroutine 和 Channel 实现多协程并发抓取网页内容,提升网络请求效率。通过实战掌握高并发编程技巧,构建爬虫、内容聚合器等工具,涵盖 WaitGroup、超时控制、错误处理等核心知识点。
|
2月前
|
数据采集 JSON Go
Go语言实战案例:实现HTTP客户端请求并解析响应
本文是 Go 网络与并发实战系列的第 2 篇,详细介绍如何使用 Go 构建 HTTP 客户端,涵盖请求发送、响应解析、错误处理、Header 与 Body 提取等流程,并通过实战代码演示如何并发请求多个 URL,适合希望掌握 Go 网络编程基础的开发者。
|
3月前
|
JSON 前端开发 Go
Go语言实战:创建一个简单的 HTTP 服务器
本篇是《Go语言101实战》系列之一,讲解如何使用Go构建基础HTTP服务器。涵盖Go语言并发优势、HTTP服务搭建、路由处理、日志记录及测试方法,助你掌握高性能Web服务开发核心技能。
|
3月前
|
Go
如何在Go语言的HTTP请求中设置使用代理服务器
当使用特定的代理时,在某些情况下可能需要认证信息,认证信息可以在代理URL中提供,格式通常是:
244 0
|
4月前
|
开发框架 JSON 中间件
Go语言Web开发框架实践:路由、中间件、参数校验
Gin框架以其极简风格、强大路由管理、灵活中间件机制及参数绑定校验系统著称。本文详解其核心功能:1) 路由管理,支持分组与路径参数;2) 中间件机制,实现全局与局部控制;3) 参数绑定,涵盖多种来源;4) 结构体绑定与字段校验,确保数据合法性;5) 自定义校验器扩展功能;6) 统一错误处理提升用户体验。Gin以清晰模块化、流程可控及自动化校验等优势,成为开发者的优选工具。