一：安装rabbitMQ服务组件，建议开发测试的时候在windows下，Linux下安装rabbitMQ太麻烦，会花费大量时间，还不一定能安装成功。推荐一个https://blog.csdn.net/tjcyjd/article/details/77150893 ，讲解很详细，参考一下。

二：RabbitMQ基本概念。推荐一个https://www.cnblogs.com/luotianshuai/p/7469365.html，讲解很详细。

三：官网的介绍最直接，如果你的英文很好，建议直接看官方介绍http://www.rabbitmq.com/getstarted.html。

四：RabbitMQ的channel参数详解，推荐一个https://www.cnblogs.com/piaolingzxh/p/5448927.html。

五：废话不多说，直接上代码，还是代码来的直接。

1：队列模式的生产者

//定义消息队列名称
private final static String QUEUE_NAME = "0625ceshi";

public static void send(String content) {
		ConnectionFactory factory = null;
		Connection connection = null;
		Channel channel = null;
		try {
                        //创建连接工厂
			factory = new ConnectionFactory();
                        //设置连接属性
			factory.setHost("127.0.0.1");
			factory.setPort(5672);
			factory.setUsername("guest");
			factory.setPassword("guest");
                        //  连接服务
			connection = factory.newConnection();
                        //创建channel
			channel = connection.createChannel();
                        //绑定队列
			channel.queueDeclare(QUEUE_NAME, true, false, false, null);
			String aa="要发送的数据";
			//发送数据
				channel.basicPublish("", QUEUE_NAME, MessageProperties.PERSISTENT_BASIC, aa.getBytes("UTF-8"));
			}catch (Exception e) {
	            e.printStackTrace();
	        }
}
			

2：队列模式的消费者

//定义队列名称
private final static String QUEUE_NAME = "0625ceshi";

public static String receive() {		
		ConnectionFactory factory = null;
		Connection connection = null;
		Channel channel = null;
		try {
			factory = new ConnectionFactory();
			factory.setHost("127.0.0.1");
			connection = factory.newConnection();
			channel = connection.createChannel();
                        //绑定要消费的队列名称
			channel.queueDeclare(QUEUE_NAME, false, false, false, null);
                        //创建消费者消费信息，消费者方法是一个阻塞方法，启动后一直处于监听状态
			Consumer 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");
					List<String> sqlList=Arrays.asList(message.split("/n"));
					for (int i = 0; i < sqlList.size(); i++) {
						System.out.println(sqlList.get(i));
					}
					
					//System.out.println("收到消息....." + message);					
				}
			};
                        //设置第二个参数为false 当noAck=false时，RabbitMQ会等待消费者显式发回
			channel.basicConsume(QUEUE_NAME, true, consumer);
			
		} catch (IOException e) {
			e.printStackTrace();
		} catch (TimeoutException e) {
			e.printStackTrace();
		} finally {
			if (channel != null) {
				// 关闭资源
				// channel.close();
			}
			if (connection != null) {
				// connection.close();
			}
		}
		return content;
	}

这是最简单的rabbitMQ生产消费信息的模式代码。