RabbitMQ使用

rabbitmq的优点

可以异步执行，等等，优点很多这里不过多废话，请直接进入实际开发流程

使用docker命令安装

docker run -d --hostname my-rabbit -v /mq/plugins:/plugins --name rabbit -p 15672:15672 -p 5672:5672 rabbitmq

-d 后台运行容器；
--name 指定容器名；
-p 指定服务运行的端口（5672：应用访问端口；15672：控制台Web端口号）；
-v 映射目录或文件；
--hostname  主机名（RabbitMQ的一个重要注意事项是它根据所谓的 “节点名称” 存储数据，默认为主机名）；
-e 指定环境变量；（RABBITMQ_DEFAULT_VHOST：默认虚拟机名；RABBITMQ_DEFAULT_USER：默认的用户名；
RABBITMQ_DEFAULT_PASS：默认用户名的密码）

启动rabbit管理页面，不然无法进入管理页面

docker exec -it rabbitmq rabbitmq-plugins enable rabbitmq_management

错误提示信息

Management API returned status code 500

修改方法为：

1、进入docker

2、执行如下命令

cd /etc/rabbitmq/conf.d/
echo management_agent.disable_metrics_collector = false > management_agent.disable_metrics_collector.conf

3、重启RabbitMQ

网页端登陆地址 ip:15672

登陆默认账号/密码 guest

注意：默认的用户使用java连接的时候连接地址只能填写localhost，可以在额外创建一个账户，并设置admin权限

使用springboot进行实战演示

先引入必备包

<!--进入测试包-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-logging</artifactId>
        </dependency>
        <!--AMQP依赖，包含RabbitMQ-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
        <!--引入消息转换器-->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </dependency>

知识点

//    测试交换机的收发 - 所有的交换机都需要输入key，但是fanout可以输入null的key也就是所有绑定的都可以收到消息
    @Test
    void testSend() throws InterruptedException {
        String bluemsg = "blue msg";
        CorrelationData cd = new CorrelationData(UUID.randomUUID().toString());
        cd.getFuture().addCallback(new ListenableFutureCallback<CorrelationData.Confirm>() {
            @Override
            public void onFailure(Throwable ex) {
                log.error("消息回调失败",ex); //基本上不会发生
            }
            @Override
            public void onSuccess(CorrelationData.Confirm confirm) {
                log.debug("收到confirm callback包回执");
                System.out.println(confirm.isAck());
                if (confirm.isAck()) {
//                    消息发送成功
                    log.info("消息发送成功，收到ack");

                } else {
//                    这里应该重发消息,
                    log.error("消息发送失败，收到nack");
                }
            }
        });
        //消息到达了交换机,但是发送到队列的时候出错了(如果key不存在),返回ack但是有return返回值
        //消息没有到达mq交换机会返回nack ,没有return返回值(代码问题，如路由不存在)
        //只要到达mq交换机都是ack，列队没收到返回返回ack+路由错误
        rabbitTemplate.convertAndSend("nbsb.direct5  ", "blue", bluemsg, cd);
        Thread.sleep(2000);
    }

设计思路（仅作为参考）

这个回调和发消息都在一个方法里定义的, 失败了调用convert重发或是写数据库交给定时任务重发都可以

问题

问题1：springboot项目使用spring-boot-starter-amqp连接rabbitmq时出现报错：

Failed to check/redeclare auto-delete queue(s).
思路
这类问题是因为没有连接上rabbitmq导致的，一般可以的原因有如下几种：

1、springboot中的配置文件配置的不对，这其中又分为：
（1）配置项格式出错，比如yml格式常见的配置项错位
（2）rabbitmq地址错误
（3）端口错误
这里给出一个最基本的配置项作为参考

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
    virtual-host: /

2、rabbitmq所在服务器或虚拟机中的对应端口没有打开，比如默认的5672端口没有开放，如果是外网地址的，还要打开内外网端口映射。这一点可以通过telnet指令检查

telnet 192.168.1.1 5672

3、rabbitmq地址有误，或者rabbitmq所在服务器的网络存在问题，无法连接，这点可以通过ping来测试

ping 192.168.1.1

4、配置的账号没有开通对应权限
进入rabbitmq管理页面的用户页面后可以看到对应的账户是否有开通权限，如图所示即没有开通权限

点击对应的用户名，进入权限设置页面
如图所示，我们给予其配置、读、写的权限，并将其赋予管理员角色

配置之后再看用户权限就发生了变化了

5、virtual-host配置的有误，springboot中配置的virtual-host与rabbitmq中的virtual-host没有对应上，需要注意的是如果在rabbitmq中配置的virtual-host叫xxx的话，那么springboot中的也一定是xxx,而不需要再之前加上/

版权属于：戏人看戏博客网

本文链接：https://day.nb.sb/archives/1396.html

若无注明均为戏人看戏原创，转载请注明出处，感谢您的支持!