openfeign与dubbo调用下载excel实践

一、前言

openfeign和dubbo均是rpc框架

RPC(Remote Procedure Call,远程过程调用)框架 是一种允许程序像调用本地方法一样调用远程服务器上函数的技术。它隐藏了底层网络通信的复杂性,让开发者可以专注于业务逻辑,实现分布式系统中不同服务之间的高效协作

文本计划在一个应用中同时使用openfeigndubbo来进行远程调用,前端提供el-switch组件来进行切换

showCase

分别使用dubbo和feign进行了1万笔数据的导出测试

请添加图片描述

二、实践

2-1、模块拆分

先前只有一个security-demo服务,如今拆分成security-demobase-service两个服务,其中model-manage模块用来管理微服务中通用的实体类,remote-client用来管理远程调用:
在这里插入图片描述
其中和excel导出相关的具体实现被移动到了base-service服务中,计划在security-demo通过openfeign和dubbo等方式来调用导出接口。

2-2、依赖引入

在远程调用管理中引入dubbo、openfeign、nacos、通用实体相关依赖,其中${dubbo.version}取父pom的<dubbo.version>2.7.15</dubbo.version>

		<dependencies><!-- Dubbo Spring Boot Starter --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>${dubbo.version}</version></dependency><!-- Dubbo Registry Nacos --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-registry-nacos</artifactId><version>${dubbo.version}</version></dependency><!-- Spring Cloud Alibaba Nacos Discovery --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><!-- Spring Boot Actuator --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><!-- OpenFeign --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><dependency><groupId>com.tgh</groupId><artifactId>model-manage</artifactId><version>0.0.1-SNAPSHOT</version><scope>compile</scope></dependency></dependencies>

在服务调用方security-demo和服务提供方base-service引入model-manageremote-client

        <dependency><groupId>com.tgh</groupId><artifactId>remote-client</artifactId><version>0.0.1-SNAPSHOT</version><scope>compile</scope></dependency>

2-3、后端环境&配置变更

由于涉及到微服务之间的通信,涉及到服务的注册和发现,本文以nacos作为注册中心,于是需要安装并运行nacos,安装细节不赘述,博主将nacos安装在ubuntu机器中

base-service yml配置

spring:profiles:active: devapplication:name: base-servicedatasource:url: jdbc:postgresql://192.168.125.102:5432/dbname?user=postgres&password=postgresdriver-class-name: org.postgresql.Drivercloud:nacos:discovery:server-addr: 192.168.125.102:8848redis:host: 192.168.125.102port: 6379password: redisdatabase: 0
server:port: 8081
management:endpoints:web:exposure:include: '*'
# Dubbo配置
dubbo:application:name: ${spring.application.name}qos-enable: falseprotocol:name: dubboport: 20881payload: 20971520provider:payload: 20971520timeout: 600000threads: 200       # 增大服务端线程池registry:address: nacos://${spring.cloud.nacos.discovery.server-addr}namespace: ${spring.cloud.nacos.discovery.namespace}scan:base-packages: com.tghconsumer:check: false
logging:level:org.springframework.boot.web.servlet.context: DEBUGorg.apache.tomcat: DEBUGorg.apache.dubbo: DEBUGorg.alibaba.dubbo: DEBUG
#sql日志
mybatis-plus:configuration:log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

security-demo yml配置

#---------------dev环境配置---------------
#pg数据源
spring:datasource:url: jdbc:postgresql://192.168.125.102:5432/dbname?user=postgres&password=postgresdriver-class-name: org.postgresql.Driverapplication:name: security-democloud:nacos:discovery:server-addr: 192.168.125.102:8848redis:host: 192.168.125.102port: 6379password: redis # 如果有密码database: 0rabbitmq:host: 192.168.125.102port: 5672username: adminpassword: adminvirtual-host: /
logging:level:org.springframework.transaction: DEBUGorg.springframework.jdbc: DEBUGorg.apache.dubbo: DEBUGorg.alibaba.dubbo: DEBUG
#rabbit-mq
mybatis-plus:configuration:log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
server:port: 8888
feign:client:config:default:  # 对所有Feign客户端生效connectTimeout: 5000  # 连接超时时间(毫秒)readTimeout: 100000     # 读取超时时间(毫秒)
# Dubbo配置
dubbo:application:name: ${spring.application.name}qos-enable: falseregistry:address: nacos://${spring.cloud.nacos.discovery.server-addr}namespace: ${spring.cloud.nacos.discovery.namespace}scan:base-packages: com.tghconsumer:payload: 20971520timeout: 600000check: false       # 启动时不强制检查服务可用性

ubuntu开放8848、9848、9849端口

sudo ufw allow 8848/tcp
sudo ufw allow 9848/tcp
sudo ufw allow 9849/tcp
sudo ufw enable

2-4、前端调整

工单列表查询从调用 security-demo服务调整为base-service服务

