专栏首页陌无崖知识分享RabbitMQ系列笔记入门篇

RabbitMQ系列笔记入门篇

导语

在了解本篇文章之前,先复习以下知识点,如果你对RabbitMQ还不了解,请先查看RabbitMQ系列笔记介绍篇这篇文章。

  • 生产者:发送消息的程序
  • 队列:消息的中转站
  • 消费者:接收消息的程序 在以上生产者同样也可以是消费者,消费者也可以是生产者,只需实现响应的发布订阅就行,本篇文章会从最简单的例子讲起。

小试牛刀

连接我们的RabbitMQ服务器

在连接我们的服务器之前,首先需要启动一个RabbitMQ服务器,这里推荐用docker容器快速启动,启动之后我们就可以在浏览器中访问服务器,获得可视化的界面,如图所示:

现在让我们用Golang代码进行连接,首先需要获得相应的包使用go get命令

go get github.com/streadway/amqp

写一个通用的错误处理函数

// 错误检查代码
func failOnError(err error, msg string) {
    if err != nil {
        log.Fatalf("%s:%s", msg, err)
        panic(fmt.Sprintf("%s:%s", msg, err))
    }
}

连接我们的服务器,在下面的代码中,首先我们使用Dial函数,用我们的账号密码,进行拨号获得一个TCP连接。

conn, err := amqp.Dial("amqp://admin:admin@192.168.10.252:5672")
failOnError(err, "Failed to connect to RabbitMQ")
defer conn.Close()

创建通道

有了连接我们需要创建一个通道,又称之为信道,信道是建立在“真实的”TCP 连接内的虚拟连接,AMQP 命令都是通过信道发送出去的,每条信道都会被指派一个唯一的ID(AMQP库会帮你记住ID的),不论是发布消息、订阅队列或者接收消息,这些动作都是通过信道来完成的。

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

申请队列

在发送消息之前我们需要用信道申请一个队列,存放我们的消息,具体的参数解释,请看代码注释

q, err := ch.QueueDeclare(
    "hello", //队列的名字
    true,    //是否持久化
    false,   //对列没有用到的时候是否删除
    false,   //是否设置排他,true为是。如果设置为排他,则队列仅对首次声明他的连接可见,并在连接断开时自动删除
    false,   //是否非阻塞,true表示是。阻塞:表示创建交换器的请求发送后,阻塞等待RMQ Server返回信息
    nil,     //arguments
)

在上面中需要注意的是持久化的设置,这里的持久化设置为true,当我们重启我们的服务器时,我们的队列仍然存在,因为服务会把持久化的queue存放在硬盘上,但是消息的持久化,还需要在发送消息的时候进行设置。

发送消息

在这段代码中需要注意的是对消息的持久化设置,将这行代码去掉,即代表对消息不进行持久化。在发送消息的时候需要指定交换器和队列的名字,这样消费者才能准确的收到消息从该队列中。

body := "Hello"
err = ch.Publish(
    "",     //发送到交换机的名字
    q.Name, // 路由,即队列的名字
    false,  //mandatory
        false,  //immediate
    amqp.Publishing{
        DeliveryMode: amqp.Persistent, //消息的持久化
        ContentType:  "text/plain",
        Body:         []byte(body),
    },
)

消费者发送消息

在写以下的代码中最好新建一个消费者的文件,这个消费者程序,同样需要连接我们的服务器,和创建信道,申请队列,要保证和上面的代码完全一致。现在我们来看如何进行消费:

msgs, err := ch.Consume(
        q.Name, //队列的名称
        "",     //消费者的名称
        false,  // 是否自动应答
        false,  //是否排他
        false,  // 如果设置为true,则生产者与消费者不能是同一连接
        false,  // no-wait
        nil,    // arguments
    )
    failOnError(err, "Failed to register a consumer")
    forever := make(chan bool)

    go func() {
        for d := range msgs {
            log.Printf("Received a message : %s", d.Body)
            // 开始手动应答
            d.Acknowledger.Ack(d.DeliveryTag, true)
        }
    }()

    log.Printf(" [*] Waiting for messages, To exit press CTRL+C")
    <-forever

上面代码中需要注意的是消费需要指定队列的名字,是否设置自动应答,这里推荐false我们使用了d.Acknowledger.Ack(d.DeliveryTag, true)进行手动应答,防止消息丢失,只有确保我们收到消息,才应该告诉服务器,将这条消息进行删除,另外需要注意的是,我们创建了一个协程来持续消费消息,只要生产者生产消息,发送到相应的队列,我们就可以对消息进行打印,为防止main函数的主进程提前结束,我们使用forever这个通道进行阻塞,只有强制结束程序,forever才会释放阻塞。

运行效果

生产者发送4条消息

可视化界面显示

消费者收消息

最终可视化界面显示

本文分享自微信公众号 - golang技术杂文(gh_ebbdb61f463e),作者:无崖子天下无敌

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2019-08-06

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • NATS用Go入门实践

    NATS系统通常由具有nats或tls协议的标准URL标识,例如, NATS://demo.nats.io。NATS系统可以是单个服务器,小型集群或全局超级集群...

    陌无崖
  • NATS多种连接Golang实践

    如果因为任何原因断开连接,大多数(如果不是全部)客户端库将重新连接到NATS系统。重新连接逻辑可能因库而异,因此请检查客户端库的文档。

    陌无崖
  • 30天习惯养成第三天

    今天是习惯养成的第三天了,昨天给自己安排今天任务时想尝试了任务少会是什么状态,因为前两天总觉得任务过满,自己完成之后很疲惫,觉得时间不够用。

    陌无崖
  • 在学习Python的道路上,我们应该如何走好这条路

    当你决定入门 Python 时,需要有一个清晰且短期内可实现的目标,比如通过学习找一份初级程序员工作,目标明确后,你需要知道企业对 Python 程序员的技能有...

    企鹅号小编
  • 安卓实现安卓-光速虚拟机技术内幕

    光速虚拟机是基于安卓系统和ARM处理器架构实现的一套虚拟化技术,在安卓系统的用户态空间无需特殊权限实现了一套完整的安卓内核和硬件抽象层,能够在安卓APP内部运行...

    用户6237893
  • 继万字谏言后,Python Web 怎么学,看这篇就够了!

    之前那篇「万字谏言,给那些想学Python的人,建议收藏后细看!」得到很多后台读者的留言,表示想再来点,甚至说万字系?你知道万字有多少么?不要杠我根本没有万字!...

    用户1634449
  • 性能测评(1):MySQL云数据库vs自建数据库

    最近在学习数据库相关知识,经常跟一个在某金融公司做DBA的大学朋友交流问题。听说他们公司最近在使用云数据库,我立马来了兴趣,以前只听说过云主机,没想到数据库这种...

    磊哥测评
  • 磊哥测评之数据库篇:自建数据库VS云数据库,到底怎么选?

    最近在学习数据库相关知识,经常跟一个在某金融公司做DBA的大学朋友交流问题。听说他们公司最近在使用云数据库,我立马来了兴趣,以前只听说过云主机,没想到数据库这种...

    腾讯云数据库 TencentDB
  • 云计算赛道:网宿科技掉队了?

    3月以来国内疫情逐步得到控制,“新基建”从政府部署到产业落实不断提速,目前已经形成了强劲的风口。

    刘旷
  • Linux驱动开发概述

    原文出处:http://www.cnblogs.com/jacklu/p/4722563.html

    用户7043923

扫码关注云+社区

领取腾讯云代金券