RabbitMq六种使用模式(1)_直接指定消息接收队列

ConnectionFactory factory = new ConnectionFactory(); 
factory.setHost("localhost");//此处可以设置多个属性，包括IP地址以及认证账号等信息 
Connection cOnnection= factory.newConnection(); //Connection代表了一个socket链接，具有协议协商和认证的功能； 
Channel channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, false, false, false, null); 
//声明一个队列（如果不存在则创建，如果存在且属性设置一样则不变，如果属性设置不同，则报错 
//队列名称+是否需要持久化（服务重启后可恢复）+是否是排他性的（只属于本connection）+是否自动删除（不再使用时服务器自动删除）+其他属性设置 
String message = "Hello World!"; 
channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); 
// exchange名称+路由关键字(exchange名字为""时代表队列名称)+消息的其他设置信息+消息内容字节数组  
System.out.println(" [x] Sent '" + message + "'"); 
//关闭链接，如果不关闭，connection会以配置的时间间隔心跳保持链接的可用性（如果空闲时间过长，有的系统会强制关闭链接） 
channel.close(); connection.close();

如生产者一样创建链接和通道；
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection cOnnection= factory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, false, false, false, null）
QueueingConsumer cOnsumer= new QueueingConsumer(channel);
channel.basicConsume(QUEUE_NAME, true, consumer);
while (true) {
      QueueingConsumer.Delivery delivery = consumer.nextDelivery();//会阻塞，直到有消息返回
      String message = new String(delivery.getBody());
      System.out.println(" [x] Received '" + message + "'");
}