在这里插入图片描述
在前缀调整后,需在vite.config.ts的server.proxy中加入

      '/base': { // 以 '/asset' 开头的请求会被代理target: 'http://localhost:8081', // 后端服务器地址changeOrigin: true, // 允许跨域rewrite: (path) => path.replace(/^\/base/, '') // 重写路径,去掉 '/asset'}

工单列表查询页面,增加el-switch组件来进行切换dubbo和feign

在这里插入图片描述

三、补充说明

3-1、使用dubbo可能遇到的问题

3-1-1、com.alibaba.nacos.api.exception.NacosException: Client not connected, current status:STARTING

nacos新增的gRPC通信方式,需要多开两个端口9848、9849,博主的nacos安装在ubuntu机器上,可执行如下指令:

sudo ufw allow 9848/tcp
sudo ufw allow 9849/tcp
sudo ufw enable

3-1-2、Caused by: java.lang.IllegalStateException: Serialized class com.tgh.entity.excel.WorkOrderLogSearchVO must implement java.io.Serializable

Dubbo方法的入参和入参都需要实现Serializable,为什么?

(1) 二进制协议需要严格序列化

Dubbo 默认使用 Hessian2 或 Kryo 等二进制序列化协议,要求所有跨网络传输的对象必须实现 Serializable 接口,因为:

二进制切割:需要精确计算对象字节大小和字段偏移量。类型安全:反序列化时必须还原原始类结构,避免数据丢失。

(2) 性能优化考虑

二进制序列化比JSON更高效,但需要预先定义类型结构。非 Serializable 对象无法保证序列化/反序列化的确定性。

3-1-3、org.apache.dubbo.remoting.RemotingException: Data length too large: 15871746, max payload: 8388608

Dubbo默认只能传输小于8M的内容,需要手动修改Dubbo的配置
服务提供方

  protocol:name: dubbopayload: 20971520  # 20MBprovider:payload: 20971520timeout: 600000threads: 200       # 增大服务端线程池

服务调用方

  consumer:payload: 20971520timeout: 600000check: false       # 启动时不强制检查服务可用性

3-1、测试数据初始化

本文采用pg数据库,工单初始化脚本可以参考PostgreSQL 分区表——范围分区SQL实践的执行脚本新增2400w行。
也可从后端代码script/sql/init.sql中获取

3-2、代码仓

后端:https://gitee.com/pinetree-cpu/parent-demon
前端:https://gitee.com/pinetree-cpu/hello_vue3

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

解密企业级大模型智能体Agentic AI 关键技术:MCP、A2A、Reasoning LLMs-强化学习算法

解密企业级大模型智能体Agentic AI 关键技术&#xff1a;MCP、A2A、Reasoning LLMs-强化学习算法 现在我们的核心问题是有一些同学会知道要才能强化学习。为什么才能强化学习&#xff1f;是实现AGI。例如从这个其实你从第一阶段开始以后&#xff0c;就是chatbot&#xff0c;这…

音频分类的学习

1.深度学习PyTorch入门-语音分类 https://blog.csdn.net/sinat_41787040/article/details/129795496 https://github.com/musikalkemist/pytorchforaudio https://github1s.com/musikalkemist/pytorchforaudio/blob/main/04%20Creating%20a%20custom%20dataset/urbansoundda…

美SEC主席:探索比特币上市证券交易所

作者/演讲者&#xff1a;美SEC主席Paul S. Atkins 编译&#xff1a;Liam 5月12日&#xff0c;由美国SEC加密货币特别工作组发起的主题为《资产上链&#xff1a;TradFi与DeFi的交汇点》系列圆桌会议如期举行。 会议期间&#xff0c;现任美SEC主席Paul S. Atkins发表了主旨演讲。…

Qt file文件操作详解

1.引言 很多应用程序都具备操作文件的能力&#xff0c;包括对文件进行写入和读取&#xff0c;创建和删除文件等等&#xff0c;甚至某些应用程序的就是为了操作文件&#xff0c;像WPS Office。基于此Qt框架中专门提供了对文件操作的类&#xff1a;QFile。 2.QFile文件操作 QF…

【测试开发知识储备】之Jacoco(Java Code Coverage)

文章目录 Jacoco是什么Jacoco的主要功能&#xff08;一&#xff09;多样化覆盖率指标分析&#xff08;二&#xff09; 丰富的报告生成&#xff08;三&#xff09;实时数据收集 Jacoco的工作原理&#xff08;一&#xff09;字节码增强&#xff08;二&#xff09;测试执行与数据收…

Docker 介绍与使用

Docker 文章目录 Docker介绍与虚拟机的比较启动速度占用资源 优势更容易迁移更容易维护更容易扩展 使用场景持续集成提供可伸缩的云服务搭建微服务架构 镜像与容器镜像构成&#xff08;分层结构&#xff09;镜像与容器的区别 安装 Docker常用命令介绍镜像相关容器相关 实战&…

《AI大模型应知应会100篇》第62篇:TypeChat——类型安全的大模型编程框架

第62篇&#xff1a;TypeChat——类型安全的大模型编程框架 摘要 在构建 AI 应用时&#xff0c;一个常见的痛点是大语言模型&#xff08;LLM&#xff09;输出的不确定性与格式不一致问题。开发者往往需要手动解析、校验和处理模型返回的内容&#xff0c;这不仅增加了开发成本&a…

upload-labs通关笔记-第5关 文件上传之.ini绕过

目录 一、ini文件绕过原理 二、源码审计 三、渗透实战 1、查看提示 2、制作.user.ini文件 &#xff08;1&#xff09;首先创建一个文本文件 &#xff08;2&#xff09;保存文件名为.user.ini 2、制作jpg后缀脚本 &#xff08;1&#xff09;创建一个文本文件 &#xf…

为什么 Linux 上默认没有 host.docker.internal

在 Linux 环境中&#xff0c;host.docker.internal 是 Docker 为容器提供的一个特殊 DNS 名称&#xff0c;用于指向宿主机的 IP 地址&#xff08;类似 macOS/Windows 中的行为&#xff09;。但这个功能在 Linux 上默认不启用&#xff0c;需要手动配置才能使用。以下是详细解释和…

C++GO语言微服务和服务发现②

01 创建go-micro项目-查看生成的 proto文件 02 创建go-micro项目-查看生成的main文件和handler ## 创建 micro 服务 命令&#xff1a;micro new --type srv test66 框架默认自带服务发现&#xff1a;mdns。 使用consul服务发现&#xff1a; 1. 初始consul服务发现&…

Redis--常见数据类型List列表

目录 一、概念 二、命令 2.1 LPUSH 2.2 LPUSHX 2.3 RPUSH 2.4 RPUSHX 2.5 LRANGE 2.6 LPOP 2.7 RPOP 2.8 LINDEX 2.9 LINSERT 2.10 LLEN 2.11 阻塞版本命令 三、内部编码 一、概念 列表类型是用来存储多个有序的字符串&#xff0c;列表中的每个字符串称为元素&…

QListWedget控件使用指南

QListWedget公共函数 函数签名功能描述QListWidget(QWidget *parent nullptr)构造函数&#xff0c;创建一个QListWidget对象&#xff0c;可指定父部件&#xff08;默认为nullptr&#xff09;。virtual ~QListWidget()虚析构函数&#xff0c;释放QListWidget对象及其资源。voi…

Seata源码—1.Seata分布式事务的模式简介

大纲 1.Seata分布式事务框架简介 2.Seata AT模式实现分布式事务的机制 3.Seata AT模式下的写隔离机制 4.Seata AT模式下的读隔离机制 5.官网示例说明Seata AT模式的工作机制 6.Seata TCC模式的介绍以及与AT模式区别 7.Seata Saga模式的介绍 8.单服务多个库的分布式事务…

【Qt】之音视频编程2:QtAV的使用篇

QtAV 基本播放控制功能实现&#xff08;C & QML&#xff09; QtAV 提供了完整的播放控制 API&#xff0c;支持 播放、暂停、停止、快进快退、截屏 等功能。以下是具体实现方法&#xff1a; 1. C 控制方式 基本播放控制 #include <QtAV> #include <QtAV/AVPlaye…

歌词滚动效果

<!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><!-- 设置标签页图标 --><link rel"shortcut icon&…

基于大模型的TIA诊疗全流程智能决策系统技术方案

目录 一、多模态数据融合与预处理系统1.1 数据接入模块1.2 数据预处理伪代码二、TIA智能预测模型系统2.1 模型训练流程2.2 混合模型架构伪代码三、术中智能监测系统3.1 实时监测流程3.2 实时预测伪代码四、智能诊疗决策系统4.1 手术方案推荐流程4.2 麻醉方案生成伪代码五、预后…

Java 日期解析与格式化:从标准格式到自然语言解析

使用 Java 搭配 Apache Commons Lang3 和 Natty 库&#xff0c;实现灵活高效的日期解析与格式化。 一、背景 将不同格式的日期统一成一个格式。日期格式可能有以下几种类型&#xff1a; 标准格式&#xff1a;2024-02-28、14/05/2022、2002年5月6日非英文月份缩写&#xff1a;…

Room持久化库:从零到一的全面解析与实战

简介 在Android开发中,Room作为官方推荐的数据库持久化库,提供了对SQLite的抽象层,使得数据库操作更加安全、高效且易于维护。 Room通过注解处理器和编译时验证,显著降低了数据库操作的复杂度,同时支持响应式编程模式,使开发者能够轻松实现数据变化的实时监听。对于企业…

MySQL(6)如何删除数据库和表?

在 MySQL 中删除数据库和表是常见的管理操作。下面将详细介绍如何使用 SQL 语句以及图形化工具来删除数据库和表。 步骤一&#xff1a;连接 MySQL 服务器 首先&#xff0c;连接到 MySQL 服务器&#xff0c;可以使用命令行工具 mysql 或图形化工具如 MySQL Workbench。 使用命…

携固态电池、新形态钢壳叠片电池等产品 豪鹏科技将亮相CIBF 2025

携固态电池、新形态钢壳叠片电池等产品 豪鹏科技将亮相CIBF 2025 来源&#xff1a; 电池百人会-电池网 豪鹏科技&#xff08;展位号:14W001&#xff09;将携固态电池、新形态钢壳叠片电池及高安全性钠离子电池等前沿技术产品亮相CIBF 2025&#xff0c;凭借多年的技术积累和产…