Golang Http 验证码示例

验证码(CAPTCHA)是“Completely Automated Public Turing test to tell Computers and Humans Apart”(全自动区分计算机和人类的图灵测试)的缩写,是一种区分用户是计算机还是人的公共全自动程序。可以防止:恶意破解密码、刷票、论坛灌水,有效防止某个黑客对某一个特定注册用户用特定程序暴力破解方式进行不断的登陆尝试,实际上用验证码是现在很多网站通行的方式,我们利用比较简易的方式实现了这个功能。这个问题可以由计算机生成并评判,但是必须只有人类才能解答。由于计算机无法解答CAPTCHA的问题,所以回答出问题的用户就可以被认为是人类。

一起学context(二)——超时控制

上一篇文章讲到如何使用context来传值,实际上context还有另外一个重要功能——goroutine的超时控制。
很多时候goroutine如果不设超时,一旦发生阻塞将无限等待,协程数会越来越多,导致耗尽服务器内存。

分类

拥有超时控制的context有以下几种:

一起学context(一)——上下文值传递

系列开篇

本文开始将针对context的用法进行系统化讨论,在这里你将能够在工作中合理使用context解决一些比较棘手的问题。

context处理超时处理之外还可以用来保存数据,当你需要在多个上下文传递时传递数据,那么本文提到的知识可以排上用场。

示例代码

示例代码为一个简单的http服务,流程是登录之后会跳转首页,首页通过guard中间件进行鉴权。当然,示例代码未做其他诸如连接数据库之类的处理,这不是本文的重点。
守卫函数读取cookie之后将cookie值写入context并向下传递,在整个请求中可以说是“透明”的。当访问到需要保护的接口时检测到没有提供cookie,则直接终端请求,否则通过r.WithContext将username的值存入cookie,避免的业务接口直接读取cookie的弊端。因为如果后期更改鉴权算法的话,业务代码可以不用更改,直接更改中间件即可。

io.Reader游标引发的血案

#背景
线上运行了一个图片合成程序,默认的小程序二维码中奖是小程序LOGO,不满足需求,所以将微信小程序二维码和用户头像合成在一张图片。
由于微信图片有时候返回的Content-Type不对应(比如内容是PNG的,头确是image/jpeg)所以使用jpeg/png/gif的顺序进行图片数据解析,哪个成功就返回解析结果。

#问题
总是出现诸如invalid JPEG format: missing SOI marker

#解决过程
我去查看jpeg.Decode的源码,如下:

1
2
3
4
5
6
7
8
9
10
11
func (d *decoder) decode(r io.Reader, configOnly bool) (image.Image, error) {
d.r = r

// Check for the Start Of Image marker.
if err := d.readFull(d.tmp[:2]); err != nil {
return nil, err
}
if d.tmp[0] != 0xff || d.tmp[1] != soiMarker {
return nil, FormatError("missing SOI marker")
}
...

golang40行代码实现通用协程池

代码仓库

goroutine-pool

golang 的协程管理

golang 协程机制很方便的解决了并发编程的问题,但是协程并不是没有开销的,所以也需要适当限制一下数量。

不使用协程池的代码(示例代码使用 chan 实现,代码略啰嗦)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
func (p *converter) upload(bytes [][]byte) ([]string, error) {
ch := make(chan struct{}, 4)
wg := &sync.WaitGroup{}
wg.Add(len(bytes))
ret := make([]string, len(bytes))

// 上传
for index, item := range bytes {
ch <- struct{}{}
go func(index int, imageData []byte) {
defer func() {
wg.Done()
<-ch
}()

link, err := qiniu.UploadBinary(imageData, fmt.Sprintf("%d.png", time.Now().UnixNano()))
if err != nil {
log.Println("上传图片失败", err.Error())
return
}
ret[index] = link
}(index, item)
}

wg.Wait()
return ret, nil
}

golang不到30行代码实现依赖注入

项目地址

go-di-demo

本项目依赖

使用标准库实现,无额外依赖

依赖注入的优势

用java的人对于spring框架一定不会陌生,spring核心就是一个IoC(控制反转/依赖注入)容器,带来一个很大的优势是解耦。一般只依赖容器,而不依赖具体的类,当你的类有修改时,最多需要改动一下容器相关代码,业务代码并不受影响。

不到20行代码实现golang路由调度

项目地址

go-dispatcher

本项目依赖

使用标准库实现,无额外依赖

为什么需要路由调度层

golang使用travis进行持续集成

虽然golang的工程工具已经非常完善了,比如测试、代码格式化等等。但是如果开发library开源到github的话,这些东西是可以使用自动化工具完成的,那就是 travis

使用步骤

  1. 开发好需要集成的library以及测试用例

golang for遍历channel时需要注意的问题

最近在做一个基于RabbitMQ的应用,由于官方的qos没有golang的版本,所以出了一点问题。问题代码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
_, ch, err := component.NewRabbitMQ()
if err != nil {
panic(err)
}
if err := ch.Qos(10, 0, true); err != nil {
panic(err)
}
msgs, err := ch.Consume("push", "", false, false, false, false, nil)
if err != nil {
panic(err)
}
for m := range msgs {
go func(d *amqp.Delivery) {
defer func() { d.Ack(false) }
// 处理消息
}(&m)
}

发现消费到10条消息,进程就退出了,但是exit code为0,表示系统是正常退出,由于做了日志记录可以确定消费了10条,所以初步确定是qos相关问题。

golang解决TCP粘包问题

什么是TCP粘包问题以及为什么会产生TCP粘包,本文不加讨论。本文使用golang的bufio.Scanner来实现自定义协议解包。

协议数据包定义

本文模拟一个日志服务器,该服务器接收客户端传到的数据包并显示出来

1
2
3
4
5
6
7
8
9
10
type Package struct {
Version [2]byte // 协议版本,暂定V1
Length int16 // 数据部分长度
Timestamp int64 // 时间戳
HostnameLength int16 // 主机名长度
Hostname []byte // 主机名
TagLength int16 // 标签长度
Tag []byte // 标签
Msg []byte // 日志数据
}
Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×