MQ教程 | RabbitMQ 简单队列 hello world [Java版]（三）

package com.mmr.rabbitmq.conn; 
import java.io.IOException; 
import java.util.concurrent.TimeoutException; 
import com.rabbitmq.client.ConnectionFactory; 
import com.rabbitmq.client.Connection; 
public class ConnectionUtils { 
    public static Connection getConnection() throws IOException, TimeoutException {   //定义连接工厂   ConnectionFactory factory = new ConnectionFactory();   //设置服务地址   factory.setHost("127.0.0.1");   //端口   factory.setPort(5672);//amqp协议 端口 类似与mysql的3306   //设置账号信息，用户名、密码、vhost 
    factory.setVirtualHost("/vhost_mmr"); 
    factory.setUsername("user_mmr"); 
    factory.setPassword("admin");   // 通过工程获取连接   Connection connection = factory.newConnection(); 
    return connection; 
    } 
} 

public class SendMQ { 
    private static final String QUEUE_NAME="QUEUE_simple"; 

    /* 
    P----->|QUEUE | 
    */ 
    @Test 
    public void sendMsg() throws Exception {   /* 获取一个连接 */   Connection connection = ConnectionUtils.getConnection(); 
        /*从连接中创建通道*/   Channel channel = connection.createChannel(); 
        //创建队列 (声明)  因为我们要往队列里面发送消息,这是后就得知道往哪个队列中发送,就好比在哪个管子里面放 水,   boolean durable=false; 
    boolean exclusive=false; 
    boolean autoDelete=false;   channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, null);//如果这个队列不存在,其实 这句话是不需要的 

    String msg="Hello  Simple QUEUE !";    //第一个参数是exchangeName(默认情况下代理服务器端是存在一个""名字的exchange的,       //因此如果不创建exchange的话我们可以直接将该参数设置成"",如果创建了exchange的话    //我们需要将该参数设置成创建的exchange的名字),第二个参数是路由键   channel.basicPublish("", QUEUE_NAME, null, msg.getBytes()); 
    System.out.println("---------send ms :"+msg); 

    channel.close(); 
    connection.close(); 
    } 
} 

package com.mmr.rabbitmq.simple; 

import java.io.IOException; 

import com.mmr.rabbitmq.conn.ConnectionUtils; 
import com.rabbitmq.client.AMQP.BasicProperties; 
import com.rabbitmq.client.Channel; 
import com.rabbitmq.client.Connection; 
import com.rabbitmq.client.DefaultConsumer; 
import com.rabbitmq.client.Envelope; 
import com.rabbitmq.client.QueueingConsumer; 

public class Consumer { 
 private static final String QUEUE_NAME = "QUEUE_simple"; 

 public static void main(String[] args) throws Exception { 

  /* 获取一个连接 */   Connection connection = ConnectionUtils.getConnection(); 
  Channel channel = connection.createChannel(); 

  //声明队列  如果能确定是哪一个队列 这边可以删掉,不去掉 这里会忽略创建   //channel.queueDeclare(QUEUE_NAME, false, false, false, null); 

  DefaultConsumer consumer = new DefaultConsumer(channel) {    //获取到达的消息 
   @Override 
   public void handleDelivery(String consumerTag, Envelope envelope, BasicProperties 
properties, byte[] body) throws IOException { 
    String message = new String(body, "UTF-8"); 
    System.out.println(" [x] Received '" + message + "'"); 
   } 
  }; 

  //监听队列   channel.basicConsume(QUEUE_NAME, true, consumer); 
 } 

 @SuppressWarnings("deprecation") 
 private static void oldGet(Channel channel) throws IOException, InterruptedException {   //定义队列的消费者 
  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 + "'"); 
  } 
 } 
 }