一、简单的生产者和消费者

生产者：

package com.xiaoxu.simple;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;import java.io.IOException;
import java.util.concurrent.TimeoutException;/*** 入门工程*/
public class Producter {//定义一个消息队列static  final  String QUEUE_NAME = "simple_queue";public static void main(String[] args) throws IOException, TimeoutException {//1、创建连接工厂ConnectionFactory connectionFactory = new ConnectionFactory();connectionFactory.setHost("39.101.204.74");//设置主机地址connectionFactory.setPort(5672);//端口号connectionFactory.setUsername("guest");connectionFactory.setPassword("guest");//2. 创建连接；（抽取一个获取连接的工具类）Connection connection = connectionFactory.newConnection();// 3. 创建频道；Channel channel = connection.createChannel();//4. 声明队列；/*** 参数1：队列名称* 参数2：是否定义持久化队列* 参数3：是否独占本次连接* 参数4：是否在不使用的时候自动删除队列* 参数5：队列其它参数*/channel.queueDeclare(QUEUE_NAME,true,false,false,null);// 5. 创建消费者（接收消息并处理消息）；String msg = "我是一个消息。。。。。";// 6. 监听队列/*** 参数1：交换机名称，如果没有指定则使用默认Default Exchage* 参数2：路由key,简单模式可以传递队列名称* 参数3：消息其它属性* 参数4：消息内容*/channel.basicPublish("",QUEUE_NAME,null,msg.getBytes());System.out.println(msg);//7、关闭资源channel.close();connection.close();}}

消费者：

package com.xiaoxu.simple;import com.rabbitmq.client.*;import java.io.IOException;
import java.util.concurrent.TimeoutException;public class Consumer {public static void main(String[] args) throws IOException, TimeoutException {Connection connection = ConnectionUtis.getConnection();//创建频道Channel channel = connection.createChannel();// create queuechannel.queueDeclare(Producter.QUEUE_NAME,true,false,false,null);//creat consumer and set informationDefaultConsumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope,AMQP.BasicProperties properties, byte[] body) throws IOException{//路由keySystem.out.println("路由key为：" + envelope.getRoutingKey());//交换机System.out.println("交换机为：" + envelope.getExchange());//消息idSystem.out.println("消息id为：" + envelope.getDeliveryTag());//收到的消息System.out.println("接收到的消息为：" + new String(body, "utf-8"));}};//listen to the messagechannel.basicConsume(Producter.QUEUE_NAME,false,consumer);}
}

提取的连接工具：

package com.xiaoxu.simple;import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;import java.io.IOException;
import java.util.concurrent.TimeoutException;public class ConnectionUtis {public static  Connection getConnection() throws IOException, TimeoutException {//1、创建连接工厂ConnectionFactory connectionFactory = new ConnectionFactory();connectionFactory.setHost("39.101.204.74");connectionFactory.setPort(5672);connectionFactory.setUsername("guest");connectionFactory.setPassword("guest");//创建连接Connection connection = connectionFactory.newConnection();return connection;}
}

三、测试
先开启消费者一直监听消息队列，再开启生产者。