springboot2.0集成rabbitmq的示例代码

$ 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 # 添加开机启动RabbitMQ服务
 
$ sudo /sbin/service rabbitmq-server start # 启动服务
 
$ sudo /sbin/service rabbitmq-server status # 查看服务状态
 
$ sudo /sbin/service rabbitmq-server stop # 停止服务
 
#查看当前所有用户
 
$ sudo rabbitmqctl list_users
 
#查看默认guest用户的权限
 
$ sudo rabbitmqctl list_user_permissions guest
 

#由于RabbitMQ默认的账号用户名和密码都是guest。为了安全起见, 先删掉默认用户
 
$ sudo rabbitmqctl delete_user guest
 
 
 
#添加新用户
 
$ sudo rabbitmqctl add_user username password
 
#设置用户tag
 
$ sudo rabbitmqctl set_user_tags username administrator
 
#赋予用户默认vhost的全部操作权限
 
$ sudo rabbitmqctl set_permissions -p / username ".*" ".*" ".*"

#查看用户的权限
 
$ 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服务器地址 （默认为127.0.0.1）
spring.rabbitmq.host=127.0.0.1
# rabbitmq服务器连接端口 （默认为5672）
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.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
 */
@Configuration
public class RabbitConfig {
 
  /**
   * 消费者数量，默认10
   */
  public static final int DEFAULT_CONCURRENT = 10;
 
  /**
   * 每个消费者获取最大投递数量 默认50
   */
  public static final int DEFAULT_PREFETCH_COUNT = 50;
 
 
  /**
   * 注入 Queue
   * @return
   */
  @Bean
  public Queue Queue() {
    return new Queue("hello");
  }
 
 
  /**
   * 并发消费配置
   * @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
 */
@Autowired
private AmqpTemplate rabbitTemplate;

 

public void sendMessage(){
  //发送消息
  this.rabbitTemplate.convertAndSend("hello","你好,rabbitmq");
}

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

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

/**
   * 消费者数量，默认10
   */
  public static final int DEFAULT_CONCURRENT = 10;
 
  /**
   * 每个消费者获取最大投递数量 默认50
   */
  public static final int DEFAULT_PREFETCH_COUNT = 50;