Skip to content

onnoink/go-rabbit-pool

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

5 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

go-rabbit-pool

纯Go写的RabbitMQ连接池,做了基本的测试,支持MaxLive,MaxIdle,MinAlive设置,其他设置也可以通options修改

使用方法

simple



var (
	minAlive = 4
	maxAlive = 16
	maxIdle  = 8
)

pool := NewPool(*url, MaxAlive(maxAlive), MaxIdle(maxIdle), MinAlive(minAlive))


// 获取连接实例,会被阻塞如果没有更多的连接可以获取 
// TODO 超时设置
con,err := pool.Acquire()


// 释放一个连接实例
err := pool.Release(con)

idle 超时设置

pool 实例通过options进行设置,pool支持最大idle设置,会自动释放连接,保持MaxIdle连接数量

About

A RabbitMQ connection pool write in pure go

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages