快速上手：利用Go语言实现简单消息队列

package main

import (
    "fmt"
    "time"
)

type Message struct {
    ID      int
    Content string
}

func main() {
    // 创建一个消息channel，容量为10
    messageQueue := make(chan Message, 10)

    // 启动生产者goroutine
    go producer(messageQueue)

    // 启动消费者goroutine
    go consumer(messageQueue)

    // 保持程序运行，等待消息处理完成
    time.Sleep(5 * time.Second)
    close(messageQueue) // 关闭channel，通知消费者
    time.Sleep(1 * time.Second) // 确保消费者处理完所有消息
    fmt.Println("程序结束")
}

// 生产者
func producer(queue chan Message) {
    for i := 0; i < 20; i++ {
        message := Message{
            ID:      i,
            Content: fmt.Sprintf("Message %d", i),
        }
        queue <- message
        fmt.Printf("生产者：发送消息 ID %d\n", message.ID)
        time.Sleep(time.Millisecond * 50) // 模拟生产速度
    }
    fmt.Println("生产者：消息发送完毕")
}

// 消费者
func consumer(queue chan Message) {
    for message := range queue {
        fmt.Printf("消费者：接收消息 ID %d, 内容: %s\n", message.ID, message.Content)
        time.Sleep(time.Millisecond * 100) // 模拟消费速度
    }
    fmt.Println("消费者：消息处理完毕")
}

func consumer(queue chan Message) {
    for message := range queue {
        err := processMessage(message)
        if err != nil {
            fmt.Printf("消费者：处理消息 ID %d 失败: %v\n", message.ID, err)
            // 尝试重试，或者放入死信队列
        } else {
            fmt.Printf("消费者：接收消息 ID %d, 内容: %s\n", message.ID, message.Content)
        }
        time.Sleep(time.Millisecond * 100)
    }
    fmt.Println("消费者：消息处理完毕")
}

func processMessage(message Message) error {
    // 模拟消息处理错误
    if message.ID%5 == 0 {
        return fmt.Errorf("消息ID %d 处理失败", message.ID)
    }
    return nil
}