Golang RabbitMQ: Amalan Terbaik untuk Pemesejan Kebolehpercayaan Tinggi
Pengenalan:
Dalam pembangunan perisian moden, mesej telah menjadi cara penting untuk mencapai komunikasi yang cekap antara sistem. RabbitMQ ialah perisian tengah baris gilir mesej yang berkuasa dan digunakan secara meluas dengan kebolehpercayaan tinggi, ketersediaan tinggi dan prestasi tinggi, jadi ia telah menjadi pilihan pertama dalam banyak projek.
Artikel ini akan memperkenalkan amalan terbaik untuk melaksanakan pemesejan kebolehpercayaan tinggi menggunakan Golang dan RabbitMQ, dan memberikan contoh kod khusus.
1 Pasang RabbitMQ
Pertama, kita perlu memasang RabbitMQ. Anda boleh memuat turun pemasang yang sepadan dari tapak web rasmi dan memasang serta mengkonfigurasinya mengikut dokumentasi.
2. Import perpustakaan pelanggan RabbitMQ Go
Golang mempunyai banyak perpustakaan klien RabbitMQ untuk dipilih, antaranya yang lebih biasa digunakan ialah amqp dan streadway/amqp. Artikel ini akan menggunakan perpustakaan pelanggan streadway/amqp.
Gunakan arahan berikut untuk mengimport perpustakaan:
go get github.com/streadway/amqp
Salin selepas log masuk
3 Sambung ke pelayan RabbitMQ
Selepas mengimport perpustakaan dalam kod, kita perlu mewujudkan a. sambungan dengan pelayan RabbitMQ. Kod sampel adalah seperti berikut:
package main
import (
"log"
"github.com/streadway/amqp"
)
func failOnError(err error, msg string) {
if err != nil {
log.Fatalf("%s: %s", msg, err)
}
}
func main() {
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
failOnError(err, "连接 RabbitMQ 服务器失败")
defer conn.Close()
// 后续代码...
}Salin selepas log masuk
4 Buat pengeluar mesej
Seterusnya, kami akan mencipta pengeluar mesej mudah untuk menghantar mesej ke baris gilir RabbitMQ. Kod sampel adalah seperti berikut:
func main() {
// ...
ch, err := conn.Channel()
failOnError(err, "创建通道失败")
defer ch.Close()
q, err := ch.QueueDeclare(
"hello", // 队列名称
false, // 是否持久化
false, // 是否自动删除
false, // 是否独占模式
false, // 是否等待所有连接断开
nil, // 额外参数
)
failOnError(err, "声明队列失败")
body := "Hello, RabbitMQ!"
err = ch.Publish(
"", // 交换器名称
q.Name, // 队列名称
false, // 是否强制发送到队列
false, // 是否立即发送
amqp.Publishing{
ContentType: "text/plain",
Body: []byte(body),
})
failOnError(err, "发送消息失败")
log.Printf("发送消息：%s", body)
}Salin selepas log masuk
5 Buat pengguna mesej
Kami juga perlu mencipta pengguna mesej untuk menerima mesej dalam baris gilir RabbitMQ. Kod sampel adalah seperti berikut:
func main() {
// ...
ch, err := conn.Channel()
failOnError(err, "创建通道失败")
defer ch.Close()
q, err := ch.QueueDeclare(
"hello", // 队列名称
false, // 是否持久化
false, // 是否自动删除
false, // 是否独占模式
false, // 是否等待所有连接断开
nil, // 额外参数
)
failOnError(err, "声明队列失败")
msgs, err := ch.Consume(
q.Name, // 队列名称
"", // 消费者名称
true, // 是否自动回复确认
false, // 是否独占模式
false, // 是否等待所有连接断开
false, // 额外参数
)
failOnError(err, "注册消费者失败")
forever := make(chan bool)
go func() {
for d := range msgs {
log.Printf("接收消息：%s", d.Body)
}
}()
log.Printf("等待消息...")
<-forever
}Salin selepas log masuk
Dalam contoh kod di atas, kami membuat baris gilir bernama "hello" untuk menghantar dan menerima mesej.
6. Ketekunan mesej
Untuk memastikan kebolehpercayaan penghantaran mesej, kami boleh menggunakan mekanisme kegigihan RabbitMQ untuk memastikan mesej tidak hilang apabila pelayan dimulakan semula. Kod sampel adalah seperti berikut:
func main() {
// ...
q, err := ch.QueueDeclare(
"hello", // 队列名称
true, // 是否持久化
false, // 是否自动删除
false, // 是否独占模式
false, // 是否等待所有连接断开
nil, // 额外参数
)
failOnError(err, "声明队列失败")
// ...
}Salin selepas log masuk
7. Mekanisme pengesahan mesej
Secara lalai, RabbitMQ akan menghantar mesej kepada mana-mana pengguna, tidak kira sama ada pengguna telah memproses mesej dengan betul. Untuk memastikan mesej dapat diproses dengan betul, kami boleh menggunakan mekanisme pengesahan mesej.
Kod sampel adalah seperti berikut:
func main() {
// ...
msgs, err := ch.Consume(
q.Name, // 队列名称
"", // 消费者名称
false, // 是否自动回复确认
false, // 是否独占模式
false, // 是否等待所有连接断开
false, // 额外参数
)
failOnError(err, "注册消费者失败")
forever := make(chan bool)
go func() {
for d := range msgs {
log.Printf("接收消息：%s", d.Body)
d.Ack(false) // 确认消息已被正确处理
}
}()
// ...
}Salin selepas log masuk
Dalam contoh kod di atas, kami mengesahkan bahawa mesej telah diproses dengan betul dengan memanggil kaedah d.Ack(false).
8. Menggunakan Exchange dalam RabbitMQ
Selain menghantar mesej terus ke baris gilir, kami juga boleh menggunakan Exchange untuk mencapai penghalaan mesej yang lebih fleksibel.
Kod sampel adalah seperti berikut:
func main() {
// ...
err = ch.ExchangeDeclare(
"logs", // 交换器名称
"fanout", // 交换器类型
true, // 是否持久化
false, // 是否自动删除
false, // 是否等待所有连接断开
false, // 额外参数
)
failOnError(err, "声明交换器失败")
// 发送消息到交换器
err = ch.Publish(
"logs", // 交换器名称
"", // 队列名称
false, // 是否强制发送到队列
false, // 是否立即发送
amqp.Publishing{
ContentType: "text/plain",
Body: []byte(body),
})
failOnError(err, "发送消息失败")
// ...
}Salin selepas log masuk
Dalam contoh di atas, kami mencipta pertukaran jenis fanout bernama "log" dan menghantar mesej kepada pertukaran .
9 Ringkasan
Artikel ini memperkenalkan amalan terbaik untuk melaksanakan pemesejan kebolehpercayaan tinggi menggunakan Golang dan RabbitMQ, dan menyediakan contoh kod khusus. Dengan menggunakan RabbitMQ, kami boleh merealisasikan pengeluaran dan penggunaan mesej dengan mudah dan memastikan penghantaran mesej yang boleh dipercayai.
Dalam projek sebenar, kami juga boleh menggunakan fungsi lain mengikut keperluan, seperti ketekunan mesej, mekanisme pengesahan mesej, penggunaan Exchange, dan lain-lain untuk meningkatkan lagi kestabilan dan kebolehpercayaan sistem.
Saya harap artikel ini dapat membantu anda mempelajari dan mengamalkan Golang dan RabbitMQ, supaya anda boleh mengaplikasikannya dengan lebih baik dalam pembangunan sebenar.
Atas ialah kandungan terperinci Golang RabbitMQ: Amalan terbaik untuk pemesejan kebolehpercayaan tinggi. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!
![[Web front-end] Permulaan pantas Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
