Go语言中实现消息队列主要有两种方式：使用channel适合并发场景，天然支持FIFO且无需加锁；使用切片可自定义队列结构，便于扩展功能如判断空满、获取长度等。

在Go语言中，实现基本的消息队列操作非常直接，核心是遵循先进先出（FIFO）的原则。你可以利用Go内置的channel作为最简单高效的方式，或者通过切片（slice）来自定义一个更灵活的队列结构。

使用Channel实现消息队列

channel 是Go语言中天然的并发安全队列，特别适合作为生产者-消费者模型中的消息队列。它无需额外加锁，语法简洁。

下面是一个基础示例：

package main
<p>import (
"fmt"
"time"
)</p><p>func main() {
// 创建一个带缓冲的字符串通道，容量为10
queue := make(chan string, 10)</p><pre class="brush:php;toolbar:false;">// 生产者：向队列发送消息（入队）
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) // 模拟耗时处理
}

}

使用切片实现自定义队列

如果你需要更多控制权，比如检查队列长度、判断空满状态或实现环形队列，可以使用切片来构建一个队列结构体。

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

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

示例代码如下：

package main
<p>import "fmt"</p><p>// 定义一个泛型队列，支持任意类型
type Queue[T any] struct {
items []T
}</p><p>// 入队：将元素添加到队列末尾
func (q *Queue[T]) Enqueue(item T) {
q.items = append(q.items, item)
}</p><p>// 出队：从队列头部移除并返回元素
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
}</p><p>// 查看队列是否为空
func (q *Queue[T]) IsEmpty() bool {
return len(q.items) == 0
}</p><p>// 获取队列大小
func (q *Queue[T]) Size() int {
return len(q.items)
}</p><p>func main() {
q := &Queue[string]{}</p><pre class="brush:php;toolbar:false;">q.Enqueue("任务1")
q.Enqueue("任务2")
fmt.Println("队列大小:", q.Size()) // 输出: 2

for !q.IsEmpty() {
    if val, ok := q.Dequeue(); ok {
        fmt.Println("处理:", val)
    }
}

}

基本上就这些。用channel适合大多数并发场景，够快够稳；用切片则更灵活，方便扩展功能。