Rabbitmq中的channel接口常用方法详解
作者：轻尘×
channel接口常用方法
Queue.DeclareOk queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete,
Map<String, Object> arguments) throws IOException;方法作用：
声明一个队列
参数：queue
含义：队列名称
参数：durable
含义：是否持久化，如果设置为true，服务器重启了队列仍然存在
参数：exclusive
含义：是否为独享队列（排他性队列），只有自己可见的队列，即不允许其它用户访问
如果exclusive声明为true，则该队列的特点是：
1、只对首次声明它的连接（Connection）可见
2、会在其连接断开的时候自动删除。
参数：autoDelete
含义：当没有任何消费者使用时，自动删除该队列
参数：arguments
含义：其他参数 api解释
void basicQos(int prefetchCount) throws IOException;
解释： 方法作用： 一次获取多少个消息
参数：prefetchCount 含义：会告诉RabbitMQ不要同时给一个消费者推送多于prefetchCount个消息
String basicConsume(String queue, boolean autoAck, Consumer callback) throws IOException;
解释： 方法作用： 订阅消息并消费
参数：queue 含义：所订阅的队列
参数：autoAck 含义：是否开启自动应答，默认是开启的，如果需要手动应答应该设置为false
注意：为了确保消息一定被消费者处理，rabbitMQ提供了消息确认功能，就是在消费者处理完任务之后，就给服务器一个回馈，服务器就会将该消息删除，如果消费者超时不回馈，那么服务器将就将该消息重新发送给其他消费者，当autoAck设置为true时，只要消息被消费者处理，不管成功与否，服务器都会删除该消息，而当autoAck设置为false时，只有消息被处理，且反馈结果后才会删除。
参数：callback 含义：接收到消息之后执行的回调方法 看一下回调方法源码：
void handleDelivery(String consumerTag,
Envelope envelope,
AMQP.BasicProperties properties,
byte[] body)
throws IOException;
}额，看不太懂，反正就是接到消息之后你对消息的处理都要写在这里！
之前我有一个RPC的例子，可以参考一下那里的这个方法如何实现的 //blog.csdn.net/leisure_life/article/details/78657935
void basicPublish(String exchange, String routingKey, BasicProperties props, byte[] body) throws IOException;
解释： 方法作用： 发布一个消息
参数：exchange
含义：指定转发器名称—-ExchangeName，这里用空字符串，就表示消息会交给默认的Exchange
参数：routingKey
含义：发布到哪个队列
参数：props
含义：和消息有关的其他配置参数，路由报头等
参数：body
含义：消息体
源码：
/**
* Publish a message.
*
* Publishing to a non-existent exchange will result in a channel-level
* protocol exception, which closes the channel.
*
* Invocations of <code>Channel#basicPublish</code> will eventually block if a
* <a href="http://www.rabbitmq.com/alarms.html">resource-driven alarm</a> is in effect.
*
* @see com.rabbitmq.client.AMQP.Basic.Publish
* @see <a href="http://www.rabbitmq.com/alarms.html">Resource-driven alarms</a>
* @param exchange the exchange to publish the message to
* @param routingKey the routing key
* @param props other properties for the message - routing headers etc
* @param body the message body
* @throws java.io.IOException if an error is encountered
*/
void basicPublish(String exchange, String routingKey, BasicProperties props, byte[] body) throws IOException;void basicAck(long deliveryTag, boolean multiple) throws IOException;
解释： 方法作用： 另外需要在每次处理完成一个消息后，手动向服务端发送一次应答。
参数：deliveryTag
含义：当前消息的类似编号的号码，服务端为每一个消息生成的类似编号的号码
参数：multiple
含义：是否把小于当前deliveryTag的小于都应答了
注意：这个要在打开应答机制后使用，
boolean ack = false ; //打开应答机制 channel.basicConsume(QUEUE_NAME, ack, consumer);
当multiple设置为false时，只会为deliveryTag所对应的消息进行应答，服务端收到应答后将该消息删除 源码：
/**
* Acknowledge one or several received
* messages. Supply the deliveryTag from the {@link com.rabbitmq.client.AMQP.Basic.GetOk}
* or {@link com.rabbitmq.client.AMQP.Basic.Deliver} method
* containing the received message being acknowledged.
* @see com.rabbitmq.client.AMQP.Basic.Ack
* @param deliveryTag the tag from the received {@link com.rabbitmq.client.AMQP.Basic.GetOk} or {@link com.rabbitmq.client.AMQP.Basic.Deliver}
* @param multiple true to acknowledge all messages up to and
* including the supplied delivery tag; false to acknowledge just
* the supplied delivery tag.
* @throws java.io.IOException if an error is encountered
*/
void basicAck(long deliveryTag, boolean multiple) throws IOException;到此这篇关于Rabbitmq中的channel接口常用方法详解的文章就介绍到这了,更多相关channel接口常用方法内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！