在 go lang 中 amqp.Dial 是否是线程安全时是否每次都创建连接

golang学习网今天将给大家带来《在 go lang 中 amqp.Dial 是否是线程安全时是否每次都创建连接》，感兴趣的朋友请继续看下去吧！以下内容将会涉及到golang等等知识点，如果你是正在学习Golang或者已经是大佬级别了，都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家！

问题内容

正如 RabbitMQ 文档中提到的那样，建立 tcp 连接的成本很高。因此，引入了渠道的概念。现在我遇到了这个[例子](https://www.rabbitmq.com/tutorials/tutorial- four-go.html)。每次发布消息时，main()它都会创建连接。 conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/"). 它不应该被全局声明一次，并且应该有故障转移机制，以防连接像单例对象一样关闭。如果 amqp.Dial 是线程安全的，我想它应该是

编辑问题：

我正在以下列方式处理连接错误。我在其中收听频道并在错误时创建新连接。但是当我终止现有连接并尝试发布消息时。我收到以下错误。

错误 ：

2016/03/30 19:20:08 Failed to open a channel: write tcp 172.16.5.48:51085->172.16.0.20:5672: use of closed network connection
exit status 1
7:25 PM

代码 ：

 func main() {

        Conn, err := amqp.Dial("amqp://guest:guest@172.16.0.20:5672/")
        failOnError(err, "Failed to connect to RabbitMQ")
         context := &appContext{queueName: "QUEUENAME",exchangeName: "ExchangeName",exchangeType: "direct",routingKey: "RoutingKey",conn: Conn}
        c := make(chan *amqp.Error)

        go func() {
            error := 
<h2 class="daan">
    正确答案
</h2>
<p>当然，您不应该为每个请求都创建一个连接。使其成为全局变量或[应用程序上下文](https://elithrar.github.io/article/custom-
handlers-avoiding-globals/)的更好部分，您在启动时初始化一次。</p>
<p>您可以通过使用以下方法注册通道来处理连接错误<code>Connection.NotifyClose</code>：</p>
<pre class="brush:go;toolbar:false">func initialize() {
  c := make(chan *amqp.Error)
  go func() {
    err := <p>以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。</p>