Rumah pembangunan bahagian belakang Golang Bagaimana untuk melaksanakan fungsi langganan mudah menggunakan Golang

Bagaimana untuk melaksanakan fungsi langganan mudah menggunakan Golang

Apr 27, 2023 am 09:08 AM

Golang ialah bahasa pengaturcaraan yang semakin popular, dan keselarasan serta kecekapannya menjadikannya bahasa pilihan untuk membangunkan aplikasi web dan aplikasi rangkaian. Artikel ini akan memperkenalkan cara menggunakan Golang untuk melaksanakan fungsi langganan mudah.

Langganan ialah corak biasa yang digunakan untuk menghantar maklumat antara aplikasi yang berbeza. Dalam aplikasi web, model langganan digunakan secara meluas untuk melaksanakan fungsi seperti bilik sembang dan pemberitahuan masa nyata. Menggunakan model langganan boleh mengurangkan kerumitan aplikasi, meningkatkan kecekapan dan mengurangkan tekanan pada pelayan.

Di Golang, anda boleh menggunakan goroutine dan saluran untuk melaksanakan fungsi langganan. Goroutine ialah benang ringan yang meningkatkan kecekapan program dengan melaksanakan pelbagai tugas serentak. Saluran ialah mekanisme untuk komunikasi antara coroutine, yang membolehkan berbilang goroutine berinteraksi dan berkongsi data melalui saluran.

Mari laksanakan aplikasi langganan mudah yang boleh menerima permintaan langganan pengguna dan menolak kandungan langganan kepada pelanggan.

Pertama, kita perlu membuat pengurus langganan. Pengurus langganan akan mengekalkan senarai langganan, termasuk nama pelanggan dan saluran yang sepadan. Semua pelanggan akan menerima maklumat langganan melalui saluran mereka. Kami mentakrifkan struktur berikut untuk mewakili pelanggan:

type Subscriber struct {
    Name string
    Channel chan string
}
Salin selepas log masuk

Seterusnya, kami mentakrifkan struktur pengurus langganan:

type SubscriptionManager struct {
    subscribers []*Subscriber
    mu sync.Mutex
}
Salin selepas log masuk

di mana pelanggan ialah senarai pelanggan dan mu ialah mutex Kunci digunakan untuk memastikan bahawa berbilang operasi goroutine pada senarai langganan adalah selamat.

Kemudian, kita perlu melaksanakan beberapa kaedah untuk mengurus pelanggan dan menerbitkan kandungan langganan. Yang pertama ialah kaedah AddSubscriber, digunakan untuk menambah pelanggan baharu:

func (m *SubscriptionManager) AddSubscriber(name string) (*Subscriber, error) {
    m.mu.Lock()
    defer m.mu.Unlock()

    // 检查是否有已经存在的订阅者
    for _, s := range m.subscribers {
        if s.Name == name {
            return nil, fmt.Errorf("subscriber with name %s already exists", name)
        }
    }

    // 创建一个新的订阅者
    subscriber := &Subscriber{
        Name: name,
        Channel: make(chan string),
    }

    // 将新的订阅者添加到订阅者列表中
    m.subscribers = append(m.subscribers, subscriber)

    return subscriber, nil
}
Salin selepas log masuk

Dalam kod di atas, kami mula-mula mendapatkan kunci mutex untuk memastikan berbilang goroutin tidak menambah pelanggan pada masa yang sama. Kami kemudian menyemak sama ada pelanggan dengan nama yang sama sudah wujud dan mengembalikan ralat jika ya. Akhir sekali, kami mencipta pelanggan baharu dan menambahkannya pada senarai pelanggan.

Seterusnya, kami mentakrifkan kaedah PublishMessage untuk menghantar maklumat langganan kepada semua pelanggan:

