golang hibiken 这个消息队列怎么控制个 queue 的并发

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

The Go Programming Language

› http://golang.org/

› Go Playground

Go Projects

› Revel Web Framework

这是一个创建于 248 天前的主题，其中的信息可能已经有所发展或是发生改变。

https://github.com/hibiken/asynq

看文档，

	srv := asynq.NewServer(
		asynq.RedisClientOpt{Addr: ":6379"},
		asynq.Config{Concurrency: 20}, //并发控制
	)

	h := asynq.NewServeMux()
	// ... Register handlers

	// Run blocks and waits for os signal to terminate the program.
	if err := srv.Run(h); err != nil {
		log.Fatal(err)
	}

这个是对于整个项目的并发，现在只需要对于不同任务的并发控制，不知道怎么实现。

5 条回复 • 2024-04-06 13:45:19 +08:00

qloog

248 天前

可以控制队列的优先级，也就变相的控制了某个队列的并发数：

srv := asynq.NewServer(
asynq.RedisClientOpt{Addr: redisAddr},
asynq.Config{
// Specify how many concurrent workers to use
Concurrency: 10,
// Optionally specify multiple queues with different priority.
Queues: map[string]int{
"queue1": 6,
"queue2": 3,
"queue3": 1,
},
// See the godoc for other configuration options
},
)

awanganddong

248 天前

https://github.com/hibiken/asynq/wiki/Queue-Priority#strict-priority

这种勉强能实现，但是不太正确。

awanganddong

247 天前

找到解决方案了，可以再重新起一个 server

然后记得指定就可以了
client.Enqueue(task1, asynq.Queue("notifications"))

qloog

234 天前

这个 server 专门跑 notifications 队列？

awanganddong

230 天前

不是，是一些牵扯到扣费的逻辑，为了保证用户余额的一致性，然后串行扣费。