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() | 开启发送端确认模式 |