func (m *SubscriptionManager) PublishMessage(message string) {
    m.mu.Lock()
    defer m.mu.Unlock()
    
    for _, s := range m.subscribers {
        s.Channel <- message
    }
}
Salin selepas log masuk

Dalam kod di atas, kami memperoleh kunci mutex dan kemudian melelang melalui semua pelanggan , menghantar maklumat langganan kepada mereka saluran. Memandangkan setiap pelanggan mempunyai saluran yang berasingan, penghantaran mesej tidak akan mengganggu satu sama lain. Selepas semua pelanggan menerima mesej, kami melepaskan kunci mutex.

Berikut ialah cara untuk melaksanakan aplikasi langganan menggunakan SubscriptionManager yang ditakrifkan di atas:

func main() {
    manager := &SubscriptionManager{}

    // 添加两个订阅者
    subscriber1, _ := manager.AddSubscriber("Alice")
    subscriber2, _ := manager.AddSubscriber("Bob")

    // 开始一个goroutine,给订阅者月份日期
    go func() {
        for {
            now := time.Now()
            message := fmt.Sprintf("The time is: %s", now.Format(time.RFC3339))

            // 发布订阅信息
            manager.PublishMessage(message)

            // 休眠一秒钟,给订阅者以足够的时间接收信息
            time.Sleep(1 * time.Second)
        }
    }()

    // 订阅者通过循环语句接收订阅信息
    for {
        select {
        case message := <-subscriber1.Channel:
            fmt.Printf("%s received a message: %s\n", subscriber1.Name, message)
        case message := <-subscriber2.Channel:
            fmt.Printf("%s received a message: %s\n", subscriber2.Name, message)
        }
    }
}
Salin selepas log masuk

Dalam kod di atas, kami mula-mula membuat contoh SubscriptionManager dan menambah dua pelanggan padanya . Kami kemudian menggunakan goroutine untuk menjana dan menerbitkan maklumat langganan. Akhir sekali, kami menggunakan gelung tak terhingga untuk menerima maklumat langganan. Menggunakan penyataan pilihan, kami boleh memproses berbilang saluran pada masa yang sama, yang merupakan cara yang sangat mudah untuk menggunakan Golang untuk pengaturcaraan serentak.

Ini adalah cara untuk melaksanakan aplikasi langganan mudah menggunakan Golang. Dengan menggunakan goroutine dan saluran, kami boleh menghantar mesej dengan mudah kepada berbilang pelanggan dan menjadikan pemprosesan aplikasi lebih cekap.

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan fungsi langganan mudah menggunakan Golang. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn

Alat AI Hot

Undresser.AI Undress

Undresser.AI Undress

Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover

AI Clothes Remover

Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Undress AI Tool

Undress AI Tool

Gambar buka pakaian secara percuma

Clothoff.io

Clothoff.io

Penyingkiran pakaian AI

AI Hentai Generator

AI Hentai Generator

Menjana ai hentai secara percuma.

Artikel Panas

R.E.P.O. Kristal tenaga dijelaskan dan apa yang mereka lakukan (kristal kuning)
1 bulan yang lalu By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Tetapan grafik terbaik
1 bulan yang lalu By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Cara Memperbaiki Audio Jika anda tidak dapat mendengar sesiapa
1 bulan yang lalu By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Arahan sembang dan cara menggunakannya
1 bulan yang lalu By 尊渡假赌尊渡假赌尊渡假赌

Alat panas

Notepad++7.3.1

Notepad++7.3.1

Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina

SublimeText3 versi Cina

Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1

Hantar Studio 13.0.1

Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6

Dreamweaver CS6

Alat pembangunan web visual

SublimeText3 versi Mac

SublimeText3 versi Mac

Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

Apakah kelemahan debian openssl Apakah kelemahan debian openssl Apr 02, 2025 am 07:30 AM

