1、消费者订阅消息，先创建一个交换器，如果交换器已经存在即返回一个交换器。当然你可以passive 为 true 如果 passive 为 true , 交换器已经存在返回一个已经存在的交换器，否则报错。我暂时不知道用在哪里，所以 先记住一般情况下 创建一个交换器，如果存在就返回一个已经存在的交换器，如果不存在则创建并返回。
JAVA 代码如下【直接给源码的方法定义，是不是很贴心】：
备注是自己翻译的别喷 /** * Declare an exchange, via an interface that allows the complete set of * arguments. * @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) 【是否持久化交换器，这个后面说，还是简单说一下，纠结帝~ 就是交换器中的消息会持久化，就是会存在硬盘当中，宕机或重启服务时会自动恢复当时会牺牲性能，除非你的SSD硬盘好快，当我没有说过~】 * @param autoDelete true if the server should delete the exchange when it is no longer in use 【当这个交换器 已经没有人使用的时候 会自动删除，longer 长时期 当时我不知道长时期是什么时候，所以我会记住是 没人用就自己删掉 自动消失】 * @param internal true if the exchange is internal, i.e. can't be directly * published to by a client. 【不知道什么鬼意思，如果是内部 不会直接发送到客户端，我一般写false ，真心不知道他什么意思，后面学下去应该明白】 * @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 【会抛出IO异常】 */ Exchange.DeclareOk exchangeDeclare(String exchange,String type, boolean durable, boolean autoDelete, boolean internal,Map<String, Object> arguments) throws IOException;2、消费者创建队列，并绑定队列到交换器当中，上写路由键，让交换器知道这个路由键的消息是跑到这个队列当中的。
JAVA 代码如下【直接给源码的方法定义】：
/** * 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) 【私有的，独有的。 这个队列之后这个应用可以消费，上面的英文注释是 说restricted to this connection 就是限制在这个连接可以消费，就是说不限制channel信道咯，具体没有试过，但是应该是这样，除非备注骗我，我读得书少，你唔好呃我！！！】 * @param autoDelete true if we are declaring an autodelete queue (server will delete it when no longer in use) 【没有人使用自动删除】 注意：如果exclusive为true 最好 autodelete都为true 至于为什么 这么简单自己想~ * @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, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments) throws IOException;/** * 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, boolean durable, boolean exclusive, boolean autoDelete,Map<String, Object> arguments) throws IOException; 绑定队列和交换器 并指定路由键 /** * Bind a queue to an exchange. * @see com.rabbitmq.client.AMQP.Queue.Bind * @see com.rabbitmq.client.AMQP.Queue.BindOk * @param queue the name of the queue 【队列名称】 * @param exchange the name of the exchange 【交换器名称】 * @param routingKey the routine key to use for the binding 【路由键】 * @param arguments other properties (binding parameters) 【其他参数 还是那句没有玩过】 * @return a binding-confirm method if the binding was successfully created * @throws java.io.IOException if an error is encountered */ Queue.BindOk queueBind(String queue, String exchange, String routingKey, Map<String, Object> arguments) throws IOException;3、然后消费者就去订阅消息咯，注意在JAVA里面的订阅方法会产生线程阻塞的。