RabbitMQ 教程

AMQP 命令概览

🎉摘要:本文提供AMQP 0-9-1协议的主要命令概览,按连接、信道、交换器、队列等分类整理,附对应Java实现方法及功能说明。

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-OK否connection.openChannel()打开信道
Channel.Close否channel.close()关闭信道
Channel.Close-OK否channel.close()关闭信道
交换器命令
Exchange.Declare
否channel.exchangeDeclare()声明交换器
Exchange.Declare-OK否channel.exchangeDeclare()声明交换器
Exchange.Delete否channel.exchangeDelete()删除交换器
Exchange.Delete-OK否channel.exchangeDelete()删除交换器
Exchange.Bind否channel.exchangeBind()交换器与交换器绑定
Exchange.Bind-OK否channel.exchangeBind()交换器与交换器绑定
Exchange.Unbind否channel.exchangeUnbind()交换器与交换器解绑
Exchange.Unbing-OK否channel.exchangeUnbind()交换器与交换器解绑
队列命令
Queue.Declare否channel.queueDeclare()声明队列
Queue.Declare-OK否channel.queueDeclare()声明队列
Queue.Bind否channel.queueBind()队列与交换器绑定
Queue.Bind-OK否channel.queueBind()队列与交换器绑定
Queue.Unbind否channel.queueUnbind()队列与交换器解绑
Queue.Unbind-OK否channel.queueUnbind()队列与交换器解绑
Queue.Purge否channel.queuePurge()清除队列中的内容
Queue.Purge-OK否channel.queuePurge()清除队列中的内容
Queue.Delete否channel.queueDelete()删除队列
Queue.Delete-OK否channel.queueDelete()删除队列
基础命令
Basic.Qos
否channel.basicQos()设置未被确认消费的个数
Basic.Qos-OK否channel.basicQos()设置未被确认消费的个数
Basic.Consume否channel.basicConsume()消费消息(推模式)
Basic.Consume-OK否channel.basicConsume()消费消息(推模式)
Basic.Cancel否channel.basicCancel()取消
Basic.Cancel-OK否channel.basicCancel()取消

Basic.Publish

是channel.basicPublish()发送消息
Basic.Return是无未能成功路由的消息返回
Basic.Deliver是无Broker 推送消息
Basic.Get否channel.basicGet()消费消息(拉模式〉
Basic.Get-OK是channel.basicGet()消费消息(拉模式〉
Basic.Ack否channel.basicAck()确认
Basic.Reject否channel.basicReject()拒绝(单条拒绝)
Basic.Recover否channel.basicRecover()请求 Broker 重新发送未被确认的消息
Basic.Recover-OK否channel.basicRecover()请求 Broker 重新发送未被确认的消息
Basic.Nack否channel.basicNack()拒绝(可批量拒绝〉
事务命令
Tx.Select
否channel. txSelect()开启事务
Tx.Select-OK否channel. txSelect()开启事务
Tx.Commit否channel. txCommit()事务提交
Tx.Commit-OK否channel. txCommit()事务提交
Tx.Rollback否channel.txRollback()事务回滚
Tx.Rollback-OK否channel.txRollback()事务回滚
确认命令
Confirm.Select
否channel.confinnSelect()开启发送端确认模式
Confirm.Select-OK
否channel.confinnSelect()开启发送端确认模式

说说我的看法
全部评论()
没有评论
关于
本网站专注于 Java、数据库(MySQL、Oracle)、Linux、软件架构及大数据等多领域技术知识分享。涵盖丰富的原创与精选技术文章,助力技术传播与交流。无论是技术新手渴望入门,还是资深开发者寻求进阶,这里都能为您提供深度见解与实用经验,让复杂编码变得轻松易懂,携手共赴技术提升新高度。如有侵权,请来信告知:hxstrive@outlook.com
其他应用
公众号