如何在 Golang 框架中使用 Beanstalkd 消息队列？

package main

import (
    "github.com/beanstalkd/go-beanstalkd"
)

func main() {
    // 连接到 Beanstalkd 实例
    beanstalk, err := beanstalkd.NewConn("localhost:11300", 10)
    if err != nil {
        panic(err)
    }
    defer beanstalk.Close()

    // 将消息放入队列
    if _, err := beanstalk.Put([]byte("hello world"), 1, 0, 1024); err != nil {
        panic(err)
    }

    // 从队列中读取消息
    for {
        job, err := beanstalk.Reserve(5)
        if err != nil {
            break
        }
        // 处理消息，例如：fmt.Println(string(job.Body))
        if err := job.Delete(); err != nil {
            panic(err)
        }
    }
}

func sendEmail(body string) error {
    // 从 Beanstalkd 中获取一个连接
    beanstalk, err := beanstalkd.NewConn("localhost:11300", 10)
    if err != nil {
        return err
    }
    defer beanstalk.Close()

    // 将电子邮件详细信息放入队列中
    if _, err := beanstalk.Put([]byte(body), 1, 0, 1024); err != nil {
        return err
    }
    return nil
}

func processEmailQueue() {
    // 从 Beanstalkd 中获取一个连接
    beanstalk, err := beanstalkd.NewConn("localhost:11300", 10)
    if err != nil {
        panic(err)
    }
    defer beanstalk.Close()

    for {
        job, err := beanstalk.Reserve(5)
        if err != nil {
            break
        }
        // 处理电子邮件，例如：发送电子邮件
        if err := job.Delete(); err != nil {
            panic(err)
        }
    }
}