$ wget https://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm$ sudo rpm -Uvh erlang-solutions-1.0-1.noarch.rpm$ sudo yum install erlang

wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.6/rabbitmq-server-3.6.6-1.el7.noarch.rpm

yum install rabbitmq-server-3.6.6-1.el7.noarch.rpm

$ sudo yum install socat

$ sudo chkconfig rabbitmq-server on # 添加開機(jī)啟動(dòng)RabbitMQ服務(wù) $ sudo /sbin/service rabbitmq-server start # 啟動(dòng)服務(wù) $ sudo /sbin/service rabbitmq-server status # 查看服務(wù)狀態(tài) $ sudo /sbin/service rabbitmq-server stop # 停止服務(wù) #查看當(dāng)前所有用戶 $ sudo rabbitmqctl list_users #查看默認(rèn)guest用戶的權(quán)限 $ sudo rabbitmqctl list_user_permissions guest #由于RabbitMQ默認(rèn)的賬號(hào)用戶名和密碼都是guest。為了安全起見, 先刪掉默認(rèn)用戶 $ sudo rabbitmqctl delete_user guest   #添加新用戶 $ sudo rabbitmqctl add_user username password #設(shè)置用戶tag $ sudo rabbitmqctl set_user_tags username administrator #賦予用戶默認(rèn)vhost的全部操作權(quán)限 $ sudo rabbitmqctl set_permissions -p / username ".*" ".*" ".*"#查看用戶的權(quán)限 $ sudo rabbitmqctl list_user_permissions username

{loopback_users, []}

{loopback_users, ["admin"]}

<dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-amqp</artifactId></dependency>

#rabbitmq config begin# rabbitmq服務(wù)器地址 （默認(rèn)為127.0.0.1）spring.rabbitmq.host=127.0.0.1# rabbitmq服務(wù)器連接端口 （默認(rèn)為5672）spring.rabbitmq.port=5672spring.rabbitmq.username=adminspring.rabbitmq.password=123456#rabbitmq config end

package com.snow.config;import org.springframework.amqp.core.Queue;import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;import org.springframework.amqp.rabbit.connection.ConnectionFactory;import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration; /** * @Description: RabbitConfig * @Author: 愛飄de小子 * @CreateDate: 2018/8/15 19:59 * @Version: 1.0 */@Configurationpublic class RabbitConfig {   /**   * 消費(fèi)者數(shù)量，默認(rèn)10   */  public static final int DEFAULT_CONCURRENT = 10;   /**   * 每個(gè)消費(fèi)者獲取最大投遞數(shù)量 默認(rèn)50   */  public static final int DEFAULT_PREFETCH_COUNT = 50;    /**   * 注入 Queue   * @return   */  @Bean  public Queue Queue() {    return new Queue("hello");  }    /**   * 并發(fā)消費(fèi)配置   * @param configurer   * @param connectionFactory   * @return   */  @Bean("pointTaskContainerFactory")  public SimpleRabbitListenerContainerFactory pointTaskContainerFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer, ConnectionFactory connectionFactory) {    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();    factory.setPrefetchCount(DEFAULT_PREFETCH_COUNT);    factory.setConcurrentConsumers(DEFAULT_CONCURRENT);    configurer.configure(factory, connectionFactory);    return factory;  } }

/** * 注入AmqpTemplate */@Autowiredprivate AmqpTemplate rabbitTemplate; public void sendMessage(){  //發(fā)送消息  this.rabbitTemplate.convertAndSend("hello","你好,rabbitmq");}

/**   * 消息接受   * @param message   */  @RabbitListener(queues = "hello") //監(jiān)聽器監(jiān)聽指定的QueueName  public void receive(String message) {    System.out.println("接收消息:" + message);  }

/**   * 消息接受 并發(fā)消費(fèi)   * @param message   */  @RabbitListener(queues = "hello",containerFactory = "pointTaskContainerFactory")  public void receive(String message) {    System.out.println("接收消息:" + message);  }

/**   * 消費(fèi)者數(shù)量，默認(rèn)10   */  public static final int DEFAULT_CONCURRENT = 10;   /**   * 每個(gè)消費(fèi)者獲取最大投遞數(shù)量 默認(rèn)50   */  public static final int DEFAULT_PREFETCH_COUNT = 50;