简易兔兔MQ实战教程演示

​​​​​本文已参与「新人创作礼」活动，一起开启掘金创作之路。​

上一篇Windows下RabbitMQ的安装，如有不知道怎么安装的朋友可以查看上一章讲解。

今天讲解一下咱们RabbitMQ怎么的简单使用。

英文api地址：http://localhost:15672/api/index.html

用命令查询一下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 );
    }
}

这里只是简单的写一下发送者和接收者代码。

更多编程内容，请扫码关注《coder练习生》，如果觉得有用，也可赠送作者一杯咖啡

​

​