最近好多项目都有需要是用MQ的场景，以下是在安装过程记录的一些知识点，安装MQ需要先安装依赖环境，erlang和socat。 安装RabbitMQ：

rpm -i --nodeps rabbitmq-server-3.6.10-1.el6.noarch.rpm

启动mq：

service rabbitmq-server start

创建用户：

rabbitmqctl add_user admin admin

设置为管理员：

rabbitmqctl set_user_tags admin administrator

启动web管理

rabbitmq-plugins enable rabbitmq_management

用刚才创建的用户登录web管理页面，端口默认为15672 我们需要为刚才的admin配置权限，见上图，点名字进去即可，conf/write/read 都配成缺省显示的那个.* 即可。 目前为缺省配置，更多配置见http://www.rabbitmq.com/configure.html#config-items

java项目中加入依赖

       <dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>3.0.4</version></dependency>

发送示例

package com.pactera.business.mq;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;public class Send {//队列名称  private final static String QUEUE_NAME = "queue";  public static void main(String[] argv) throws java.io.IOException  {  /** * 创建连接连接到MabbitMQ */  ConnectionFactory factory = new ConnectionFactory();  //设置MabbitMQ所在主机ip或者主机名   factory.setHost("192.168.0.3"); factory.setUsername("admin");factory.setPassword("admin123");factory.setVirtualHost("/");factory.setPort(5672);//创建一个连接  Connection connection = factory.newConnection();  //创建一个频道  Channel channel = connection.createChannel();  //指定一个队列  channel.queueDeclare(QUEUE_NAME, false, false, false, null);  //发送的消息  String message = "test quene";  //往队列中发出一条消息  channel.basicPublish("", QUEUE_NAME, null, message.getBytes());  System.out.println("Sent '" + message + "'");  //关闭频道和连接  channel.close();  connection.close();  }
}

接收示例

package com.pactera.business.mq;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.QueueingConsumer;public class Recv {//队列名称  private final static String QUEUE_NAME = "queue";  public static void main(String[] argv) throws java.io.IOException,java.lang.InterruptedException  {  //打开连接和创建频道，与发送端一样  ConnectionFactory factory = new ConnectionFactory();//设置RabbitMQ所在主机ip或者主机名  factory.setUsername("root");factory.setPassword("root");factory.setHost("192.168.0.3");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 = new QueueingConsumer(channel);  //指定消费队列  channel.basicConsume(QUEUE_NAME, true, consumer);  while (true)  {  //nextDelivery是一个阻塞方法（内部实现其实是阻塞队列的take方法）  QueueingConsumer.Delivery delivery = consumer.nextDelivery();  String message = new String(delivery.getBody());  System.out.println("Received '" + message + "'");}  }
}

接下来会整合到spring中。