Golang简单消息队列处理项目实例-Golang-PHP中文网

Golang简单消息队列处理项目实例

P粉602998670

发布： 2025-09-09 11:36:03

原创

848人浏览过

答案：使用Redis的LPush和BRPop命令结合Golang的goroutine可高效实现消息队列。1. 定义Message结构体并用JSON序列化；2. 通过redis.Client实现Push推送消息；3. Consume方法内使用BRPop阻塞获取消息并处理；4. 利用context控制消费循环的生命周期，支持优雅关闭，适用于异步任务与服务解耦场景。

golang简单消息队列处理项目实例

用Golang做简单消息队列，核心是选对工具和模式。直接上手Redis配合Go的并发特性，能快速搭出一个可靠又高效的系统。下面是一个基于Redis的实用项目实例，适合处理异步任务、解耦服务等场景。

使用Redis + Golang搭建基础消息队列

Redis的

LPush

登录后复制

和

BRPop

登录后复制

命令天然适合做消息队列。结合Golang的goroutine，能轻松实现生产者-消费者模型。

关键点：

生产者调用
```
LPush
```
登录后复制
把消息推入Redis列表
消费者用
```
BRPop
```
登录后复制
阻塞式地从列表右侧取出消息
消息结构建议用JSON，方便跨语言和调试
使用
```
context
```
登录后复制
控制生命周期，支持优雅关闭

核心代码实现

定义消息结构和队列操作：

立即学习“go语言免费学习笔记（深入）”；

MindShow

MindShow官网 | AI生成PPT，快速演示你的想法

1492

查看详情

type Message struct { ID string `json:"id"` Content string `json:"content"` Created time.Time `json:"created"` } type Queue struct { client *redis.Client Name string } func NewQueue(redisAddr, queueName string) *Queue { rdb := redis.NewClient(&redis.Options{ Addr: redisAddr, DB: 0, }) return &Queue{client: rdb, Name: queueName} }

生产者推送消息：

func (q *Queue) Push(msg Message) error { jsonData, _ := json.Marshal(msg) return q.client.LPush(context.Background(), q.Name, jsonData).Err() }

消费者处理消息：

func (q *Queue) Consume(ctx context.Context, processMsg func(Message) error) { for { select { case