Rabbitmq调用FeignClient接口失败

news2024/11/19 3:27:15

文章目录

  • 一、框架及逻辑介绍
    • 1.背景服务介绍
    • 2.问题逻辑介绍
  • 二、代码
    • 1.A服务
    • 2.B服务
    • 3.C服务
  • 三、解决思路
    • 1.确认B调用C服务接口是否能正常调通
    • 2.确认B服务是否能正常调用A服务
    • 3.确认消息能否正常消费
    • 4.总结
  • 四、修改代码验证
    • 1.B服务异步调用C服务接口——失败
    • 2.将消费消息放到C服务中，消费时直接调用service——成功
  • 五、结论

走过路过大神帮忙给个正确解决方案~~~~~

一、框架及逻辑介绍

1.背景服务介绍

微服务结构，目前有A、B、C三个服务。

  • A服务：做一些工具类的功能
  • B服务：类似于门户，调用A、C服务来给到前端
  • C服务：基础模块，日志、权限、数据维护

2.问题逻辑介绍

  • A服务：实现blast功能，该功能是异步任务，需要几分钟的时间才能执行完成，所以采用了消息队列的方式通知功能完成，可查看数据。当代码执行完成之后通过rabbitmq发送消息到B服务
  • B服务：消费消息，调用C服务存储完成通知数据
  • C服务：提供FeignClient接口

二、代码

1.A服务

业务代码，详细的逻辑部分就不列出代码部分了， 测试确认无问题。

@Api(tags = "blast工具")
@RequiredArgsConstructor
@RequestMapping("blast")
@RestController
public class BlastController {

    private final BlastService blastService;

    @PostMapping("uniport")
    @ApiOperation("蛋白质序列对比")
    public ApiResponse<Boolean> check(@RequestBody BlastEntity blastEntity) {
        boolean flag = blastService.check(blastEntity);
        if(flag){
            return ApiResponse.success(flag);
        }else{
            return ApiResponse.failure("序列比对失败");
        }
    }

    @GetMapping("uniportDetail")
    @ApiOperation("蛋白质序列对比详情")
    public ApiResponse<BlastLogEntity> selectDetailById(@ApiParam("主键") @RequestParam("id") Integer id){
        return ApiResponse.success(blastService.selectDetailById(id));
    }
}

通过FeignClient提供功能接口给B服务（门户）

@FeignClient(name = "tool", url = "${customer.tool-url}")
public interface DataClient {

    @PostMapping("/blast/uniport")
    @ApiOperation("蛋白质序列对比")
    ApiResponse<Boolean> checkBlastUniprot(@RequestBody BlastEntity blastEntity);

    @GetMapping("/blast/uniportDetail")
    @ApiOperation("蛋白质序列对比详情")
    ApiResponse<BlastLogEntity> selectDetailById(@ApiParam("主键") @RequestParam("id") Integer id);
}

通过Rabbitmq发送消息

@Configuration
public class DirectRabbitMQConfig {

    //创建一个名为TestDirectExchange的Direct类型的交换机
    @Bean
    DirectExchange directExchange(){
        // durable:是否持久化,默认是false,持久化交换机。
        // autoDelete:是否自动删除，交换机先有队列或者其他交换机绑定的时候，然后当该交换机没有队列或其他交换机绑定的时候，会自动删除。
        // arguments：交换机设置的参数，比如设置交换机的备用交换机（Alternate Exchange），当消息不能被路由到该交换机绑定的队列上时，会自动路由到备用交换机
        return new DirectExchange(RabbitMqConstants.EXCHANGE_NAME,true,false);
    }
    //创建一个名为insertChassisDirectQueue的队列
    @Bean
    public Queue insertBlastDirectQueue(){
        // durable:是否持久化,默认是false,持久化队列：会被存储在磁盘上，当消息代理重启时仍然存在，暂存队列：当前连接有效
        // exclusive:默认也是false，只能被当前创建的连接使用，而且当连接关闭后队列即被删除。此参考优先级高于durable
        // autoDelete:是否自动删除，有消息者订阅本队列，然后所有消费者都解除订阅此队列，会自动删除。
        // arguments：队列携带的参数，比如设置队列的死信队列，消息的过期时间等等。
        return new Queue(RabbitMqConstants.INSERT_BLAST_NAME,true);
    }

