什么是河流？

River 是一个功能强大且易于使用的工具，旨在管理 Go 应用程序中的工作队列。想象一下，您有一项需要很长时间才能完成的任务，例如向数千名用户发送电子邮件或处理大图像。您可以将这些任务发送到队列并让 River 在后台运行它们，而不是阻塞主应用程序。

为什么要使用 River？

1. 简单：River 允许您只需几行代码即可创建和管理工作队列。
2. 可靠性：即使您的应用程序重新启动，您的作业也将始终运行。
3. 可扩展性：River 可以处理可变的工作负载并随着您的应用程序的增长而增长。
4. 灵活性：您可以自定义 River 的行为以满足您的特定需求。

你能用 River 做什么？

• 处理异步任务
• 发送电子邮件
• 处理图像
• 视频转码
• 数据导入
• 还有更多

安装与使用

1. 设施：
   去获取 github.com/riverqueue/river

2. 创建队列:
   

package main

import (
    "github.com/riverqueue/river"
)

func main() {
    queue := river.NewQueue("my-queue", "postgres://user:password@host:port/database")
}

1. 将作业排队：

type MyJob struct {
    Data string
}

queue.Enqueue(&MyJob{Data: "Hello, world!"})

1. 运行作业：

queue.Run()

结论
对于寻求简单高效的工作队列管理解决方案的 Go 开发人员来说，River 是一个不错的选择。它的功能和易用性使其成为任何需要后台任务处理的项目不可或缺的工具。

卢卡托尼·劳达莱斯

X/Twitter
GitHub

去#river #queue #opensource