答案：使用Redis的LPush和BRPop命令结合Golang的goroutine可高效实现消息队列。1. 定义Message结构体并用JSON序列化；2. 通过redis.Client实现Push推送消息；3. Consume方法内使用BRPop阻塞获取消息并处理；4. 利用context控制消费循环的生命周期，支持优雅关闭，适用于异步任务与服务解耦场景。
用Golang做简单消息队列，核心是选对工具和模式。直接上手Redis配合Go的并发特性，能快速搭出一个可靠又高效的系统。下面是一个基于Redis的实用项目实例，适合处理异步任务、解耦服务等场景。
使用Redis + Golang搭建基础消息队列
Redis的
LPush和
BRPop命令天然适合做消息队列。结合Golang的goroutine，能轻松实现生产者-消费者模型。
关键点：
- 生产者调用
LPush
把消息推入Redis列表 - 消费者用
BRPop
阻塞式地从列表右侧取出消息 - 消息结构建议用JSON，方便跨语言和调试
- 使用
context
控制生命周期，支持优雅关闭
核心代码实现
定义消息结构和队列操作：
立即学习“go语言免费学习笔记（深入）”；
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实际应用场景
这个结构可以直接用在很多常见需求里：
- 用户注册后异步发送欢迎邮件，提升接口响应速度
- 订单创建后把消息丢进队列，由独立服务处理库存和通知
- 日志收集，前端或服务把日志事件发到队列，后端统一写入文件或数据库
基本上就这些，不复杂但容易忽略错误处理和重试机制。上线前记得加日志和监控，确保消息不丢失。
