Go语言中实现消息队列主要有两种方式：使用channel适合并发场景，天然支持FIFO且无需加锁；使用切片可自定义队列结构，便于扩展功能如判断空满、获取长度等。
在Go语言中，实现基本的消息队列操作非常直接，核心是遵循先进先出（FIFO）的原则。你可以利用Go内置的channel作为最简单高效的方式，或者通过切片（slice）来自定义一个更灵活的队列结构。
使用Channel实现消息队列
channel 是Go语言中天然的并发安全队列，特别适合作为生产者-消费者模型中的消息队列。它无需额外加锁，语法简洁。
下面是一个基础示例：package mainimport ( "fmt" "time" )
func main() { // 创建一个带缓冲的字符串通道，容量为10 queue := make(chan string, 10)
// 生产者：向队列发送消息（入队） go func() { for i := 1; i <= 3; i++ { msg := fmt.Sprintf("消息 %d", i) queue <- msg fmt.Println("已入队:", msg) time.Sleep(time.Second) // 模拟处理时间 } close(queue) // 发送完毕，关闭通道 }() // 消费者：从队列接收消息（出队） for msg := range queue { fmt.Println("已出队:", msg) time.Sleep(time.Second * 2) // 模拟耗时处理 }}
使用切片实现自定义队列
如果你需要更多控制权，比如检查队列长度、判断空满状态或实现环形队列，可以使用切片来构建一个队列结构体。
示例代码如下：package mainimport "fmt"
// 定义一个泛型队列，支持任意类型 type Queue[T any] struct { items []T }
// 入队：将元素添加到队列末尾 func (q *Queue[T]) Enqueue(item T) { q.items = append(q.items, item) }
// 出队：从队列头部移除并返回元素 func (q *Queue[T]) Dequeue() (T, bool) { var zero T if len(q.items) == 0 { return zero, false // 队列为空，返回零值和false } item := q.items[0] q.items = q.items[1:] // 切片操作，移除第一个元素 return item, true }
// 查看队列是否为空 func (q *Queue[T]) IsEmpty() bool { return len(q.items) == 0 }
// 获取队列大小 func (q *Queue[T]) Size() int { return len(q.items) }
func main() { q := &Queue[string]{}
q.Enqueue("任务1") q.Enqueue("任务2") fmt.Println("队列大小:", q.Size()) // 输出: 2 for !q.IsEmpty() { if val, ok := q.Dequeue(); ok { fmt.Println("处理:", val) } }}
基本上就这些。用channel适合大多数并发场景，够快够稳；用切片则更灵活，方便扩展功能。
