首页 > Golang > Go教程

Golang rabbitMQ生产者消费者实现示例

来源：脚本之家

时间：2022-12-23 18:28:45 148浏览收藏

IT行业相对于一般传统行业，发展更新速度更快，一旦停止了学习，很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习，精进自己的技术，尤其是初学者。今天golang学习网给大家整理了《Golang rabbitMQ生产者消费者实现示例》，聊聊RabbitMQ、生产者、消费者，我们一起来看看吧！

消费者

package main
import (
    "fmt"
    "github.com/streadway/amqp"
)
func failOnError(err error, msg string) {
    if err != nil {
        fmt.Println("%s: %s", msg, err)
    }
}
// 只能在安装 rabbitmq 的服务器上操作
func main() {
    conn, err := amqp.Dial("amqp://mquser:123456@127.0.0.1/toutiao")
    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(
        "toutiao.web.test", // 队列名字
        false,   // durable
        false,   // delete when unused
        false,   // exclusive
        false,   // no-wait
        nil,     // arguments
    )
    failOnError(err, "Failed to declare a queue")
    msgs, err := ch.Consume(
        q.Name,         // queue
        "toutiao",     // consumer
        true,   // auto-ack,true消费了就消失
        false,  // exclusive
        false,  // no-local
        false,  // no-wait
        nil,    // args
    )
    failOnError(err, "Failed to register a consumer")
    forever := make(chan bool)
    go func() {
        for d := range msgs {
            fmt.Println(fmt.Sprintf("返回的消息:%s",d.Body))
        }
    }()
    fmt.Println("[*] Waiting for messages. To exit press CTRL+C")
     
<h2>生产者</h2>
<p>body：消息体</p>
<pre class="brush:go;">package main
import (
    "github.com/streadway/amqp"
    "log"
)
func failOnError(err error, msg string) {
    if err != nil {
        log.Fatalf("%s: %s", msg, err)
    }
}
// 只能在安装 rabbitmq 的服务器上操作
func main() {
    conn, err := amqp.Dial("amqp://mquser:123456@127.0.0.1/toutiao")
    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(
    "toutiao.web.test",   // name
        false, // durable
        false, // delete when unused
        false, // exclusive
        false, // no-wait
        nil, // arguments
)
    failOnError(err, "Failed to declare a queue")
    body := "Hello World!"  //发送的消息
    err = ch.Publish(
    "",         // exchange
        q.Name, // routing key
        false,  // mandatory
        false,  // immediate
        amqp.Publishing{
        ContentType: "text/plain",
            Body:        []byte(body),
        })
    log.Printf(" [x] Sent %s", body)
    failOnError(err, "Failed to publish a message")
}
</pre>
<p>理论要掌握，实操不能落！以上关于《Golang rabbitMQ生产者消费者实现示例》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！</p>

golang RabbitMQ 生产者消费者

声明：本文转载于：脚本之家如有侵犯，请联系study_golang@163.com删除