springboot2.0集成rabbitmq的示例代码

$ wget https: //packages.erlang-solutions测试数据/erlang-solutions-1.0-1.noarch.rpm

$ sudo rpm -uvh erlang-solutions- 1.0 - 1 .noarch.rpm

$ sudo yum install erlang

wget http: //HdhCmsTestrabbitmq测试数据/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 ;