定义：

消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过写和检索出入列队的针对应用程序的数据(消息)来通信，而无需专用连接来链接它们。简单理解：蓝牙配对

jar包依赖：

com.rabbitmq

amqp-client

3.0.4

方式一：

(发)

importjava.io.IOException;importcom.rabbitmq.client.Channel;importcom.rabbitmq.client.Connection;importcom.rabbitmq.client.ConnectionFactory;public classSend {private final static String QUEUE_NAME = "qq";public static void main(String[] args) throwsIOException {

ConnectionFactory factory= newConnectionFactory();

factory.setHost("hostname");

factory.setUsername("username");

factory.setPassword("password");

factory.setPort(5672);

Connection connection=factory.newConnection();

Channel channel=connection.createChannel();

channel.queueDeclare(QUEUE_NAME,false, false, false, null);

String message= "Hello World!";

channel.basicPublish("", QUEUE_NAME, null, message.getBytes());

System.out.println(" [x] Sent '" + message + "'");

channel.close();

connection.close();

}

}

(收)

importcom.rabbitmq.client.ConnectionFactory;importcom.rabbitmq.client.QueueingConsumer;importcom.rabbitmq.client.Channel;importcom.rabbitmq.client.Connection;public classReqv {private final static String QUEUE_NAME = "qq";public static void main(String[] argv) throwsException {

ConnectionFactory factory= newConnectionFactory();

factory.setUsername("username");

factory.setPassword("password");

factory.setHost("hostname");

factory.setVirtualHost("/");

factory.setPort(5672);

Connection connection=factory.newConnection();

Channel channel=connection.createChannel();

channel.queueDeclare(QUEUE_NAME,false, false, false, null);

System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

QueueingConsumer consumer= newQueueingConsumer(channel);

channel.basicConsume(QUEUE_NAME,true, consumer);while(true){

QueueingConsumer.Delivery delivery=consumer.nextDelivery();

String message= newString(delivery.getBody());

System.out.println(" [x] Received '" + message + "'");

}

}

}

方式二：

(发)

importcom.rabbitmq.client.Channel;importcom.rabbitmq.client.Connection;importcom.rabbitmq.client.ConnectionFactory;public classSend2 {private static final String EXCHANGE_NAME = "qq";public static void main (String [] argv) throwsjava.io.IOException {

ConnectionFactory factory= newConnectionFactory();

factory.setHost("hostname");

factory.setUsername("username");

factory.setPassword("password");

factory.setPort(5672);

Connection connection=factory.newConnection();

Channel channel=connection.createChannel();

channel.exchangeDeclare(EXCHANGE_NAME,"fanout",true);

String message="hello world";

channel.basicPublish(EXCHANGE_NAME,"",null,message.getBytes());

System.out.println("[x] Sent'" + message + "'");

channel.close();

connection.close();

}

(收)

importjava.io.IOException;importcom.alibaba.fastjson.JSONObject;importcom.rabbitmq.client.AMQP;importcom.rabbitmq.client.Channel;importcom.rabbitmq.client.Connection;importcom.rabbitmq.client.ConnectionFactory;importcom.rabbitmq.client.Consumer;importcom.rabbitmq.client.DefaultConsumer;importcom.rabbitmq.client.Envelope;public classReqv2 {private static final String EXCHANGE_NAME = "qq";public static void main (String [] argv) throwsException {

ConnectionFactory factory= newConnectionFactory();

factory.setHost("hostname");

factory.setUsername("username");

factory.setPassword("password");

factory.setPort(5672);

Connection connection=factory.newConnection();

Channel channel=connection.createChannel();

channel.exchangeDeclare(EXCHANGE_NAME,"fanout",true);

String queueName=channel.queueDeclare().getQueue();

channel.queueBind(queueName,EXCHANGE_NAME,"");

System.out.println("[*]等待消息。退出按CTRL + C");

Consumer consumer= newDefaultConsumer(channel){

@Overridepublic void handleDelivery (String consumerTag,Envelope envelope,AMQP.BasicProperties properties,byte[] body) throwsIOException {

String message= new String(body,"UTF-8");

System.out.println("[x] Received'" + message + "'");}

};

channel.basicConsume(queueName,true,consumer);

}

}

参考网址：

http://www.rabbitmq.com/tutorials/tutorial-one-java.html