    //绑定交换机和队列
    @Bean
    Binding insertBlastDirect(){
        return BindingBuilder.bind(insertBlastDirectQueue()).to(directExchange()).with(RabbitMqConstants.INSERT_BLAST_KEY);
    }
}

2.B服务

消费消息，根据输出日志，可以看到消费消息成功。
但是走到apiClient.addLogMessage(logMessageEntity);不报错，C服务无响应，断点查看apiClient是可以看到C服务的信息localhost:8080的。

	@RabbitHandler
    @RabbitListener(bindings = {@QueueBinding(
            value = @Queue(value = INSERT_BLAST_NAME, durable = "true"),
            exchange = @Exchange(value = RabbitMqConstants.EXCHANGE_NAME),
            key = INSERT_BLAST_KEY)})
    public void insertBlast(Map map, Channel channel, Message message) {
        try {
            LOGGER.info("【生成的消息-blast序列比对结果】:{}", map.toString());
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
            BlastLogEntity blastLogEntity = TypeSwitchUtil.toSnakeObject(JSON.toJSONString(map), BlastLogEntity.class);
            if (null == blastLogEntity || StringUtils.isEmpty(blastLogEntity.getContent())) {
                LOGGER.warn("【生成的消息-blast序列比对结果】:{}", map.toString());
            } else {
                LogMessageEntity logMessageEntity = new LogMessageEntity();
                logMessageEntity.setTargetId(blastLogEntity.getId());
                logMessageEntity.setUserId(String.valueOf(blastLogEntity.getUserId()));
                logMessageEntity.setMsgType(MsgStatusEnum.BLAST.getCode());
                logMessageEntity.setContent(MsgStatusEnum.BLAST.getMsg());
                apiClient.addLogMessage(logMessageEntity);
            }
        } catch (Exception e) {
            LOGGER.error(e.getMessage());
        }
    }

3.C服务

@FeignClient(name = "api", url = "${customer.url}", configuration = FeignConfig.class)
public interface ApiClient {
    
    @PostMapping("/cms/logMessage/add")
    @ApiOperation("新增系统通知发送记录")
    ApiResponse<Boolean> addLogMessage(@RequestBody LogMessageEntity logMessageEntity);
}

三、解决思路

1.确认B调用C服务接口是否能正常调通

在B服务中，通过Controller暴露接口，调用C服务FeignClient的@PostMapping("/cms/logMessage/add") 接口，通过swagger测试，数据成功存储到数据库中。

——接口没有问题，服务之间通信也没有问题

2.确认B服务是否能正常调用A服务

在B服务中，调用A服务接口，测试成功。

——服务之间通信没有问题

3.确认消息能否正常消费

在B服务中，调用A服务接口，A服务输出发送消息日志。B服务消费输出日志。

——消息无问题

4.总结

在这里插入图片描述

  • 服务之间通信没有问题
    在这里插入图片描述

  • 消息提供和消费没有问题

综合猜测可能是线程或事务问题。

四、修改代码验证

1.B服务异步调用C服务接口——失败

	@RabbitHandler
    @RabbitListener(bindings = {@QueueBinding(
            value = @Queue(value = INSERT_BLAST_NAME, durable = "true"),
            exchange = @Exchange(value = RabbitMqConstants.EXCHANGE_NAME),
            key = INSERT_BLAST_KEY)})
    public void insertBlast(Map map, Channel channel, Message message) {
        try {
            LOGGER.info("【生成的消息-blast序列比对结果】:{}", map.toString());
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
            BlastLogEntity blastLogEntity = TypeSwitchUtil.toSnakeObject(JSON.toJSONString(map), BlastLogEntity.class);
            if (null == blastLogEntity || StringUtils.isEmpty(blastLogEntity.getContent())) {
                LOGGER.warn("【生成的消息-blast序列比对结果】:{}", map.toString());
            } else {
                LogMessageEntity logMessageEntity = new LogMessageEntity();
                logMessageEntity.setTargetId(blastLogEntity.getId());
                logMessageEntity.setUserId(String.valueOf(blastLogEntity.getUserId()));
                logMessageEntity.setMsgType(MsgStatusEnum.BLAST.getCode());
                logMessageEntity.setContent(MsgStatusEnum.BLAST.getMsg());
                CompletableFuture.runAsync(() -> {
		            apiClient.addLogMessage(logMessageEntity);
		        });
            }
        } catch (Exception e) {
            LOGGER.error(e.getMessage());
        }
    }

