RabbitMQ的简单使用Demo

今天讲解一下咱们RabbitMQ怎么的简单使用。
用命令查询一下RabbitMQ的注册用户：rabbitmqctl list_users 如下图：

那么在命令行下创建一个用户，创建用户的命令是：rabbitmqctl add_user [username] [password]

创建用户，并查看用户列表，发现用户列表里多了一个用户 rabbit1,但是tag是空的。使用命令给rabbit设置tag，设置tag的命令格式：rabbitmqctl set_user_tags 用户名 [tag1] [tag2] ...

有5个tag可供选择，分别是：administrator ，monitoring，policymaker，management和none ，其实这里的tag代表的是权限，administrator是最高权限，none表示不能访问
其实有了rabbitmq_management这个可视化插件，很多事情都可以在这个插件里干，包括创建用户，创建交换机（Exchange)和创建队列（Queque）。
关于Rabbit的在windows下的基本配置就告一段落，关于更多的更高级的配置，可以参考官网，有了rabbitmq_management 插插件还是很方便我们可视化操作的。下面就开始创建客户端进行测试了。

配置类：

/**
 * MQ的配置类，定义出队列信息
 */
@Configuration
public class RabbitMQConfig {
   
   
    @Bean
    public Queue Queue(){
   
   
        return new Queue("rabbittest");
    }
}

发送者

@Component
public class Sender {
   
   

    @Autowired
    private AmqpTemplate rabbitTemplate;

    private static SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    public void send(){
   
   
        String context = "hello " + format.format(new Date());
        System.out.println("Sender : " + context);
        this.rabbitTemplate.convertAndSend("rabbittest", context);
    }

}

接受者：

@Component
@RabbitListener(queues = "rabbittest")
public class Receiver {
   
   

    @RabbitHandler
    public void process(String msg) {
   
   
        System.out.println("Receiver接收到了："+msg );
    }
}