索引：https://waterflow.link/articles/1666534616841 我们先看一个简单的例子，我们自定义一个错误，用来把多个错误放在一起输出： type CustomError struct { errors []string } func (c *CustomError) Add(err string) { c.errors = append(c.errors, err) } func (c *CustomError) Error() string { return strings.J…
hello，大家好呀，我是小楼。 前几天不是写了这篇文章《发现一个开源项目优化点，点进来就是你的了》嘛。 文章介绍了Sentinl的自适应缓存时间戳算法，从原理到实现都手把手解读了，而且还发现Sentinel-Go还未实现这个自适应算法，于是我就觉得，这简单啊，把Java代码翻译成Go不就可以混个PR？ 甚至在文章初稿中把这个描述为：「有手就可以」，感觉不太妥当，后来被我删掉了。 过了几天，我想去看看有没有人看了我的文章真的去提了个PR，发现仍然是没有，心想，可能是大家太忙（懒）了吧。 于是准备自己来实现一遍，周末…
0、转载 go-zero docker-compose 搭建课件服务（六）：完善jwt鉴权和返回结构 0.1源码地址 https://github.com/liuyuede123/go-zero-courseware 1、用户服务登录接口生成jwt token user/api/etc/user.yaml中增加用于生成jwt的secret和过期时间 ... Auth: AccessSecret: 38f9c7af24ff11edb92900163e30ef81 AccessExpire: 86400 user/ap…
书接上回，上一回我们完成了用户管理页面的构建，并且通过前端的Vue.js框架动态地获取表单数据，同时异步请求后端Iris接口进行入库操作，过程中使用函数封装可复用的逻辑。 本回我们将继续完善用户管理功能。 唯一索引 虽然在之前的章节中已经完成了用户添加（注册）的功能，然而我们忽略了一个重要的细节，那就是用户名（username）应该是全局唯一的字段，而添加逻辑中并未做唯一性校验，事实上唯一性校验有两种方案，一种是入库之前做一次查询，但这样会浪费一次磁盘的IO操作，另外一种就是通过唯一索引进行拦截操作，这里我们采用后…
判断是否实现接口 Go 里面没有 implements 关键字来判断一个结构体 (对象) 是否实现了某个接口， 要实现类似的功能， 需要用到 类型断言。 类型断言 // 判断 v 是否实现了接口 i // 返回值 ok 为 true 表示已实现，ok 为 false 表示未实现 if _, ok := v.(i); ok { // do something... } 例子 判断是否实现接口 package main import "fmt" type geometry interface { …
0、转载 go-zero docker-compose 搭建课件服务（一）：编写服务api和proto 0.1源码地址 https://github.com/liuyuede123/go-zero-courseware 1、创建项目目录 mkdir go-zero-courseware cd go-zero-courseware 2、安装goctl # 安装 GOPROXY=https://goproxy.cn/,direct go install github.com/zeromicro/go-zero/tool…
0.1、索引 https://blog.waterflow.link/articles/1663078266267 当我们下载一个大文件的时候，会因为下载时间太久而超时或者出错。那么我么我们可以利用goroutine的特性并发分段的去请求下载资源。 1、Accept-Ranges 首先下载链接需要在响应中返回Accept-Ranges，并且它的值不为 “none”，那么该服务器支持范围请求。比如我们可以利用HEAD请求来进行检测 ... // head请求获取url的header head, err := http…
我的gRPC之旅。使用gRPC一元通信模式和双向流通信模式写一个简单的控制台聊天室。实现创建用户和实时聊天两个功能，不考虑高性能。复习了内存同步访问Sync包的使用。用切片缓存聊天记录，新用户可以同步聊天记录。 效果 使用gRPC一元通信模式和双向流通信模式写一个简单的控制台聊天室。实现创建用户和实时聊天两个功能，不考虑高性能。复习了内存同步访问Sync包的使用。用切片缓存聊天记录，新用户可以同步聊天记录。 PS C:\Users\小能喵喵喵\Desktop\Go\gRPC\chatroom> tree /f…
今天这篇笔记我们记录sync包下面的Cond,Once和Pool Cond cond就是条件，当条件不满足的时候等待Wait()，条件满足后，继续执行。 通过Signal()和Broadcast()来通知wait结束，继续执行。我们先来看一个Signal通知的例子 func main() { c := sync.NewCond(&sync.Mutex{}) queue := make([]interface{}, 0, 10) removeFromQueue := func(delay time.Durat…