Adakah `amqp.Dial` Thread-Selamat di Go? Mengoptimumkan Sambungan RabbitMQ untuk Kecekapan.

Keselamatan Benang amqp.Dial

Dalam Go, mengoptimumkan penggunaan sumber adalah penting dan mewujudkan banyak sambungan yang tidak diperlukan boleh memakan kos yang tinggi. Itulah sebabnya RabbitMQ menekankan meminimumkan sambungan TCP.

Mengenai persoalan sama ada amqp.Dial selamat untuk benang, adalah penting untuk ambil perhatian bahawa ia mewujudkan sambungan ke pelayan RabbitMQ setiap kali ia dipanggil. Ini menunjukkan bahawa berbilang panggilan daripada urutan berbeza berkemungkinan akan mewujudkan berbilang sambungan, yang bukan amalan optimum.

Penyelesaian Cadangan

Daripada membuat sambungan baharu pada setiap permintaan , pertimbangkan untuk mencipta sambungan global yang memenuhi semua keperluan aplikasi anda. Anda boleh memulakan sambungan ini sekali pada permulaan aplikasi.

Untuk mengendalikan ralat sambungan dengan baik, anda boleh menggunakan Connection.NotifyClose untuk melampirkan saluran pendengar. Saluran ini akan membolehkan anda mengesan sambungan tertutup dan mewujudkannya semula apabila perlu.

Berikut ialah contoh cara anda boleh melaksanakan teknik ini:

<code class="go">func initialize() {
  c := make(chan *amqp.Error)
  go func() {
    err := <-c
    log.Println("reconnect: " + err.Error())
    initialize()
  }()

  conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
  if err != nil {
    panic("cannot connect")
  }
  conn.NotifyClose(c)

  // create topology
}</code>

Dengan melaksanakan pendekatan ini, aplikasi anda akan mewujudkan satu sambungan berterusan ke RabbitMQ, memastikan penggunaan sumber yang cekap sambil mengendalikan ralat sambungan dengan anggun.

Atas ialah kandungan terperinci Adakah `amqp.Dial` Thread-Selamat di Go? Mengoptimumkan Sambungan RabbitMQ untuk Kecekapan.. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!