经测试，未能解决问题。

2.将消费消息放到C服务中，消费时直接调用service——成功

	@RabbitHandler
    @RabbitListener(bindings = {@QueueBinding(
            value = @Queue(value = "blast.insert.queue", durable = "true"),
            exchange = @Exchange(value = "tool"),
            key = "blast.insert")})
    public void insertBlast(Map map, Channel channel, Message message) {
        try {
            LOGGER.info("【生成的消息-blast序列比对结果】:{}", map.toString());
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
            if (null == map || StringUtils.isEmpty(map.get("id").toString())) {
                LOGGER.warn("【生成的消息-blast序列比对结果】:{}", map.toString());
            } else {
                LogMessageEntity logMessageEntity = new LogMessageEntity();
                logMessageEntity.setTargetId(Integer.valueOf(map.get("id").toString()));
                logMessageEntity.setUserId(String.valueOf(map.get("user_id")));
                logMessageEntity.setMsgType(MsgStatusEnum.BLAST.getCode());
                logMessageEntity.setContent(MsgStatusEnum.BLAST.getMsg());
                logMessageService.save(logMessageEntity);
            }
        } catch (Exception e) {
            LOGGER.error(e.getMessage());
        }
    }

在这里插入图片描述

五、结论

在使用消息队列（MQ）调用FeignClient服务时，采取以下步骤：

  • 配置消息队列：首先，确保已正确配置和启动您所使用的消息队列，例如 RabbitMQ 或者 Kafka。

  • 创建消息生产者：创建一个消息生产者，用于将消息发送到消息队列。您可以使用消息队列的客户端库或框架来实现此功能。

  • 发送消息：在需要调用FeignClient服务的地方，将消息发送到消息队列。消息中包含请求的相关信息，例如服务名称、路径、参数等。

  • 创建消息消费者：创建一个消息消费者，用于从消息队列接收消息并处理。

  • 处理消息：在消息消费者中，处理接收到的消息。根据消息中的请求信息，使用FeignClient来调用相应的服务。

虽然通过直接调用service的方式成功进行数据存储了，这样做也没有违背原有的逻辑。
但是问题仍然没有一个正确的解决方式，希望走过路过的大神能指点一二，在线求助。

走过路过大神帮忙给个正确解决方案~~~~~

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1413341.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

【Web】CTFSHOW SQL注入刷题记录(上)

【Web】CTFSHOW SQL注入刷题记录(上)

目录 无过滤注入 web171 web172 web173 web174 web175 时间盲注 写马 过滤注入 web176 web177 web178 web179 web180 web181-182 web183 web184 web185-186 web187 web188 web189 web190 布尔盲注 web191 web192 web193 web194 堆叠注入 web195 …
阅读更多...
对于gzip的了解

对于gzip的了解

gzip基本操作原理&#xff1a;通过消除文件中的冗余信息&#xff0c;使用哈夫曼编码等算法&#xff0c;将文件体积压缩到最小。这种数据压缩方式在网络传输中发挥了巨大作用&#xff0c;减小了传输数据的大小&#xff0c;从而提高了网页加载速度。 静态资源 Vue Vue CLl修改v…
阅读更多...
Task04：DDPG、TD3算法

Task04：DDPG、TD3算法

本篇博客是本人参加Datawhale组队学习第四次任务的笔记 【教程地址】https://github.com/datawhalechina/joyrl-book 【强化学习库JoyRL】https://github.com/datawhalechina/joyrl/tree/main 【JoyRL开发周报】 https://datawhale.feishu.cn/docx/OM8fdsNl0o5omoxB5nXcyzsInGe…
阅读更多...
【原神游戏开发日志3】登录和注册有何区别？

【原神游戏开发日志3】登录和注册有何区别？

