logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Caused by: java.io.IOException: 你的主机中的软件中止了一个已建立的连接。

记一次使用微服务,大数据量导出Excel经过网关时的坑,导出时间在6分钟左右。正常直接访问服务,不经过网关导出是没有问题的(只是等待时间比较久),一旦经过网关就会报错:org.apache.catalina.connector.ClientAbortException: java.io.IOException: 你的主机中的软件中止了一个已建立的连接。at org.apache...

#ribbon
记一次Kafka重复消费解决过程

而且kafka消息拉取参数max-poll-records设置了500,意味着一次会批量拉取500条消息到本地处理,而max.poll.interval.ms参数默认是5分钟,当500条消息处理时长超过5分钟后,就会认为消费者死掉了,触发再均衡,导致同一个消息被重复消费。,一次拉取数据的最大数据量,默认为52428800B,也就是50M,但是如果设置的值过小,甚至小于每条消息的值,实际上也是能消费

#kafka#java
springBoot集成极光 app消息推送

极光推送一直以来提供了“广播”、“标签(tag)”、“别名(alias)”和“registration_id”等多种推送方式,这几种推送方式正确使用场景如下:如果您希望一条推送能发给您 App 下的全量用户,建议您使用“广播”;参考:怎么样广播推送?如果您希望一条推送能批量推送给具有相同属性的一群用户,建议您使用“标签(tag)”推送;参考:怎么样向指定的一群用户推送消息?如果您希望一条推送只针对

Datax是什么

9、split()方法通过adjustChannelNumber()方法调整channel个数,同时执行reader和writer最细粒度的切分,需要注意的是,writer的切分结果要参照reader的切分结果,达到切分后数目相等,才能满足1:1的通道模型。DataX作为一个服务于大数据的ETL工具,除了提供数据快照搬迁功能之外,还提供了丰富数据转换的功能,让数据在传输过程中可以轻松完成数据脱敏,

文章图片
#数据仓库
华为云对象存储OBS-通过临时URL访问OBS

官方API文档:​​​​​​​​​​​​​​通过临时URL访问OBS_对象存储服务 OBS_Java_临时授权访问_华为云开发过程中,您有任何问题可以在github上提交issue,或者在华为云对象存储服务论坛中发帖求助。接口参考文档详细介绍了每个接口的参数和使用方法。OBS客户端支持通过访问密钥、请求方法类型、请求参数等信息生成一个在Query参数中携带鉴权信息的URL,可将该URL提供给其他用

#java
Feign 自定义 ErrorDecoder (捕获 Feign 服务端异常)

问题描述:Feign 客户端捕获不到服务端抛出的异常解决:微服务之间接口互相调用,Feign客户端需要捕获服务的抛出的异常,并且返回统一错误格式。@Configurationpublic class FeignErrorDecoder implements ErrorDecoder {@Overridepublic Exception decode(String methodKey, Respon

#微服务
到底了