RabbitMQ 教程

AMQP 命令概览

AMQP 0-9-1 协议中定义的命名远远不止AMQP 协议介绍中使用到的命令。

下面将列举AMQP 0-9-1协议主要的命令。如下表:

名称是否包含内容对应Java方法描述
连接命令
Connection.Start
factory.newConnection()建立连接
Connection.Start-OK
factory.newConnection()建立连接
Connection.Tune
factory.newConnection()建立连接
Connection.Tune-OK
factory.newConnection()建立连接
Connection.Open
factory.newConnection()建立连接
Connection.Open-OK
factory.newConnection()建立连接
Connection.Close
connection.close()关闭连接
Connection.Close-OK
connection.close()关闭连接
信道命令
Channel.Open
connection.openChannel()打开信道
Channel.Open-OKconnection.openChannel()打开信道
Channel.Closechannel.close()关闭信道
Channel.Close-OKchannel.close()关闭信道
交换器命令
Exchange.Declare
channel.exchangeDeclare()声明交换器
Exchange.Declare-OKchannel.exchangeDeclare()声明交换器
Exchange.Deletechannel.exchangeDelete()删除交换器
Exchange.Delete-OKchannel.exchangeDelete()删除交换器
Exchange.Bindchannel.exchangeBind()交换器与交换器绑定
Exchange.Bind-OKchannel.exchangeBind()交换器与交换器绑定
Exchange.Unbindchannel.exchangeUnbind()交换器与交换器解绑
Exchange.Unbing-OKchannel.exchangeUnbind()交换器与交换器解绑
队列命令
Queue.Declarechannel.queueDeclare()声明队列
Queue.Declare-OKchannel.queueDeclare()声明队列
Queue.Bindchannel.queueBind()队列与交换器绑定
Queue.Bind-OKchannel.queueBind()队列与交换器绑定
Queue.Unbindchannel.queueUnbind()队列与交换器解绑
Queue.Unbind-OKchannel.queueUnbind()队列与交换器解绑
Queue.Purgechannel.queuePurge()清除队列中的内容
Queue.Purge-OKchannel.queuePurge()清除队列中的内容
Queue.Deletechannel.queueDelete()删除队列
Queue.Delete-OKchannel.queueDelete()删除队列
基础命令
Basic.Qos
channel.basicQos()设置未被确认消费的个数
Basic.Qos-OKchannel.basicQos()设置未被确认消费的个数
Basic.Consumechannel.basicConsume()消费消息(推模式)
Basic.Consume-OKchannel.basicConsume()消费消息(推模式)
Basic.Cancelchannel.basicCancel()取消
Basic.Cancel-OKchannel.basicCancel()取消

Basic.Publish

channel.basicPublish()发送消息
Basic.Return未能成功路由的消息返回
Basic.DeliverBroker 推送消息
Basic.Getchannel.basicGet()消费消息(拉模式〉
Basic.Get-OKchannel.basicGet()消费消息(拉模式〉
Basic.Ackchannel.basicAck()确认
Basic.Rejectchannel.basicReject()拒绝(单条拒绝)
Basic.Recoverchannel.basicRecover()请求 Broker 重新发送未被确认的消息
Basic.Recover-OKchannel.basicRecover()请求 Broker 重新发送未被确认的消息
Basic.Nackchannel.basicNack()拒绝(可批量拒绝〉
事务命令
Tx.Select
channel. txSelect()开启事务
Tx.Select-OKchannel. txSelect()开启事务
Tx.Commitchannel. txCommit()事务提交
Tx.Commit-OKchannel. txCommit()事务提交
Tx.Rollbackchannel.txRollback()事务回滚
Tx.Rollback-OKchannel.txRollback()事务回滚
确认命令
Confirm.Select
channel.confinnSelect()开启发送端确认模式
Confirm.Select-OK
channel.confinnSelect()开启发送端确认模式
说说我的看法
全部评论(
没有评论
关于
本网站专注于 Java、数据库(MySQL、Oracle)、Linux、软件架构及大数据等多领域技术知识分享。涵盖丰富的原创与精选技术文章,助力技术传播与交流。无论是技术新手渴望入门,还是资深开发者寻求进阶,这里都能为您提供深度见解与实用经验,让复杂编码变得轻松易懂,携手共赴技术提升新高度。如有侵权,请来信告知:hxstrive@outlook.com
公众号