golang melaksanakan mq

Dalam beberapa tahun kebelakangan ini, Message Queuing (MQ) telah digunakan secara meluas dalam data besar, pengkomputeran awan dan medan lain. Baris gilir mesej ialah kaedah pemprosesan tak segerak Dengan menyerahkan data kepada baris gilir mesej, pengendali boleh memprosesnya secara tidak segerak, yang meningkatkan prestasi dan kebolehskalaan sistem. Oleh itu, menguasai pengetahuan yang berkaitan tentang teknologi baris gilir mesej telah menjadi bahagian yang sangat diperlukan dalam seni bina perisian moden. Artikel ini akan memperkenalkan cara menggunakan golang untuk menulis MQ mudah.

1. Apakah itu MQ?

Baris Gilir Mesej (MQ) ialah kaedah komunikasi yang cekap dan model pemprosesan tak segerak. Baris gilir mesej mengandungi pengeluar mesej, pengguna mesej dan pelayan mesej. Apabila pengeluar menjana mesej, ia akan diserahkan kepada pelayan mesej Pelayan mesej akan menyimpan mesej dalam baris gilir dan kemudian memberitahu pengguna mesej itu daripada baris gilir untuk diproses. Oleh itu, MQ boleh melaksanakan model tak segerak dengan baik, meningkatkan kelajuan dan kebolehskalaan sistem.

2. Kelebihan MQ

1. Penyahgandingan
   MQ boleh memisahkan pengirim dan penerima mesej, membolehkan penyahgandingan antara komponen dalam sistem, dengan itu Mengurangkan gandingan sistem .
2. Pemprosesan tak segerak
   MQ membolehkan pengeluar dan pengguna melakukan pemprosesan tak segerak, meningkatkan kelajuan dan kebolehskalaan sistem.
3. Penimbalan
   Mesej dalam MQ boleh dicache, dengan itu menyediakan penimbal untuk menyimpan mesej supaya komunikasi terus antara pengeluar dan pengguna tidak diperlukan.
4. Kebolehpercayaan
   MQ dapat memastikan penyampaian mesej yang boleh dipercayai, iaitu sebaik sahaja mesej itu dihantar kepada MQ, ia pasti akan dihantar kepada pengguna.

3. Golang melaksanakan MQ

Dalam golang, anda boleh menggunakan perkhidmatan baris gilir mesej pihak ketiga, seperti RabbitMQ dan Kafka. Walau bagaimanapun, artikel ini akan menunjukkan kepada anda cara menulis MQ mudah secara bebas.

1. Pasang golang

Pertama sekali, anda perlu memasang persekitaran pembangunan golang. Anda boleh memuat turun pakej pemasangan dari laman web rasmi: https://golang.org/dl/. Selepas pemasangan selesai, konfigurasikan pembolehubah persekitaran.

2. Menulis kod

Seterusnya, mari tulis kod. Kod mentakrifkan struktur MQ, yang mengandungi parameter nama dan parameter mesej. Dalam pengeluar, struktur MQ mula-mula digunakan, dan kemudian mesej dihantar kepada MQ. Dalam pengguna, struktur MQ juga dijadikan instantiated, dan kemudian mesej diperoleh daripada MQ.

package main

import (
    "fmt"
)

type MQ struct {
    name string // MQ名称
    msg  []string // 消息队列
}

// 新建MQ
func NewMQ(name string) *MQ {
    return &MQ{
        name: name,
        msg:  make([]string, 0),
    }
}

// 生产者投递消息
func (m *MQ) Produce(message string) {
    m.msg = append(m.msg, message)
}

// 消费者获取消息
func (m *MQ) Consume() string {
    if len(m.msg) == 0 {
        return ""
    }
    message := m.msg[0]
    m.msg = m.msg[1:]
    return message
}

func main() {
    // 生产者
    m := NewMQ("MQ")
    m.Produce("Hello")
    m.Produce("World")
    fmt.Println("生产者：", m)

    // 消费者
    n := NewMQ("MQ")
    fmt.Println("消费者：", n.Consume())
    fmt.Println("消费者：", n.Consume())
    fmt.Println("消费者：", n.Consume())
}

Dalam kod di atas, kami mentakrifkan struktur MQ, yang mengandungi nama mesej dan baris gilir mesej. Gunakan kaedah NewMQ untuk mencipta objek MQ baharu. Dalam pengeluar, kami menggunakan kaedah Produce untuk menyampaikan mesej kepada MQ. Dalam pengguna, kami menggunakan kaedah Consume untuk mendapatkan mesej daripada MQ. Menjalankan kod, anda boleh melihat mesej yang dihantar oleh pengeluar dan mesej yang diperoleh oleh pengguna.

4. Ringkasan

Artikel ini terutamanya memperkenalkan cara menggunakan golang untuk menulis MQ mudah. Dengan melaksanakan MQ mudah, anda boleh lebih memahami prinsip pelaksanaan MQ. Sudah tentu, perkara yang dilaksanakan oleh artikel ini hanyalah MQ mudah Dalam aplikasi praktikal, lebih banyak isu perlu dipertimbangkan, seperti ketekunan mesej, pembinaan kluster, dsb. Penulis disini memberikan hala tuju agar pembaca dapat melaksanakan MQ dengan lebih terperinci berdasarkan keperluan sebenar.

Atas ialah kandungan terperinci golang melaksanakan mq. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!