Golang与RabbitMQ实现消息持久化和数据安全的设计与实现

package main

import (
    "log"

    "github.com/streadway/amqp"
)

func failOnError(err error, msg string) {
    if err != nil {
        log.Fatalf("%s: %s", msg, err)
    }
}

func main() {
    conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
    failOnError(err, "Failed to connect to RabbitMQ")
    defer conn.Close()

    ch, err := conn.Channel()
    failOnError(err, "Failed to open a channel")
    defer ch.Close()

    q, err := ch.QueueDeclare(
        "my_queue", // queue name
        true,       // durable
        false,      // delete when unused
        false,      // exclusive
        false,      // no-wait
        nil,        // arguments
    )
    failOnError(err, "Failed to declare a queue")
}

// ...

err = ch.Publish(
        "",     // exchange
        q.Name, // routing key
        false,  // mandatory
        false,  // immediate
        amqp.Publishing{
            ContentType: "text/plain",
            Body:        []byte("Hello, RabbitMQ!"),
            DeliveryMode: amqp.Persistent, // make message persistent
        })
    failOnError(err, "Failed to publish a message")

// ...

msg, err := ch.Consume(
        q.Name, // queue name
        "",     // consumer
        true,   // auto-ack
        false,  // exclusive
        false,  // no-local
        false,  // no-wait
        nil,    // arguments
    )
    failOnError(err, "Failed to register a consumer")

    go func() {
        for d := range msg {
            log.Printf("Received a message: %s", d.Body)
        }
    }()

    select {}

openssl req -new -newkey rsa:2048 -days 365 -nodes -x509 -keyout server.key -out server.crt

// ...

cert, err := tls.LoadX509KeyPair("server.crt", "server.key")
failOnError(err, "Failed to load certificates")

config := &tls.Config{
    Certificates: []tls.Certificate{cert},
}

conn, err := amqp.DialTLS("amqps://guest:guest@localhost:5671/", config)
failOnError(err, "Failed to connect to RabbitMQ")
defer conn.Close()

// ...