https://www.cnblogs.com/piaolingzxh/p/5448927.html

1但指、Channel

1.1 channel.exchangeDeclare()：

type：有direct、fanout彻舰、topic三種

durable：true佛猛、false true：服務(wù)器重啟會(huì)保留下來Exchange惑芭。警告：僅設(shè)置此選項(xiàng)，不代表消息持久化继找。即不保證重啟后消息還在遂跟。原文：true if we are declaring a durable exchange (the exchange will survive a server restart)

autoDelete:true、false.true:當(dāng)已經(jīng)沒有消費(fèi)者時(shí)，服務(wù)器是否可以刪除該Exchange幻锁。原文1：true if the server should delete the exchange when it is no longer in use凯亮。

/**? ? * Declare an exchange.

? ? * @see com.rabbitmq.client.AMQP.Exchange.Declare

? ? * @see com.rabbitmq.client.AMQP.Exchange.DeclareOk

? ? * @param exchange the name of the exchange

? ? * @param type the exchange type

? ? * @param durable true if we are declaring a durable exchange (the exchange will survive a server restart)

? ? * @param autoDelete true if the server should delete the exchange when it is no longer in use

? ? * @param arguments other properties (construction arguments) for the exchange

? ? * @return a declaration-confirm method to indicate the exchange was successfully declared

? ? * @throws java.io.IOException if an error is encountered

? ? */? ? Exchange.DeclareOk exchangeDeclare(String exchange, String type, booleandurable,boolean autoDelete,

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? Map arguments)throwsIOException;

1.2 chanel.basicQos()

prefetchSize：0

prefetchCount：會(huì)告訴RabbitMQ不要同時(shí)給一個(gè)消費(fèi)者推送多于N個(gè)消息，即一旦有N個(gè)消息還沒有ack哄尔，則該consumer將block掉假消，直到有消息ack

global：true\false 是否將上面設(shè)置應(yīng)用于channel，簡單點(diǎn)說岭接，就是上面限制是channel級(jí)別的還是consumer級(jí)別

備注：據(jù)說prefetchSize 和global這兩項(xiàng)富拗，rabbitmq沒有實(shí)現(xiàn)，暫且不研究

/**? ? * Request specific "quality of service" settings.

? ? *

? ? * These settings impose limits on the amount of data the server

? ? * will deliver to consumers before requiring acknowledgements.

? ? * Thus they provide a means of consumer-initiated flow control.

? ? * @see com.rabbitmq.client.AMQP.Basic.Qos

? ? * @param prefetchSize maximum amount of content (measured in

? ? * octets) that the server will deliver, 0 if unlimited

? ? * @param prefetchCount maximum number of messages that the server

? ? * will deliver, 0 if unlimited

? ? * @param global true if the settings should be applied to the

? ? * entire channel rather than each consumer

? ? * @throws java.io.IOException if an error is encountered

? ? */voidbasicQos(intprefetchSize,intprefetchCount,booleanglobal)throwsIOException;

1.3 channel.basicPublish()

routingKey：路由鍵鸣戴，#匹配0個(gè)或多個(gè)單詞啃沪，*匹配一個(gè)單詞，在topic exchange做消息轉(zhuǎn)發(fā)用

mandatory：true：如果exchange根據(jù)自身類型和消息routeKey無法找到一個(gè)符合條件的queue窄锅，那么會(huì)調(diào)用basic.return方法將消息返還給生產(chǎn)者创千。false：出現(xiàn)上述情形broker會(huì)直接將消息扔掉

immediate：true：如果exchange在將消息route到queue(s)時(shí)發(fā)現(xiàn)對(duì)應(yīng)的queue上沒有消費(fèi)者，那么這條消息不會(huì)放入隊(duì)列中入偷。當(dāng)與消息routeKey關(guān)聯(lián)的所有queue(一個(gè)或多個(gè))都沒有消費(fèi)者時(shí)追驴，該消息會(huì)通過basic.return方法返還給生產(chǎn)者。

BasicProperties ：需要注意的是BasicProperties.deliveryMode疏之，0:不持久化 1：持久化 這里指的是消息的持久化殿雪，配合channel(durable=true),queue(durable)可以實(shí)現(xiàn)，即使服務(wù)器宕機(jī)锋爪，消息仍然保留

簡單來說：mandatory標(biāo)志告訴服務(wù)器至少將該消息route到一個(gè)隊(duì)列中冠摄，否則將消息返還給生產(chǎn)者；immediate標(biāo)志告訴服務(wù)器如果該消息關(guān)聯(lián)的queue上有消費(fèi)者几缭，則馬上將消息投遞給它，如果所有queue都沒有消費(fèi)者沃呢，直接把消息返還給生產(chǎn)者年栓，不用將消息入隊(duì)列等待消費(fèi)者了。

/**? ? * Publish a message.

? ? *

? ? * Publishing to a non-existent exchange will result in a channel-level

? ? * protocol exception, which closes the channel.

? ? *

? ? * Invocations of Channel#basicPublish will eventually block if a

? ? * resource-driven alarm is in effect.

? ? *

? ? * @see com.rabbitmq.client.AMQP.Basic.Publish

? ? * @see Resource-driven alarms.

? ? * @param exchange the exchange to publish the message to

? ? * @param routingKey the routing key

? ? * @param mandatory true if the 'mandatory' flag is to be set

? ? * @param immediate true if the 'immediate' flag is to be

? ? * set. Note that the RabbitMQ server does not support this flag.

? ? * @param props other properties for the message - routing headers etc

? ? * @param body the message body

? ? * @throws java.io.IOException if an error is encountered

? ? */voidbasicPublish(String exchange, String routingKey,booleanmandatory,booleanimmediate, BasicProperties props,byte[] body)

