Menggunakan kaedah langganan pengekalan pengendali tersuai nats golang

editor php Banana akan memperkenalkan anda cara menggunakan pengendali tersuai nats golang untuk mengekalkan kaedah langganan dalam artikel ini. Semasa proses pembangunan, kami selalunya perlu menggunakan baris gilir mesej untuk mengendalikan tugas tak segerak, dan nats golang ialah sistem baris gilir mesej yang ringan dengan prestasi tinggi dan berskala. Dengan menyesuaikan pengendali, kami boleh mengekalkan kaedah langganan dan mencapai pemprosesan mesej dan kawalan proses yang lebih fleksibel. Di bawah ini kami akan memperkenalkan secara terperinci bagaimana untuk melaksanakan fungsi ini dalam nats golang.

Kandungan soalan

Saya sedang menulis pembungkus di atas pelanggan nats di golang dan saya ingin mendapatkan fungsi pengendali yang boleh saya hubungi daripada pengguna sebaik sahaja saya menerima mesej daripada pelayan nats. Saya mahu mengekalkan kaedah langganan tersuai sehingga ia menerima mesej daripada nats.

Diterbitkan oleh:

func (busconfig busconfig) publish(service string, data []byte) error {
    puberr := conn.publish(service, data)
    if puberr != nil {
        return puberr
    }
    return nil
}

Langgan:

func (busconfig busconfig) subscribe(subject string, handler func(msg []byte)) {
    fmt.println("subscrbing on : ", subject)

    //wg := sync.waitgroup{}
    //wg.add(1)
    subscription, err := conn.subscribe(subject, func(msg *nats.msg) {
        go func() {
            handler(msg.data)
        }()
        //wg.done()
    })
    if err != nil {
        fmt.println("subscriber error : ", err)
    }
    //wg.wait()
    defer subscription.unsubscribe()

}

Kes ujian:

func TestLifeCycleEvent(t *testing.T) {
    busClient := GetBusClient()
    busClient.Subscribe(SUBJECT, func(input []byte) {
        fmt.Println("Life cycle event received :", string(input))
    })

    busClient.Publish(SUBJECT, []byte("complete notification"))
}

Saya melihat mesej itu diterbitkan tetapi tidak dilanggan, saya cuba menggunakan kumpulan tunggu untuk mengekalkan kaedah langganan, tetapi saya fikir ini bukan penyelesaian yang betul.

Penyelesaian

Anda tidak dapat melihat mesej dihantar kerana Subscribe ialah kaedah async yang menghasilkan goroutine untuk mengendalikan mesej masuk dan memanggil panggilan balik.

Hubungi busClient.Publish() 之后，您的应用程序立即退出。它不会等待 Subscribe() apa sahaja yang berlaku secara dalaman.

Apabila anda menggunakan nats.Subscribe() anda biasanya mempunyai aplikasi yang berjalan lama yang keluar dalam keadaan tertentu (seperti menerima isyarat tutup). WaitGroup akan berfungsi di sini, tetapi mungkin bukan untuk aplikasi sebenar, hanya untuk ujian.

Anda juga harus memanggil kaedah Flush() pada sambungan NATS untuk memastikan semua mesej buffer dihantar sebelum keluar dari program.

Kalau nak kaedah synchronize boleh guna nats.SubscribeSync()

Lihat contoh: https://natsbyexample.com/examples/messaging/publish-subscribe/execute

Atas ialah kandungan terperinci Menggunakan kaedah langganan pengekalan pengendali tersuai nats golang. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!