go語言使用Casbin實現(xiàn)角色的權(quán)限控制
更新時間：2021年06月25日 16:14:06 作者：王大陽_
Casbin是用于Golang項目的功能強大且高效的開源訪問控制庫。本文主要介紹了go語言使用Casbin實現(xiàn)角色的權(quán)限控制，感興趣的可以了解下
本文主要介紹了go語言使用Casbin實現(xiàn)角色的權(quán)限控制，分享給大家，具體如下：
介紹 Casbin 是什么？
官方解釋：Casbin是一個強大的、高效的開源訪問控制框架，其權(quán)限管理機制支持多種訪問控制模型。
Casbin只負(fù)責(zé)訪問控制。身份認(rèn)證 authentication（即驗證用戶的用戶名、密碼），需要其他專門的身份認(rèn)證組件負(fù)責(zé)。例如（jwt-go）
兩個核心概念：
訪問控制模型model和策略policy。
工作原理：
Casbin把 訪問控制模型 被抽象為基于
PERM元模型 (Policy, Effect, Request, Matchers) [策略，效果，請求，匹配器]， 反映了權(quán)限的本質(zhì) – 訪問控制
- Policy: 定義權(quán)限的規(guī)則
- Effect: 定義組合了多個 Policy 之后的結(jié)果, allow/deny
- Request: 訪問請求, 也就是誰想操作什么
- Matcher: 判斷 Request 是否滿足 Policy
匹配來源：定義的 request 和 存儲的 police 比對判斷。
所有 model file 中主要就是定義 PERM 4 個部分的一個文件（ model.conf , 這個文件一般是固定的）。
因此，切換或升級項目的授權(quán)機制與修改配置一樣簡單。 您可以通過組合可用的模型來定制您自己的訪問控制模型（ACL， RBAC, ABAC）。
例如，您可以在一個model中獲得RBAC角色和ABAC屬性，并共享一組policy規(guī)則。
g, g2, g3 表示不同的 RBAC 體系, _, _ 表示用戶和角色 _, _, _ 表示用戶, 角色, 域(也就是租戶)
rbac_models.conf
# Request definition [request_definition] r = sub, obj, act # Policy definition [policy_definition] p = sub, obj, act # Policy effect [policy_effect] e = some(where (p.eft == allow)) # Matchers [matchers] m = r.sub == p.sub && r.obj == p.obj && r.act == p.act
實戰(zhàn)
一般運用到項目后臺的管理權(quán)限中
初始化數(shù)據(jù)庫
初始化環(huán)境后，系統(tǒng)會在你選擇的數(shù)據(jù)庫自動生成一個casbin_rule的數(shù)據(jù)庫表
用戶權(quán)限的增刪改查
tips：這些接口，需要放在截器中間件前面， 不然空表無法添加數(shù)據(jù)
//使用自定義攔截器中間件 r.Use(Authorize())
//增加policy
r.POST("/api/v1/add", func(c *gin.Context) {
fmt.Println("增加Policy")
if ok, _ := Enforcer.AddPolicy("admin", "/api/v1/world", "GET"); !ok {
fmt.Println("Policy已經(jīng)存在")
} else {
fmt.Println("增加成功")
}
})
//刪除policy
r.DELETE("/api/v1/delete", func(c *gin.Context) {
fmt.Println("刪除Policy")
if ok, _ := Enforcer.RemovePolicy("admin", "/api/v1/world", "GET"); !ok {
fmt.Println("Policy不存在")
} else {
fmt.Println("刪除成功")
}
})
//獲取policy
r.GET("/api/v1/get", func(c *gin.Context) {
fmt.Println("查看policy")
list := Enforcer.GetPolicy()
for _, vlist := range list {
for _, v := range vlist {
fmt.Printf("value: %s, ", v)
}
}
})
添加權(quán)限，訪問其添加接口
單個用戶保存權(quán)限的路由是多條記錄
在使用Casbin中間件時，會訪問表中的數(shù)據(jù)庫表 ,得到相應(yīng)的權(quán)限信息，增加訪問信息后，訪問接口成功
代碼
package main
import (
"fmt"
"github.com/casbin/casbin"
xormadapter "github.com/casbin/xorm-adapter"
"github.com/gin-gonic/gin"
_ "github.com/go-sql-driver/mysql"
"log"
"net/http"
)
var Enforcer *casbin.Enforcer
func init() {
CasbinSetup()
}
// 初始化casbin
func CasbinSetup(){
a, err := xormadapter.NewAdapter("mysql", "root:root123@tcp(127.0.0.1:3306)/casbin?charset=utf8", true)
if err != nil {
log.Printf("連接數(shù)據(jù)庫錯誤: %v", err)
return
}
e, err := casbin.NewEnforcer("./conf/rbac_models.conf", a)
if err != nil {
log.Printf("初始化casbin錯誤: %v", err)
return
}
Enforcer = e
//return e
}
func Hello(c *gin.Context) {
fmt.Println("Hello 接收到GET請求..")
c.JSON(http.StatusOK, gin.H{
"code": 200,
"msg": "Success",
"data": "Hello 接收到GET請求..",
})
}
func main() {
//獲取router路由對象
r := gin.New()
//增加policy
r.GET("/api/v1/add", func(c *gin.Context) {
fmt.Println("增加Policy")
if ok, _ := Enforcer.AddPolicy("admin", "/api/v1/world", "GET"); !ok {
fmt.Println("Policy已經(jīng)存在")
} else {
fmt.Println("增加成功")
}
})
//刪除policy
r.DELETE("/api/v1/delete", func(c *gin.Context) {
fmt.Println("刪除Policy")
if ok, _ := Enforcer.RemovePolicy("admin", "/api/v1/world", "GET"); !ok {
fmt.Println("Policy不存在")
} else {
fmt.Println("刪除成功")
}
})
//獲取policy
r.GET("/api/v1/get", func(c *gin.Context) {
fmt.Println("查看policy")
list := Enforcer.GetPolicy()
for _, vlist := range list {
for _, v := range vlist {
fmt.Printf("value: %s, ", v)
}
}
})
//使用自定義攔截器中間件
r.Use(Authorize())
//創(chuàng)建請求
r.GET("/api/v1/hello", Hello)
r.Run(":9000") //參數(shù)為空 默認(rèn)監(jiān)聽8080端口
}
//攔截器
func Authorize() gin.HandlerFunc {
return func(c *gin.Context) {
//var e *casbin.Enforcer
e := Enforcer
//從DB加載策略
e.LoadPolicy()
//獲取請求的URI
obj := c.Request.URL.RequestURI()
//獲取請求方法
act := c.Request.Method
//獲取用戶的角色 應(yīng)該從db中讀取
sub := "admin"
//判斷策略中是否存在
if ok, _ := e.Enforce(sub, obj, act); ok {
fmt.Println("恭喜您,權(quán)限驗證通過")
c.Next() // 進行下一步操作
} else {
fmt.Println("很遺憾,權(quán)限驗證沒有通過")
c.Abort()
}
}
}
總代碼
package main
import (
"fmt"
"github.com/casbin/casbin"
xormadapter "github.com/casbin/xorm-adapter"
"github.com/gin-gonic/gin"
_ "github.com/go-sql-driver/mysql"
"log"
"net/http"
)
var Enforcer *casbin.Enforcer
func init() {
CasbinSetup()
}
// 初始化casbin
func CasbinSetup(){
a, err := xormadapter.NewAdapter("mysql", "root:root123@tcp(127.0.0.1:3306)/casbin?charset=utf8", true)
if err != nil {
log.Printf("連接數(shù)據(jù)庫錯誤: %v", err)
return
}
e, err := casbin.NewEnforcer("./conf/rbac_models.conf", a)
if err != nil {
log.Printf("初始化casbin錯誤: %v", err)
return
}
Enforcer = e
//return e
}
func Hello(c *gin.Context) {
fmt.Println("Hello 接收到GET請求..")
c.JSON(http.StatusOK, gin.H{
"code": 200,
"msg": "Success",
"data": "Hello 接收到GET請求..",
})
}
func main() {
//獲取router路由對象
r := gin.New()
//增加policy
r.GET("/api/v1/add", func(c *gin.Context) {
fmt.Println("增加Policy")
if ok, _ := Enforcer.AddPolicy("admin", "/api/v1/world", "GET"); !ok {
fmt.Println("Policy已經(jīng)存在")
} else {
fmt.Println("增加成功")
}
})
//刪除policy
r.DELETE("/api/v1/delete", func(c *gin.Context) {
fmt.Println("刪除Policy")
if ok, _ := Enforcer.RemovePolicy("admin", "/api/v1/world", "GET"); !ok {
fmt.Println("Policy不存在")
} else {
fmt.Println("刪除成功")
}
})
//獲取policy
r.GET("/api/v1/get", func(c *gin.Context) {
fmt.Println("查看policy")
list := Enforcer.GetPolicy()
for _, vlist := range list {
for _, v := range vlist {
fmt.Printf("value: %s, ", v)
}
}
})
//使用自定義攔截器中間件
r.Use(Authorize())
//創(chuàng)建請求
r.GET("/api/v1/hello", Hello)
r.Run(":9000") //參數(shù)為空 默認(rèn)監(jiān)聽8080端口
}
//攔截器
func Authorize() gin.HandlerFunc {
return func(c *gin.Context) {
//var e *casbin.Enforcer
e := Enforcer
//從DB加載策略
e.LoadPolicy()
//獲取請求的URI
obj := c.Request.URL.RequestURI()
//獲取請求方法
act := c.Request.Method
//獲取用戶的角色 應(yīng)該從db中讀取
sub := "admin"
//判斷策略中是否存在
if ok, _ := e.Enforce(sub, obj, act); ok {
fmt.Println("恭喜您,權(quán)限驗證通過")
c.Next() // 進行下一步操作
} else {
fmt.Println("很遺憾,權(quán)限驗證沒有通過")
c.Abort()
}
}
}
封裝后的代碼
package mycasbin
import (
"simple-api/mongoose"
"github.com/casbin/mongodb-adapter"
"github.com/casbin/casbin"
"gopkg.in/mgo.v2/bson"
)
type CasbinModel struct {
ID bson.ObjectId `json:"id" bson:"_id"`
Ptype string `json:"ptype" bson:"ptype"`
RoleName string `json:"rolename" bson:"v0"`
Path string `json:"path" bson:"v1"`
Method string `json:"method" bson:"v2"`
}
//添加權(quán)限
func (c *CasbinModel) AddCasbin(cm CasbinModel) bool {
e := Casbin()
e.AddPolicy(cm.RoleName, cm.Path, cm.Method)
return true
}
//持久化到數(shù)據(jù)庫
// "github.com/casbin/mongodb-adapter"
// func Casbin() *casbin.Enforcer {
// a := mongodbadapter.NewAdapter(mongoose.MongoUrl)
// e := casbin.NewEnforcer("conf/auth_model.conf", a)
// e.LoadPolicy()
// return e
// }
func Casbin() *casbin.Enforcer {
a := mongodbadapter.NewAdapter(mongoose.MongoUrl)
e, err := casbin.NewEnforcer("conf/auth_model.conf", a)
if err != nil {
panic(err)
}
e.LoadPolicy()
return e
}
package apis
import (
"net/http"
"simple-api/utils/mycasbin"
"github.com/gin-gonic/gin"
"gopkg.in/mgo.v2/bson"
)
var (
casbins = mycasbin.CasbinModel{}
)
func AddCasbin(c *gin.Context) {
rolename := c.PostForm("rolename")
path := c.PostForm("path")
method := c.PostForm("method")
ptype := "p"
casbin := mycasbin.CasbinModel{
ID: bson.NewObjectId(),
Ptype: ptype,
RoleName: rolename,
Path: path,
Method: method,
}
isok := casbins.AddCasbin(casbin)
if isok {
c.JSON(http.StatusOK, gin.H{
"success": true,
"msg": "保存成功",
})
} else {
c.JSON(http.StatusOK, gin.H{
"success": false,
"msg": "保存失敗",
})
}
}
參考
https://www.jianshu.com/p/9506406e745f
到此這篇關(guān)于go語言使用Casbin實現(xiàn)角色的權(quán)限控制的文章就介紹到這了,更多相關(guān)go語言角色權(quán)限控制內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
在Go語言中,匿名嵌套結(jié)構(gòu)體和與類型同名的嵌套結(jié)構(gòu)體不是完全等價的,它們有一些重要的區(qū)別,這篇文章主要介紹了Go語言中匿名嵌套和類型嵌套的區(qū)別,需要的朋友可以參考下2023-09-09
這篇文章主要介紹了GO語言獲取系統(tǒng)環(huán)境變量的方法,實例分析了Getenv方法操作環(huán)境變量的技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-02-02
VS Code配置Go語言開發(fā)環(huán)境的詳細教程
這篇文章主要介紹了VS Code配置Go語言開發(fā)環(huán)境的詳細教程，本文通過實例代碼圖文相結(jié)合的形式給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-05-05
Go語言的unsafe包被譽為黑科技，它為Go語言提供了底層訪問和操控內(nèi)存的能力，本文將深入探討Go語言中unsafe包的使用方法和注意事項，需要的可以參考一下2023-04-04
Golang?作為一種高效的編程語言,提供了多種方法來實現(xiàn)并發(fā)發(fā)送?HTTP?請求,本文將深入探討?Golang?中并發(fā)發(fā)送?HTTP?請求的最佳技術(shù)和實踐,希望對大家有所幫助2024-02-02
這篇文章主要詳細介紹了Golang中函數(shù)的使用方法，文中有詳細的示例代碼，對大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2023-05-05
平時在項目開發(fā)過程中少不了對錯誤的處理,一個好用的系統(tǒng)首先要確保其健壯性,不能經(jīng)常發(fā)生錯誤就卡死之類的情況,為了讓我們的程序更加健壯,我們就需要知道golang里的錯誤處理機制是怎么樣的,這篇文章帶大家一起學(xué)習(xí),需要的朋友跟著小編一起來看看吧2024-05-05
本文主要介紹了Go語言Grpc?Stream的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-06-06
Go語言性能監(jiān)控和調(diào)優(yōu)的工具和方法
本文介紹了Go語言性能監(jiān)控和調(diào)優(yōu)的工具和方法,包括?pprof、expvar?和?trace?等工具的使用方法和注意事項,以及性能調(diào)優(yōu)的一些常見方法,如減少內(nèi)存分配、避免頻繁的垃圾回收、避免過度查詢數(shù)據(jù)庫等,針對不同的程序,應(yīng)該根據(jù)實際情況采用不同的優(yōu)化方法2024-01-01
這篇文章主要介紹了golang逐行讀取文件的操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-12-12