开始使用
安装
Go
go get github.com/casbin/casbin/v2
Java
<dependency>
<groupId>org.casbin</groupId>
<artifactId>jcasbin</artifactId>
<version>1.6.0</version>
</dependency>
Node.js
# NPM
npm install casbin --save
# Yarn
yarn add casbin
PHP
composer.json 中需要这个软件包。这将下载软件包:
composer require casbin/casbin
Python
pip install casbin
.NET
dotnet add package Casbin.NET
Rust
cargo install cargo-edit
cargo add casbin
// 如果你使用异步标准作为异步执行者
cargo add async-std
// 如果你使用tokio作为异步执行者
cargo add tokio // 请确保您激活了其`macros`特性
新建一个Casbin enforcer
Casbin使用配置文件来设置访问控制模型
它有两个配置文件, model.conf 和 policy.csv。 其中, model.conf 存储了我们的访问模型, 而 policy.csv 存储的是我们具体的用户权限配置。 Casbin的使用非常精炼。 基本上,我们只需要一种主要的结构:enforcer 当构造这个结构的时候, model.conf 和 policy.csv 将会被加载。
用另一种说法就是,当新建Casbin enforcer的时候 你必须提供一个 Model 和一个 Adapter。
Casbin拥有一个 FileAdapter, 想知道更多请查阅 “更多Adapter” 中的Adapter
- 使用Model文件和默认 FileAdapter:
Go
import "github.com/casbin/casbin/v2"
e, err := casbin.NewEnforcer("path/to/model.conf", "path/to/policy.csv")
Java
import org.casbin.jcasbin.main.Enforcer;
Enforcer e = new Enforcer("path/to/model.conf", "path/to/policy.csv");
Node.js
import { newEnforcer } from 'casbin';
const e = await newEnforcer('path/to/model.conf', 'path/to/policy.csv');
PHP
require_once './vendor/autoload.php';
use Casbin\Enforcer;
$e = new Enforcer("path/to/model.conf", "path/to/policy.csv");
Python
import casbin
e = casbin.Enforcer("path/to/model.conf", "path/to/policy.csv")
.NET
using NetCasbin;
var e = new Enforcer("path/to/model.conf", "path/to/policy.csv");
Delphi
var
casbin: ICasbin;
begin
casbin := TCasbin.Create('path/to/model.conf', 'path/to/policy.csv');
...
end
Rust
use casbin::prelude::*;
// 如果你使用async_td作为异步执行器
#[cfg(feature = "runtime-async-std")]
#[async_std::main]
async fn main() -> Result<()> {
let mut e = Enforcer::new("path/to/model.conf", "path/to/policy.csv").await?;
Ok(())
}
// 如果你使用tokio作为异步执行器
#[cfg(feature = "runtime-tokio")]
#[tokio::main]
async fn main() -> Result<()> {
let mut e = Enforcer::new("path/to/model.conf", "path/to/policy.csv").await?;
Ok(())
}
- 与其他Adapter一起使用Model text
Go
import (
"log"
"github.com/casbin/casbin/v2"
"github.com/casbin/casbin/v2/model"
xormadapter "github.com/casbin/xorm-adapter/v2"
_ "github.com/go-sql-driver/mysql"
)
// 使用MySQL数据库初始化一个Xorm适配器
a, err := xormadapter.NewAdapter("mysql", "mysql_username:mysql_password@tcp(127.0.0.1:3306)/casbin")
if err != nil {
log.Fatalf("error: adapter: %s", err)
}
m, err := model.NewModelFromString(`
[request_definition]
r = sub, obj, act
[policy_definition]
p = sub, obj, act
[policy_effect]
e = some(where (p.eft == allow))
[matchers]
m = r.sub == p.sub && r.obj == p.obj && r.act == p.act
`)
if err != nil {
log.Fatalf("error: model: %s", err)
}
e, err := casbin.NewEnforcer(m, a)
if err != nil {
log.Fatalf("error: enforcer: %s", err)
}
检查权限
在访问发生之前,在代码中添加 enforcement hook
Go
sub := "alice" // 想要访问资源的用户
obj := "data1" // 将要被访问的资源
act := "read" // 用户对资源的操作
ok, err := e.Enforce(sub, obj, act)
if err != nil {
// 处理err
}
if ok == true {
// 允许alice读取data1
} else {
// 拒绝请求,抛出异常
}
// 您可以使用BatchEnforce()来批量执行一些请求
// 这个方法返回布尔切片,此切片的索引对应于二维数组的行索引。
// 例如results[0] 是{"alice", "data1", "read"}的结果
results, err := e.BatchEnforce([[] []interface{}{"alice", "data1", "read"}, {"bob", datata2", "write"}, {"jack", "data3", "read"}})
Java
String sub = "alice"; // 想要访问资源的用户
String obj = "data1"; // 将要被访问的资源
String act = "read"; // 用户对资源进行的操作
if (e.enforce(sub, obj, act) == true) {
// 允许alice读取data1
} else {
// 拒绝请求,抛出异常
}
Node.js
const sub = 'alice'; // 想要访问资源的用户
const obj = 'data1'; // 将要被访问的资源
const act = 'read'; // 用户对资源进行的操作
if ((await e.enforce(sub, obj, act)) === true) {
// 允许alice读取data1
} else {
// 拒绝请求,抛出异常
}
PHP
$sub = "alice"; // 想要访问资源的用户
$obj = "data1"; // 将要被访问的资源
$act = "read"; // 用户对资源进行的操作
if ($e->enforce($sub, $obj, $act) === true) {
// 允许alice读取data1
} else {
// 拒绝请求,抛出异常
}
Python
sub = "alice" # 想要访问资源的用户
obj = "data1" # 将要被访问的资源
act = "read" # 用户对资源进行的操作
if e.enforce(sub, obj, act):
# 允许alice读取data1
pass
else:
# 拒绝请求,抛出异常
pass
.NET
var sub = "alice"; # 想要访问资源的用户
var obj = "data1"; # 将要被访问的资源
var act = "read"; # 用户对资源进行的操作
if (await e.EnforceAsync(sub, obj, act))
{
// 允许alice读取data1
}
else
{
// 拒绝请求,抛出异常
}
Delphi
if casbin.enforce(['alice,data1,read']) then
// Alice很开兴它能够读取data1了
else
// Alice很伤心
Rust
let sub = "alice"; // 想要访问资源的用户
let obj = "data1"; // 将会被访问的资源
let act = "read"; // 用户对资源的操作
if e.enforce((sub, obj, act)).await? {
// 允许alice读取data1
} else {
// 发生错误
}
Casbin 还提供了在运行时管理用户权限的API。例如,您可以通过以下方式查询分配给某个用户的所有角色:
Go
roles := e.GetRolesForUser("alice")
Java
Roles roles = e.getRolesForUser("alice");
Node.js
const roles = await e.getRolesForUser('alice');
PHP
$roles = $e->getRolesForUser("alice");
Python
roles = e.get_roles_for_user("alice")
.NET
var roles = e.GetRolesForUser("alice");
Delphi
roles = e.rolesForEntity("alice")
Rust
let roles = e.get_roles_for_user("alice");
请参阅 Management API and RBAC API 以获取更多使用方式。
请查看测试用例以获取更多使用方式。
最后编辑: kuteng 文档更新时间: 2021-06-22 19:03 作者:kuteng