版权声明&#xff1a; ● 本文为“优梦创客”原创文章&#xff0c;您可以自由转载&#xff0c;但必须加入完整的版权声明 ● 文章内容不得删减、修改、演绎 ● 本文视频版本&#xff1a;见文末 ● 相关学习资源&#xff1a;见文末 前言 ● 这是我们原神游戏开发日记的第三期 ●…
阅读更多...
web服务和前端交互相关的上中游业务技术知识点梳理

web服务和前端交互相关的上中游业务技术知识点梳理

文章目录 前言一、业务API网关鉴权Cookie Session 实现 API 鉴权API Key API Secrettoken 机制实现 API 鉴权 二、Tomcat、Servlet、SpringMVC总结 前言 可能之前在学校里面做的很多东西是纯后端的&#xff0c;不会涉及到太多和前端交互的细节&#xff0c;很多新手对前后端交…
阅读更多...
深入浅出 diffusion(3)：pytorch 实现 diffusion 中的 U-Net

深入浅出 diffusion(3)：pytorch 实现 diffusion 中的 U-Net

导入python包 import mathimport torch import torch.nn as nn import torch.nn.functional as F silu激活函数 class SiLU(nn.Module): # SiLU激活函数staticmethoddef forward(x):return x * torch.sigmoid(x) 归一化设置 def get_norm(norm, num_channels, num_groups)…
阅读更多...
php项目下微信小程序对接实战问题与解决方案

php项目下微信小程序对接实战问题与解决方案

一.实战问题与方案总结 1.SQL查询条件是一组数&#xff0c;传参却是一个字符串导致报错&#xff0c;如下 SQLSTATE[HY093]: Invalid parameter number (SQL: select count(*) as aggregate from car_video where province_id in (1492) and city_id in (1493) and county_id …
阅读更多...
Nginx编译安装以及负载均衡配置（Ubuntu 22.04）

Nginx编译安装以及负载均衡配置（Ubuntu 22.04）

目录 Nginx编译安装以及负载均衡配置 Ubuntu 22.04.1 LTS 编译安装 nginx-1.22.1 1.安装依赖包 2. 下载nginx 3. 编译安装 报错解决 解决问题2 4.安装 5启动Nginx&#xff1a; 负载均衡 负载均衡算法 轮询 加权负载均衡 ip_hash算法 算法进行配置演示 加权负载均衡 轮询 IP 哈希…
阅读更多...
ES文档索引、查询、分片、文档评分和分析器技术原理

ES文档索引、查询、分片、文档评分和分析器技术原理

技术原理 索引文档 索引文档分为单个文档和多个文档。 单个文档 新建单个文档所需要的步骤顺序&#xff1a; 客户端向 Node 1 发送新建、索引或者删除请求。节点使用文档的 _id 确定文档属于分片 0 。请求会被转发到 Node 3&#xff0c;因为分片 0 的主分片目前被分配在 …
阅读更多...
[MQ]常用的mq产品图形管理web界面或客户端

[MQ]常用的mq产品图形管理web界面或客户端

一、MQ介绍 1.1 定义 MQ全称为Message Queue&#xff0c;消息队列是应用程序和应用程序之间的通信方法。 如果非要用一个定义来概括只能是抽象出来一些概念&#xff0c;概括为跨服务之间传递信息的软件。 1.2 MQ产品 较为成熟的MQ产品&#xff1a;IBMMQ&#xff08;IBM We…
阅读更多...
《动手学深度学习(PyTorch版)》笔记4.1

《动手学深度学习(PyTorch版)》笔记4.1

注&#xff1a;书中对代码的讲解并不详细&#xff0c;本文对很多细节做了详细注释。另外&#xff0c;书上的源代码是在Jupyter Notebook上运行的&#xff0c;较为分散&#xff0c;本文将代码集中起来&#xff0c;并加以完善&#xff0c;全部用vscode在python 3.9.18下测试通过。…
阅读更多...
万界星空科技可视化数据大屏的作用

万界星空科技可视化数据大屏的作用

随着科技的不断发展和进步&#xff0c;当前各种数据化的设备也是如同雨后春笋般冒了出来&#xff0c;并且其可以说是给我们带来了极大的便利的。在这其中&#xff0c;数据大屏就是非常具有代表性的一个例子。 数据大屏的主要作用包括&#xff1a; 数据分析&#xff1a;数据大屏…
阅读更多...
k8s 进阶实战笔记 | Pod 创建过程详解

