【RabbitMQ】golang客户端教程1——HelloWorld

news/2024/4/29 1:00:14/文章来源:https://blog.csdn.net/m0_53328239/article/details/132004410

一、介绍

本教程假设RabbitMQ已安装并运行在本机上的标准端口（5672）。如果你使用不同的主机、端口或凭据，则需要调整连接设置。如果你未安装RabbitMQ，可以浏览我上一篇文章Linux系统服务器安装RabbitMQ

RabbitMQ是一个消息代理：它接受并转发消息。你可以把它想象成一个邮局：当你把你想要邮寄的邮件放进一个邮箱时，你可以确定邮差先生或女士最终会把邮件送到你的收件人那里。在这个比喻中，RabbitMQ是一个邮箱、一个邮局和一个邮递员。

RabbitMQ和邮局的主要区别在于它不处理纸张，而是接受、存储和转发二进制数据块——消息。

RabbitMQ和一般的消息传递都使用一些术语。

  • 生产仅意味着发送。发送消息的程序是生产者：
    在这里插入图片描述

  • 队列是位于RabbitMQ内部的邮箱的名称。尽管消息通过RabbitMQ和你的应用程序流动，但它们只能存储在队列中。队列只受主机内存和磁盘限制的限制，实际上它是一个大的消息缓冲区。许多生产者可以向一个队列发送消息，而许多消费者可以尝试从一个队列接收数据。以下是我们表示队列的方式：
    在这里插入图片描述

  • 消费与接收具有相似的含义。消费者是一个主要等待接收消息的程序：
    在这里插入图片描述
    请注意，生产者，消费者和代理（broker）不必位于同一主机上。实际上，在大多数应用程序中它们不是。一个应用程序既可以是生产者，也可以是消费者。

二、Hello World

在本教程的这一部分中，我们将在Go中编写两个小程序：发送单个消息的生产者和接收消息并将其打印出来的消费者。我们将忽略Go-RabbitMQ API中的一些细节，只关注非常简单的事情，以便开始教程。这是一个消息传递版的“Hello World”。

在下图中，“ P”是我们的生产者，“ C”是我们的消费者。中间的框是一个队列——RabbitMQ代表消费者保存的消息缓冲区。

在这里插入图片描述

RabbitMQ讲多种协议。本教程使用amqp0-9-1，这是一个开放的、通用的消息传递协议。RabbitMQ有许多不同语言的客户端。在本教程中，我们将使用Go amqp客户端。

首先，使用go get安装amqp

go get github.com/streadway/amqp

三、发送

在这里插入图片描述
我们将消息发布者（发送者）称为 send.go，将消息消费者（接收者）称为receive.go。发布者将连接到RabbitMQ，发送一条消息，然后退出。

在send.go中，我们需要首先导入库：

package mainimport ("log""github.com/streadway/amqp"
)

我们还需要一个辅助函数来检查每个amqp调用的返回值：

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

然后连接到RabbitMQ服务器

// 1. 尝试连接RabbitMQ，建立连接
// 该连接抽象了套接字连接，并为我们处理协议版本协商和认证等。
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
failOnErrorSend(err, "Failed to connect to RabbitMQ")
defer conn.Close()

其中，amqp.Dial 是用于建立连接到 RabbitMQ 的函数，它使用 AMQP 协议进行通信。该函数的参数是 RabbitMQ 服务器的连接字符串。

amqp://<username>:<password>@<host>:<port>/<vhost>
  • username : RabbitMQ 用户的用户名。
  • password: RabbitMQ 用户的密码。
  • host: RabbitMQ服务器的主机名或IP地址。
  • port: RabbitMQ 服务器的端口号。
  • vhost:需要连接的虚拟主机。

连接抽象了socket连接，并为我们处理协议版本协商和认证等。接下来，我们创建一个通道，这是大多数用于完成任务的API所在的位置：

// 2. 接下来，我们创建一个通道，大多数API都是用过该通道操作的。
ch, err := conn.Channel()
failOnErrorSend(err, "Failed to open a channel")
defer ch.Close()

要发送，我们必须声明要发送到的队列。然后我们可以将消息发布到队列：

