应用程序的邮件系统之类的东西是否应该在一个单独的频道中运行，如本例所示？

Question

想象一个具有大量不同路由的 Web 服务。其中一些会触发发送给用户的交易电子邮件。初始化邮件程序实例似乎很奇怪，例如github.com/aws/aws-sdk-go/service/sns每次请求想要发送某些东西时使用的东西。相反，我假设有一个邮件程序实例，并且一切都发生在一个单独的频道上，amessage被发布到该频道。例子我创建了一个简单的例子来说明这个问题。全局Mailer实例配置一次，Index处理程序请求一个通道并传递一个Message.package mainimport (    "fmt"    "log"    "net/http"    "os")// Message is the custom type used to pass the channeltype Message struct {    To      string    Subject string    Body    string}// Mailer is responsible to send out emailstype Mailer struct{}// send sends out the emailfunc (m *Mailer) send(message Message) {    fmt.Printf("Sending email to:`%s`\nSubject: %s\n%s\n\n", message.To, message.Subject, message.Body)}// Messages returns the channel to which messages can be passedfunc (m *Mailer) Messages() chan<- Message {    cm := make(chan Message)    go func() {        msg := <-cm        m.send(msg)        close(cm)    }()    return cm}// mailer is a global var in this example, would probably be part of some// sort of app context that's accessible from any handler.//// Note the mailer is NOT handler-scoped.var mailer = Mailer{} // would this be thread-safe?// Index handlerfunc Index(w http.ResponseWriter, r *http.Request) {    m := Message{"[e-mail]", fmt.Sprintf("visited `%s`", r.URL.Path[1:]), "Lorem ipsum"}    mailer.Messages() <- m    fmt.Fprintf(w, "Sent out email with subject line `%s`\n", m.Subject)}func main() {    http.HandleFunc("/", Index)    port := os.Getenv("PORT")    if port == "" {        port = "8080"    }    if err := http.ListenAndServe(":"+port, nil); err != nil {        log.Fatal("ListenAndServe: ", err)    }}输出访问http://localhost:8080/hello-world将呈现…发送主题为“visited `hello-world”的电子邮件...并记录发送电子邮件到`[e-mail]`：访问了`hello-world`Lorem ipsum问题这是正确的方法吗？它是线程安全的——如果不是，如何让它成为线程安全的？

Answer 1

在这个例子中，你并没有真正做任何事情，但是通过通道传递消息总是安全的——通道是语言中的基本并发原语之一。你让自己对竞争条件的可能性持开放态度，这取决于send实际最终做什么。处理此问题的另一种方法是send从单个通道接收。

type Mailer struct{

    Messages chan Message

}

func (m *Mailer) send() {

    for message := range m.Messages {

        fmt.Printf("Sending email to:`%s`\nSubject: %s\n%s\n\n", message.To, message.Subject, message.Body)

    }

}

var mailer *Mailer

func Index(w http.ResponseWriter, r *http.Request) {

    m := Message{"[e-mail]", fmt.Sprintf("visited `%s`", r.URL.Path[1:]), "Lorem ipsum"}

    mailer.Messages <- m

    fmt.Fprintf(w, "Sent out email with subject line `%s`\n", m.Subject)

}

func main() {

    mailer = &Mailer{

        // buffer up to 100 message to be sent before blocking

        Messages: make(chan Message, 100),

    }

    // start the mailer send loop

    go mailer.send()

    ...