k8s 进阶实战笔记 | Pod 创建过程详解

Pod 创建过程详解 ​ 初始状态0 controller-manager、scheduler、kubelet组件通过 list-watch 机制与 api-server 通信并检查资源变化 第一步 用户通过 CLI 或者 WEB 端等方式向 api-server 发送创建资源的请求&#xff08;比如&#xff1a;我要创建一个replicaset资源&…
阅读更多...
【七、centos要停止维护了，我选择Almalinux】

【七、centos要停止维护了，我选择Almalinux】

搜索镜像 https://developer.aliyun.com/mirror/?serviceTypemirror&tag%E7%B3%BB%E7%BB%9F&keywordalmalinux dvd是有界面操作的&#xff0c;minimal是最小化只有命里行 镜像下载地址 安装和centos基本一样的&#xff0c;操作命令也是一样的&#xff0c;有需要我…
阅读更多...
Redis创建集群

Redis创建集群

主要内容 搭建redis集群 能力目标 搭建redis集群 一 应用场景 为什么需要redis集群&#xff1f; 当主备复制场景&#xff0c;无法满足主机的单点故障时&#xff0c;需要引入集群配置。 一般数据库要处理的读请求远大于写请求 &#xff0c;针对这种情况&#xff0c;我们优…
阅读更多...
【C/C++】C/C++编程——C++ 关键字和数据类型简介

【C/C++】C/C++编程——C++ 关键字和数据类型简介

C 关键字和数据类型简介 大家好&#xff0c;我是 shopeeai&#xff0c;也可以叫我虾皮&#xff0c;中科大菜鸟研究生。昨天已经成功运行了第一个C程序&#xff0c;今天来学习一下C 关键字和数据类型。C 中的关键字是由 C 标准预先定义的。它们被保留作为语言的一部分&#xff…
阅读更多...
python222网站实战(SpringBoot+SpringSecurity+MybatisPlus+thymeleaf+layui)-帖子管理实现

python222网站实战(SpringBoot+SpringSecurity+MybatisPlus+thymeleaf+layui)-帖子管理实现

锋哥原创的SpringbootLayui python222网站实战&#xff1a; python222网站实战课程视频教程&#xff08;SpringBootPython爬虫实战&#xff09; ( 火爆连载更新中... )_哔哩哔哩_bilibilipython222网站实战课程视频教程&#xff08;SpringBootPython爬虫实战&#xff09; ( 火…
阅读更多...
Golang中make与new有何区别

Golang中make与new有何区别

&#x1f4d5;作者简介&#xff1a; 过去日记&#xff0c;致力于Java、GoLang,Rust等多种编程语言&#xff0c;热爱技术&#xff0c;喜欢游戏的博主。 &#x1f4d7;本文收录于go进阶系列&#xff0c;大家有兴趣的可以看一看 &#x1f4d8;相关专栏Rust初阶教程、go语言基础系…
阅读更多...
【新课上架】安装部署系列Ⅲ—Oracle 19c Data Guard部署之两节点RAC部署实战

【新课上架】安装部署系列Ⅲ—Oracle 19c Data Guard部署之两节点RAC部署实战

01 课程介绍 Oracle Real Application Clusters (RAC) 是一种跨多个节点分布数据库的企业级解决方案。它使组织能够通过实现容错和负载平衡来提高可用性和可扩展性&#xff0c;同时提高性能。本课程基于当前主流版本Oracle 19cOEL7.9解析如何搭建2节点RAC对1节点单机的DATA GU…
阅读更多...
滴滴基于 Ray 的 XGBoost 大规模分布式训练实践

滴滴基于 Ray 的 XGBoost 大规模分布式训练实践

背景介绍 作为机器学习模型的核心代表&#xff0c;XGBoost 在滴滴众多策略算法业务场景中发挥着至关重要的作用。因此&#xff0c;保障并持续提升 XGBoost 模型的离线训练及在线推理稳定性一直是机器学习平台的重点工作。同时&#xff0c;面对多样化的业务场景定制需求和数据规…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023