// 3. 声明消息要发送到的队列
q, err := ch.QueueDeclare("hello", // 队列的名称false,   // 队列是否持久化false,   // 队列是否在最后一个消费者断开连接后自动删除false,   // 是否设置队列为独占模式false,   // 是否不等待服务器的响应nil,     // 队列的可选参数
)
failOnErrorSend(err, "Failed to declare a queue")body := "Hello World!"
// 4.将消息发布到声明的队列
err = ch.Publish("",     // 要发布消息的目标交换器的名称。q.Name, // 消息的路由键。交换器根据路由键将消息路由到相应的队列。false,  // 是否要求至少一个队列接收该消息false,  // 是否要求消息在发布时立即被消费者接收amqp.Publishing { ContentType: "text/plain",Body:        []byte(body),})//要发布的消息内容
failOnErrorSend(err, "Failed to publish a message")

声明队列是幂等的——仅当队列不存在时才创建。消息内容是一个字节数组，因此你可以在此处编码任何内容。

完整代码：

package mainimport ("github.com/streadway/amqp""log"
)func failOnErrorSend(err error, msg string) {if err != nil {log.Fatalf("%s: %s", msg, err)}
}
func main() {//1.连接RabbitMQ，建立连接//该连接抽象了套接字连接，并为我们处理协议版本协商和认证等。conn, err := amqp.Dial("amqp://licong:123456@8.130.85.112:5672/")failOnErrorSend(err, "Failed to connect to RabitMQ")defer conn.Close()//2.接下来，我们创建一个通道，这是大多数用户完成任务的API所在的位置：ch, err := conn.Channel()failOnErrorSend(err, "Fail to open a channel")defer ch.Close()//3.声明消息要发送的队列q, err := ch.QueueDeclare("hello", //namefalse,   //durablefalse,   //delete when unusedfalse,   //exclusivefalse,   //no-waitnil,     //arguments)failOnErrorSend(err, "Failed to declare a queue")body := "Hello World!"//4.将消息发布到声明的队列err = ch.Publish("",     //exchangeq.Name, //routing keyfalse,  //mandatoryfalse,  //immediateamqp.Publishing{ContentType: "text/plain",Body:        []byte(body),},)failOnErrorSend(err, "Failed to publish a message")log.Printf(" [x] Sent %s\n", body)
}

四、发送

上面是我们的发布者。我们的消费者监听来自RabbitMQ的消息，因此与发布单个消息的发布者不同，我们将使消费者保持运行状态以监听消息并打印出来。
在这里插入图片描述
该代码（在receive.go中）具有与send相同的导入和帮助功能：

import ("github.com/streadway/amqp""log"
)func failOnErrorReceive(err error, msg string) {if err != nil {log.Fatalf("%s: %s", msg, err)}
}

设置与发布者相同；我们打开一个连接和一个通道，并声明要消耗的队列。请注意，这与send发布到的队列匹配。

//建立连接conn, err := amqp.Dial("amqp://licong:123456@8.130.85.112:5672/")failOnErrorReceive(err, "Failed to connect to RabbitMQ")defer conn.Close()//获取channelch, err := conn.Channel()failOnErrorReceive(err, "Failed to open a channel")defer ch.Close()//声明队列q, err := ch.QueueDeclare("hello", //namefalse,   //durablefalse,   //delete when unusedfalse,   //exclusivefalse,   //no-waitnil,     //argument)failOnErrorReceive(err, "Failed to declare a queue")
failOnError(err, "Failed to declare a queue")

请注意，我们也在这里声明队列。因为我们可能在发布者之前启动使用者，所以我们希望在尝试使用队列中的消息之前确保队列存在。

我们将告诉服务器将队列中的消息传递给我们。由于它将异步地向我们发送消息，因此我们将在goroutine中从通道（由amqp::Consume返回）中读取消息。

//获取接收消息的Delivery通道msgs, err := ch.Consume(q.Name, //要消费消息的队列名称"",     //消费者标识，留空字符串会自动生成一个唯一标识符。true,   //是否自动确认消息false,  //是否设置队列为独占模式false,  //是否禁止消费者接收自己发布的消息false,  //是否不等待服务器的响应nil,    //队列的可选参数)failOnErrorReceive(err, "Failed to register a consumer")forever := make(chan bool)go func() {for d := range msgs {log.Printf("Reveived a message:%s", d.Body)}}()log.Printf("[*] Waiting for messages. To exit press CTRL+C")<-forever

五、运行

终端运行：

go run send.go

在这里插入图片描述

go run receive.go

在这里插入图片描述

推荐：https://www.rabbitmq.com/getstarted.html

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.luyixian.cn/news_show_337485.aspx

如若内容造成侵权/违法违规/事实不符，请联系dt猫网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

25.10 matlab里面的10中优化方法介绍—— 函数fmincon（matlab程序）

25.10 matlab里面的10中优化方法介绍—— 函数fmincon（matlab程序）

1.简述 关于非线性规划 非线性规划问题是指目标函数或者约束条件中包含非线性函数的规划问题。 前面我们学到的线性规划更多的是理想状况或者说只有在习题中&#xff0c;为了便于我们理解&#xff0c;引导我们进入规划模型的一种情况。相比之下&#xff0c;非线性规划会更加贴近…
阅读更多...
联想北京公司研发管理部高级经理周燕龙受邀为第十二届中国PMO大会演讲嘉宾

联想北京公司研发管理部高级经理周燕龙受邀为第十二届中国PMO大会演讲嘉宾

联想&#xff08;北京&#xff09;有限公司研发管理部高级经理周燕龙先生受邀为由PMO评论主办的2023第十二届中国PMO大会演讲嘉宾&#xff0c;演讲议题&#xff1a;PMO如何助力研发。大会将于8月12-13日在北京举办&#xff0c;敬请关注&#xff01; 议题简要&#xff1a; PMO在…
阅读更多...
gitee使用参考

gitee使用参考

Git代码托管服务 2.1 常用的Git代码托管服务 gitHub&#xff08; 地址&#xff1a;https://github.com/ &#xff09;是一个面向开源及私有软件项目的托管平台&#xff0c;因为只支持Git 作为唯一的版本库格式进行托管&#xff0c;故名gitHub码云&#xff08;地址&#xff1a;…
阅读更多...
Docker安装部署ShardingProxy详细教程

Docker安装部署ShardingProxy详细教程

&#x1f680; ShardingSphere &#x1f680; &#x1f332; 算法刷题专栏 | 面试必备算法 | 面试高频算法 &#x1f340; &#x1f332; 越难的东西,越要努力坚持&#xff0c;因为它具有很高的价值&#xff0c;算法就是这样✨ &#x1f332; 作者简介&#xff1a;硕风和炜&…
阅读更多...
Go 下载安装教程

Go 下载安装教程

1. 下载地址&#xff1a;The Go Programming Language (google.cn) 2. 下载安装包 3. 安装 &#xff08;1&#xff09;下一步 &#xff08;2&#xff09;同意 &#xff08;3&#xff09;修改安装路径&#xff0c;如果不修改&#xff0c;直接下一步 更改后&#xff0c;点击下一…
阅读更多...
13个ChatGPT类实用AI工具汇总

13个ChatGPT类实用AI工具汇总

在ChatGPT爆火后&#xff0c;各种工具如同雨后春笋一般层出不穷。以下汇总了13种ChatGPT类实用工具&#xff0c;可以帮助学习、教学和科研。 01 / ChatGPT for google/ 一个浏览器插件&#xff0c;可搭配现有的搜索引擎来使用 最大化搜索效率&#xff0c;对搜索体验的提升相…
阅读更多...
DataStructure--Basic

DataStructure--Basic

程序设计数据结构算法 只谈数据结构不谈算法就跟去话剧院看梁山伯与祝英台结果只有梁山伯在演&#xff0c;祝英台生病了没来一样。 本文的所有内容都出自《大话数据结构》这本书中的代码实现部分&#xff0c;建议看书&#xff0c;书中比我本文写的全。 数据结构&#xff0c;直…
阅读更多...
2023.07.13力扣6题

2023.07.13力扣6题

931. 下降路径最小和 给你一个 n x n 的 方形 整数数组 matrix &#xff0c;请你找出并返回通过 matrix 的下降路径 的 最小和 。 下降路径可以从第一行中的任何元素开始&#xff0c;并从每一行中选择一个元素。在下一行选择的元素和当前行所选元素最多相隔一列&#xff08;即位…
阅读更多...
【数据结构】无头+单向+非循环链表（SList）（增、删、查、改）详解

【数据结构】无头+单向+非循环链表（SList）（增、删、查、改）详解

一、链表的概念及结构 1、链表的概念 之前学习的顺序表是用一段物理地址连续的存储单元依次存储数据元素的线性结构&#xff0c;而链表是一种物理存储结构上非连续、非顺序的存储结构&#xff0c;数据元素的逻辑顺序是通过链表中的指针链接次序实现的&#xff0c;可以实现更加…
阅读更多...
SpringBoot项目连接数据库

SpringBoot项目连接数据库

1、找到applications.yml&#xff0c;如下图 2、写入代码 server:port: 9494spring:datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/自己的数据库表名?serverTimezoneGMT%2b8username: rootpassword: root
阅读更多...
[C语言] 数组

[C语言] 数组

1. 一维数组的创建和初始化 2. 一维数组的使用 3. 一维数组在内存中的存储 4. 二维数组的创建和初始化 5. 二维数组的使用 6. 二维数组在内存中的存储 7. 数组越界 8. 数组作为函数参数 9. 数组的应用实例 1 &#xff1a;三子棋 10. 数组的应用实例 2 &#…
阅读更多...
Spring Tool Suite 4

Spring Tool Suite 4

参考&#xff1a;Spring tool suite4 安装及配置_springtoolsuite4_猿界零零七的博客-CSDN博客 下载&#xff1a;Spring | Tools 将下载的JAR进行解压两次&#xff0c;直至解压出contents中的sts 双击启动 第一次打开需要指定工作区文件夹 配置Maven的config 安装插件
阅读更多...
Pytorch学习笔记1：张量+训练参数传入与处理+制作训练集

Pytorch学习笔记1：张量+训练参数传入与处理+制作训练集

文章目录 Pytorch中张量的一些常见函数最基础也最常见的方法关于Indexing, Slicing, Joining, Mutating Ops&#xff08;索引、切片、聚合、旋转&#xff09;随机种子torch.bernoulli(input)torch.normaltorch.rand(size)torch.randn(size)torch.randperm(n) Python--argparse-…
阅读更多...
Hexo+GithubPages免费搭建个人博客网站

Hexo+GithubPages免费搭建个人博客网站

HexoGithubPages免费搭建个人博客网站 目录 一、前言二、Github配置 新建同名仓库配置Pages 三、安装Hexo四、配置hexo-deployer-git五、访问六、发布文章七、安装主题 一、前言 我之前开了好几年的云服务器了&#xff0c;实际上使用场景并不是很多&#xff0c;感觉有点浪费…
阅读更多...
什么叫前后端分离？为什么需要前后端问题？解决了什么问题？

什么叫前后端分离？为什么需要前后端问题？解决了什么问题？

单体架构出现的问题 引出&#xff1a;来看一个单体项目架构的结构 通过上述可以看到单体架构主要存在以下几点问题&#xff1a; 开发人员同时负责前端和后端代码开发&#xff0c;分工不明确开发效率低前后端代码混合在一个工程中&#xff0c;不便于管理对开发人员要求高(既会前…
阅读更多...
网络层中一些零碎且易忘的知识点

网络层中一些零碎且易忘的知识点

异构网络&#xff1a;指传输介质、数据编码方式、链路控制协议以及数据单元格式和转发机制不同&#xff0c;异构即物理层和数据链路层均不同RIP、OSPF、BGP分别是哪一层的协议&#xff1a; -RIPOSPFBGP所属层次应用层网络层应用层封装在什么协议中UDPIPTCP 一个主机可以有多个I…
阅读更多...
Manjaro KDE 22.1.3vmware无法复制文件

Manjaro KDE 22.1.3vmware无法复制文件

Wayland 是 X11 的现代替代品&#xff0c;几十年来 X11 一直是 Linux 上的默认窗口系统。 Wayland 是一种通信协议&#xff0c;定义 X Window 显示服务器和客户端应用程序之间的消息传递。 软件还不兼容 使用X11即可
阅读更多...
HCIP重发布实验

HCIP重发布实验

目录 实验要求&#xff1a; 步骤一&#xff1a;拓扑设计IP地址规划 拓扑设计 R1 R2 R3 R4 发布路由 R1 R2 R3 R4 双向重发布 在R2和R4 上进行 R2 R4 检查R1 修改开销值选路 择优选择去4.0网段的路径 测试&#xff1a;​编辑 择优选择去32网段的路径 测试&…
阅读更多...
Stable Diffusion 开源模型 SDXL 1.0 发布

Stable Diffusion 开源模型 SDXL 1.0 发布

关于 SDXL 模型&#xff0c;之前写过两篇&#xff1a; Stable Diffusion即将发布全新版本Stable Diffusion XL 带来哪些新东西&#xff1f; 一晃四个月的时间过去了&#xff0c;Stability AI 团队终于发布了 SDXL 1.0。当然在这中间发布过几个中间版本&#xff0c;分别是 SDXL …
阅读更多...
Codeforces算法心得——A. Escalator Conversations

Codeforces算法心得——A. Escalator Conversations

大家好&#xff0c;我是晴天学长&#xff0c;今天开始尝试一些外国的题目了&#xff0c;不得不说&#xff0c;创新性挺高的&#xff0c;然后是全英文&#xff0c;也可以练练英文的水平&#xff0c;后面我会持续的更新的&#xff01;加油&#xff01;&#x1f4aa;&#x1f4aa;…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站 广利置业