Кай билдирүү брокерин колдонгуңуз келет — Kafka же RabbitMQ?

Жобонун конкреттүү талаптарына жараша Kafka жана RabbitMQ ортосунда тандоо жүргүзүлөт.

Kafka чоң маалымат агымдарын жогорку өткөрүмдүүлүк жана билдирүүлөрдү сактоо менен иштетүү үчүн ылайыктуу (иш-чаралар журналы). Ал масштабдуулук жана туруктуулукка багытталган жана аналитика системалары, агымдык иштетүү жана иш-чара системдери үчүн жакшы.

RabbitMQ — бул классикалык билдирүү брокери, ал ар кандай алмашуу моделдерин (күтүүлөр, темалар) колдойт жана кепилденген жеткирүү, татаал маршруттоо жана кызматтар ортосундагы интеграция үчүн ыңгайлуу.

Эгер жогорку иштөө жана чоң көлөмдөгү маалыматтарды иштетүү керек болсо, Kafkaны колдонуңуз. Эгер ийкемдүү маршруттоо жана ишенимдүү жеткирүү маанилүү болсо, RabbitMQны колдонуңуз.

Go тилинде Kafkaны колдонуу мисалы (sarama китепканасы менен):

package main

import (
    "github.com/Shopify/sarama"
    "log"
)

func main() {
    producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, nil)
    if err != nil {
        log.Fatal(err)
    }
    defer producer.Close()

    msg := &sarama.ProducerMessage{
        Topic: "test_topic",
        Value: sarama.StringEncoder("Салам Kafka"),
    }

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("Хабар сакталды бөлүмдө %d, офсэтте %d\n", partition, offset)
}