? ? ? ? ? ? throwsIOException;

1.4channel.basicAck();

deliveryTag:該消息的index

multiple：是否批量.true:將一次性ack所有小于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

? ? */voidbasicAck(longdeliveryTag,booleanmultiple)throwsIOException;

1.5channel.basicNack(delivery.getEnvelope().getDeliveryTag(),?false,?true);

deliveryTag:該消息的index

multiple：是否批量.true:將一次性拒絕所有小于deliveryTag的消息某抓。

requeue：被拒絕的是否重新入隊(duì)列

/**? ? * Reject one or several received messages.

? ? *

? ? * Supply the deliveryTag from the {@link com.rabbitmq.client.AMQP.Basic.GetOk}

? ? * or {@link com.rabbitmq.client.AMQP.Basic.GetOk} method containing the message to be rejected.

? ? * @see com.rabbitmq.client.AMQP.Basic.Nack

? ? * @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 reject all messages up to and including

? ? * the supplied delivery tag; false to reject just the supplied

? ? * delivery tag.

? ? * @param requeue true if the rejected message(s) should be requeued rather

? ? * than discarded/dead-lettered

? ? * @throws java.io.IOException if an error is encountered

? ? */voidbasicNack(longdeliveryTag,booleanmultiple,boolean requeue)

? ? ? ? ? ? throwsIOException;

1.5channel.basicReject(delivery.getEnvelope().getDeliveryTag(),?false);

deliveryTag:該消息的index

requeue：被拒絕的是否重新入隊(duì)列

channel.basicNack 與?channel.basicReject 的區(qū)別在于basicNack可以拒絕多條消息，而basicReject一次只能拒絕一條消息

/**? ? * Reject a message. 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 rejected.

? ? * @see com.rabbitmq.client.AMQP.Basic.Reject

? ? * @param deliveryTag the tag from the received {@link com.rabbitmq.client.AMQP.Basic.GetOk} or {@link com.rabbitmq.client.AMQP.Basic.Deliver}

? ? * @param requeue true if the rejected message should be requeued rather than discarded/dead-lettered

? ? * @throws java.io.IOException if an error is encountered

? ? */voidbasicReject(longdeliveryTag,booleanrequeue)throwsIOException;

1.6 channel.basicConsume(QUEUE_NAME, true, consumer);

autoAck：是否自動(dòng)ack惰瓜，如果不自動(dòng)ack否副，需要使用channel.ack、channel.nack崎坊、channel.basicReject 進(jìn)行消息應(yīng)答

/**? ? * Start a non-nolocal, non-exclusive consumer, with

? ? * a server-generated consumerTag.

? ? * @param queue the name of the queue

? ? * @param autoAck true if the server should consider messages

? ? * acknowledged once delivered; false if the server should expect

? ? * explicit acknowledgements

? ? * @param callback an interface to the consumer object

? ? * @return the consumerTag generated by the server

? ? * @throws java.io.IOException if an error is encountered

? ? * @see com.rabbitmq.client.AMQP.Basic.Consume

? ? * @see com.rabbitmq.client.AMQP.Basic.ConsumeOk

? ? * @see #basicConsume(String, boolean, String, boolean, boolean, Map, Consumer)

? ? */? ? String basicConsume(String queue, booleanautoAck, Consumer callback)throwsIOException;

1.7 chanel.exchangeBind()

channel.queueBind(queueName, EXCHANGE_NAME, bindingKey);

用于通過綁定bindingKey將queue到Exchange备禀，之后便可以進(jìn)行消息接收

/**? ? * Bind an exchange to an exchange, with no extra arguments.

? ? * @see com.rabbitmq.client.AMQP.Exchange.Bind

? ? * @see com.rabbitmq.client.AMQP.Exchange.BindOk

? ? * @param destination the name of the exchange to which messages flow across the binding

? ? * @param source the name of the exchange from which messages flow across the binding

? ? * @param routingKey the routine key to use for the binding

? ? * @return a binding-confirm method if the binding was successfully created

? ? * @throws java.io.IOException if an error is encountered

? ? */? ? Exchange.BindOk exchangeBind(String destination, String source, String routingKey) throwsIOException;

1.8?channel.queueDeclare(QUEUE_NAME, false, false, false, null);

durable：true、false true：在服務(wù)器重啟時(shí)，能夠存活

exclusive ：是否為當(dāng)前連接的專用隊(duì)列曲尸，在連接斷開后赋续，會(huì)自動(dòng)刪除該隊(duì)列，生產(chǎn)環(huán)境中應(yīng)該很少用到吧另患。

autodelete：當(dāng)沒有任何消費(fèi)者使用時(shí)纽乱，自動(dòng)刪除該隊(duì)列。this means that the queue will be deleted when there are no more processes consuming messages from it.

/**? ? * Declare a queue

? ? * @see com.rabbitmq.client.AMQP.Queue.Declare

? ? * @see com.rabbitmq.client.AMQP.Queue.DeclareOk

? ? * @param queue the name of the queue

? ? * @param durable true if we are declaring a durable queue (the queue will survive a server restart)

? ? * @param exclusive true if we are declaring an exclusive queue (restricted to this connection)

? ? * @param autoDelete true if we are declaring an autodelete queue (server will delete it when no longer in use)

? ? * @param arguments other properties (construction arguments) for the queue

? ? * @return a declaration-confirm method to indicate the queue was successfully declared

? ? * @throws java.io.IOException if an error is encountered

? ? */? ? Queue.DeclareOk queueDeclare(String queue, booleandurable,booleanexclusive,boolean autoDelete,

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? Map arguments)throwsIOException;