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();
	}
}

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);
	}
	
}