本文介绍: 接下来我们只是通过Java语言理解下要如何使用RabbitMQ。其他语言客户端可以参考示例官方文件,RabbitMQ的使用生态已经相当庞大,支持非常多的业务场景,同时也提供了非常多的客户端语言支持。使用RabbitMQ提供的原生客户端API进行交互。这是使用RabbitMQ的基础。

RabbitMQ基础编程模型

RabbitMQ的使用生态已经相当庞大,支持非常多的业务场景,同时也提供了非常多的客户端语言支持。
接下来我们只是通过Java语言理解下要如何使用RabbitMQ。其他语言客户端可以参考示例官方文件,
自行了解。
使用RabbitMQ提供的原生客户端API进行交互。这是使用RabbitMQ的基础。

基础编程模型

step1、首先创建连接获取Channel

通常情况下,我们一个客户端里都只是创建一个Channel可以了,因为一个Channel只要不关闭,是
可以一直复用的。但是,如果你想要创建多个Channel,要注意一下Channel冲突问题
创建channel时,可以在createChannel方法中传入一个分配int参数channelNumber这个
ChannelNumber就会作为Channel的唯一标识。而RabbitMQ防止ChannelNumber重复方式是:如果对
应的Channel没有创建过,就会创建一个新的Channel。但是如果ChannelNumber已经创建一个Channel
了,这时就会返回一个null

step2、声明Exchange-可选

Exchange消息收发过程中是一个可选的步骤,如果要使用就需要先进行声明。在声明Exchange需要
注意,如果Broker没有对应的Exchange,那么RabbitMQ会自动创建一个新的交换机。但是如果Broker
已经有了这个Exchange,那么你声明时的这些参数需要与Broker上的保持一致。如果不一致就会报错
声明Exchange时可以填入很多参数,对这些参数,你不用死记。实际上这些参数,包括最后
arguments中可以传入哪些参数,在管理控制台中都有。关键属性页面上都有解释

step3、声明queue

与Exchange一样,如果你声明的Queue在Broker上不存
在,RabbitMQ会创建一个新的队列。但是如果Broker上已经有了这个队列,那么声明的属性必须和Broker
上的队列保持一致,否则也会报错
声明Queue时,同样大部分参数是可以从管理平台看到的。比如Durability,AutoDelete以及后面的
arguments参数可以传哪些参数,都可以从页面看到

step4、声明Exchange与Queue的绑定关系-可选

原文地址:https://blog.csdn.net/qq_43049895/article/details/134819980

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任

如若转载,请注明出处:http://www.7code.cn/show_47354.html

如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱suwngjj01@126.com进行投诉反馈,一经查实,立即删除

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注