Day 27 - 消息队列

Kafka

// 生产者
producer, _ := kafka.NewProducer(&kafka.ConfigMap{
    "bootstrap.servers": "localhost:9092",
})
defer producer.Close()

producer.SendMessages([]kafka.Message{
    {Topic: "my-topic", Key: []byte("key"), Value: []byte("message")},
})

RabbitMQ

import "github.com/streadway/amqp"

conn, _ := amqp.Dial("amqp://guest:guest@localhost:5672/")
ch, _ := conn.Channel()

ch.QueueDeclare("my-queue", true, false, false, false)
ch.Publish("my-exchange", "my-queue", false, false, amqp.Publishing{
    Body: []byte("message"),
})

---

📅 学习进度

Day	主题	状态
01-26	基础/监控	✅
27	消息队列	✅
28	Redis	⬜

---

本文为Go 30天学习计划第27天内容

📚 导航

| ← Day 26 - 上一章 | Day 28 - 下一章 →