用go封装一下封禁功能

news/2025/2/19 17:20:24/

思路

封禁业务也是在一般项目中比较常见的业务。我们也将它封装在库中作为功能之一。
我们同样使用adapter作为底层的存储结构,将封禁标示作为k-v结构存储。
把id和服务名称service作为key,把封禁的级别level作为value,以此我们能实现一些比较常见的封禁业务。

实现

首先就是封禁方法,首先当然要校验一下参数,然后存储封禁标识。要注意的就是level要大于等于1,在封禁后也要调用我们的logger和watcher。
github.com/weloe/token…

// Banned ban user, if time == 0,the timeout is not set
func (e *Enforcer) Banned(id string, service string, level int, time int64) error {if id == "" || service == "" {return fmt.Errorf("parameter cannot be nil")}if level < 1 {return fmt.Errorf("unexpected level = %v, level must large or equal 1", level)}err := e.adapter.SetStr(e.spliceBannedKey(id, service), strconv.Itoa(level), time)if err != nil {return err}// callbacke.logger.Ban(e.loginType, id, service, level, time)if e.watcher != nil {e.watcher.Ban(e.loginType, id, service, level, time)}return nil
}

再来就是解除封禁的实现,很简单,只要删除我们封禁存的那条记录就可以了。

// UnBanned Unblock user account
func (e *Enforcer) UnBanned(id string, services ...string) error {if id == "" {return fmt.Errorf("parmeter id can not be nil")}if len(services) == 0 {return fmt.Errorf("parmeter services length can not be 0")}for _, service := range services {err := e.adapter.DeleteStr(e.spliceBannedKey(id, service))if err != nil {return err}e.logger.UnBan(e.loginType, id, service)if e.watcher != nil {e.watcher.UnBan(e.loginType, id, service)}}return nil
}

接着还需要提供几个方便使用的方法

分别用来判断是否被封禁,获得封禁的级别,获得封禁的剩余时间三个方法

github.com/weloe/token…

判断是否被封禁

// IsBanned if banned return true, else return false
func (e *Enforcer) IsBanned(id string, services string) bool {s := e.adapter.GetStr(e.spliceBannedKey(id, services))return s != ""
}

获得封禁的级别

go复制代码// GetBannedLevel get banned level
func (e *Enforcer) GetBannedLevel(id string, service string) (int64, error) {str := e.adapter.GetStr(e.spliceBannedKey(id, service))if str == "" {return 0, fmt.Errorf("loginId = %v, service = %v is not banned", id, service)}time, err := strconv.ParseInt(str, 10, 64)if err != nil {return 0, err}return time, nil
}

github.com/weloe/token…
获得封禁的剩余时间

go复制代码// GetBannedTime get banned time
func (e *Enforcer) GetBannedTime(id string, service string) int64 {timeout := e.adapter.GetStrTimeout(e.spliceBannedKey(id, service))return timeout
}

有了这几个方法,我们就可以使用token-go更为方便是实现登录业务了。
对于一般的业务,我们其实可以无视封禁级别。只需要使用Banned()进行封禁,在每个需要校验是否被封禁的业务前进行IsBanned()的判断就行了。
测试例子:

go复制代码func TestEnforcer_Banned(t *testing.T) {err, enforcer, _ := NewTestEnforcer(t)if err != nil {t.Fatalf("NewTestEnforcer() failed: %v", err)}err = enforcer.Banned("1", "comment", 1, 100)if err != nil {t.Fatalf("Banned() failed: %v", err)}isBanned := enforcer.IsBanned("1", "comment")if !isBanned {t.Errorf("unexpected isBanned is false")}err = enforcer.UnBanned("1", "comment")if err != nil {t.Fatalf("UnBanned() failed: %v", err)}isBanned = enforcer.IsBanned("1", "comment")if isBanned {t.Errorf("unexpected isBanned is false")}
}

当然我们对于一个业务会有一些较为复杂的封禁,比如discuss交流业务,如果级别为1我们会禁止评论,如果级别为2我们会禁止评论和点赞,级别为3我们会禁止评论、点赞和收藏。
这个时候我们只需要再加上GetBannedLevel(),在每个业务前获取封禁级别进行判断就可以简单的实现了。


http://www.ppmy.cn/news/1182507.html

相关文章

AR眼镜安卓主板,智能眼镜光机方案定制

AR智能眼镜是一项涉及广泛技术的创新产品&#xff0c;它需要考虑到光学、显示、功耗、散热、延迟、重量以及佩戴人体工学等多个方面的因素&#xff0c;每一个项目都是技术进步所需攻克的难题。 在本文中&#xff0c;我们将重点讨论AR眼镜的主板和光学方案。 首先是AR智能眼镜的…

Cannot connect to the Docker

执行docker基础命令失败&#xff01; Cannot connect to the Docker daemon at unix:///var/run/docker.sock. Is the docker daemon running? 原因&#xff1a;docker服务没有启动。 解决方法&#xff1a;执行 systemctl start docker 即可。

GPT的广泛应用会对互联网公司造成挑战吗?——探讨GPT在实际使用中的应用和影响

文章目录 前言GPT 技术的背景和发展历程GPT 技术对互联网行业的影响GPT 技术在互联网行业中的应用GPT 技术对于用户隐私和数据安全的威胁GPT 技术对于人类工作岗位的影响加强 AI 伦理和监管加强 AI 安全性和隐私保护推动 AI 创新和发展&#xff0c;避免过度依赖 AIGPT 技术是一…

Leetcode刷题详解——不同路径

1. 题目链接&#xff1a;62. 不同路径 2. 题目描述&#xff1a; 一个机器人位于一个 m x n 网格的左上角 &#xff08;起始点在下图中标记为 “Start” &#xff09;。 机器人每次只能向下或者向右移动一步。机器人试图达到网格的右下角&#xff08;在下图中标记为 “Finish”…

Python基于微博的舆情分析、热搜可视化系统

博主介绍&#xff1a;✌程序员徐师兄、7年大厂程序员经历。全网粉丝30W、csdn博客专家、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ 1. 简介 基于Python Django的微博热搜、微博舆论可视化系统。通过微博舆情分析系统获取到最新微博舆情分析…

性能诊断工具对比+Prometheus(普罗米修斯)监控系统学习

【精选】Prometheus&#xff08;普罗米修斯&#xff09;监控系统_普罗米修斯监控_愿许浪尽天涯的博客-CSDN博客 Java 性能诊断工具 &#x1f3cd;️... Java自带的工具 JConsoleJVisualVMjmapjstackjcmd单机图形化诊断工具 YourKitJProfilerVisualVMArthas分布式诊断工具 Zipk…

SparkSQL综合案例-省份维度的销售情况统计分析

一、项目背景 二、项目需求 &#xff08;1&#xff09;需求 ①各省销售指标&#xff0c;每个省份的销售额统计 ②TOP3销售省份中&#xff0c;有多少家店铺日均销售额1000 ③TOP3省份中&#xff0c;各个省份的平均单价 ④TOP3省份中&#xff0c;各个省份的支付类型比例 &#x…

操作系统:进程与线程(三)死锁

一战成硕 2.4 死锁2.4.1 死锁的概念2.4.2 死锁的预防2.4.3 死锁避免2.4.4 死锁的检测和接触 2.4 死锁 2.4.1 死锁的概念 死锁的定义 多个进程因竞争资源而造成的一种僵局&#xff08;互相等待&#xff09; 死锁发生条件&#xff1a;互斥、不可剥夺、请求和保持、循环等待 死…