GoでRabbitMQを用いたイベント駆動アーキテクチャ設計

2年 ago
優斗, 朝陽
1 minute

GoでRabbitMQを使用するイベント駆動アーキテクチャ設計は、次の手順で行えます。

  1. RabbitMQのインストール： まず最初に、RabbitMQのインストールと設定が必要になります。インストールは公式ドキュメントに従ってください。
  2. イベントメッセージの構造体を定義する: Goでは、次のような構造体を使用してイベントメッセージのデータ構造体を定義できます。
type Event struct {
Type    string                 `json:"type"`
Payload map[string]interface{} `json:"payload"`
}
  1. イベントの発行：RabbitMQ に接続して交換機を宣言し、イベントメッセージを交換機に発行する必要があります。例えば：
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
if err != nil {
// 处理错误
}
defer conn.Close()
ch, err := conn.Channel()
if err != nil {
// 处理错误
}
defer ch.Close()
err = ch.ExchangeDeclare(
"events", // 交换机名称
"fanout", // 交换机类型
true,     // 是否持久化
false,    // 是否自动删除
false,    // 是否内部使用
false,    // 是否等待服务器的确认
nil,      // 额外的配置
)
if err != nil {
// 处理错误
}
event := Event{
Type: "user.created",
Payload: map[string]interface{}{
"id":   1,
"name": "John",
},
}
body, err := json.Marshal(event)
if err != nil {
// 处理错误
}
err = ch.Publish(
"events", // 交换机名称
"",       // 路由键
false,    // 是否立即发送
false,    // 是否等待服务器的确认
amqp.Publishing{
ContentType: "application/json",
Body:        body,
},
)
if err != nil {
// 处理错误
}
  1. イベントの購読: イベントを購読する必要がある場所で、RabbitMQに接続し、キューを宣言して交換機にバインドし、コンシューマーでキューのイベントメッセージを消費します。例:
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
if err != nil {
// 处理错误
}
defer conn.Close()
ch, err := conn.Channel()
if err != nil {
// 处理错误
}
defer ch.Close()
err = ch.ExchangeDeclare(
"events", // 交换机名称
"fanout", // 交换机类型
true,     // 是否持久化
false,    // 是否自动删除
false,    // 是否内部使用
false,    // 是否等待服务器的确认
nil,      // 额外的配置
)
if err != nil {
// 处理错误
}
q, err := ch.QueueDeclare(
"",    // 队列名称，由RabbitMQ随机生成
false, // 是否持久化
false, // 是否自动删除
true,  // 是否独占
false, // 是否等待服务器的确认
nil,   // 额外的配置
)
if err != nil {
// 处理错误
}
err = ch.QueueBind(
q.Name,   // 队列名称
"",       // 路由键
"events", // 交换机名称
false,    // 是否等待服务器的确认
nil,      // 额外的配置
)
if err != nil {
// 处理错误
}
msgs, err := ch.Consume(
q.Name, // 队列名称
"",     // 消费者名称，由RabbitMQ随机生成
true,   // 是否自动确认消息
false,  // 是否独占
false,  // 是否等待服务器的确认
false,  // 是否阻塞
nil,    // 额外的配置
)
if err != nil {
// 处理错误
}
for msg := range msgs {
var event Event
err := json.Unmarshal(msg.Body, &event)
if err != nil {
// 处理错误
}
// 处理事件
bannerAds