OpenSSL, sebagai perpustakaan sumber terbuka yang digunakan secara meluas dalam komunikasi yang selamat, menyediakan algoritma penyulitan, kunci dan fungsi pengurusan sijil. Walau bagaimanapun, terdapat beberapa kelemahan keselamatan yang diketahui dalam versi sejarahnya, yang sebahagiannya sangat berbahaya. Artikel ini akan memberi tumpuan kepada kelemahan umum dan langkah -langkah tindak balas untuk OpenSSL dalam sistem Debian. Debianopenssl yang dikenal pasti: OpenSSL telah mengalami beberapa kelemahan yang serius, seperti: Kerentanan Pendarahan Jantung (CVE-2014-0160): Kelemahan ini mempengaruhi OpenSSL 1.0.1 hingga 1.0.1f dan 1.0.2 hingga 1.0.2 versi beta. Penyerang boleh menggunakan kelemahan ini untuk maklumat sensitif baca yang tidak dibenarkan di pelayan, termasuk kunci penyulitan, dll.

Bagaimana anda menggunakan alat PPROF untuk menganalisis prestasi GO? Bagaimana anda menggunakan alat PPROF untuk menganalisis prestasi GO? Mar 21, 2025 pm 06:37 PM

Artikel ini menerangkan cara menggunakan alat PPROF untuk menganalisis prestasi GO, termasuk membolehkan profil, mengumpul data, dan mengenal pasti kesesakan biasa seperti CPU dan isu memori.

Bagaimana anda menulis ujian unit di GO? Bagaimana anda menulis ujian unit di GO? Mar 21, 2025 pm 06:34 PM

Artikel ini membincangkan ujian unit menulis di GO, meliputi amalan terbaik, teknik mengejek, dan alat untuk pengurusan ujian yang cekap.

Perpustakaan apa yang digunakan untuk operasi nombor terapung di GO? Perpustakaan apa yang digunakan untuk operasi nombor terapung di GO? Apr 02, 2025 pm 02:06 PM

Perpustakaan yang digunakan untuk operasi nombor terapung dalam bahasa Go memperkenalkan cara memastikan ketepatannya ...

Apakah masalah dengan thread giliran di crawler colly go? Apakah masalah dengan thread giliran di crawler colly go? Apr 02, 2025 pm 02:09 PM

Masalah Threading Giliran di GO Crawler Colly meneroka masalah menggunakan Perpustakaan Colly Crawler dalam bahasa Go, pemaju sering menghadapi masalah dengan benang dan permintaan beratur. � ...

Berubah dari front-end ke pembangunan back-end, adakah lebih menjanjikan untuk belajar Java atau Golang? Berubah dari front-end ke pembangunan back-end, adakah lebih menjanjikan untuk belajar Java atau Golang? Apr 02, 2025 am 09:12 AM

Laluan Pembelajaran Backend: Perjalanan Eksplorasi dari Front-End ke Back-End sebagai pemula back-end yang berubah dari pembangunan front-end, anda sudah mempunyai asas Nodejs, ...

Apakah arahan Go FMT dan mengapa ia penting? Apakah arahan Go FMT dan mengapa ia penting? Mar 20, 2025 pm 04:21 PM

Artikel ini membincangkan perintah Go FMT dalam pengaturcaraan GO, yang format kod untuk mematuhi garis panduan gaya rasmi. Ia menyoroti kepentingan GO FMT untuk mengekalkan konsistensi kod, kebolehbacaan, dan mengurangkan perdebatan gaya. Amalan terbaik untuk

Bagaimana cara menentukan pangkalan data yang berkaitan dengan model dalam beego orm? Bagaimana cara menentukan pangkalan data yang berkaitan dengan model dalam beego orm? Apr 02, 2025 pm 03:54 PM

Di bawah rangka kerja beegoorm, bagaimana untuk menentukan pangkalan data yang berkaitan dengan model? Banyak projek beego memerlukan pelbagai pangkalan data untuk dikendalikan secara serentak. Semasa menggunakan beego ...

See all articles