微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

下面的 webclient 配置有什么问题?

如何解决下面的 webclient 配置有什么问题?

我遇到了连接错误。日志条目是 readAddress(..) 失败:对等方重置连接;嵌套异常是 io.netty.channel.unix.Errors$NativeIoException: readAddress(..) Failed: Connection reset by peer 连接观察到错误 待处理的获取队列已达到其最大大小 1000;嵌套异常是 reactor.netty.internal.shaded.reactor.pool.PoolAcquirePendingLimitException

Web 客户端配置为:

@Bean
public WebClient webClient(@Autowired ObjectMapperBean objectMapperBean) {
        ConnectionProvider provider =
                ConnectionProvider
                        .builder("custom")
                        .maxConnections(500)
                        .build();

        HttpClient httpClient = HttpClient.create(provider);

        ExchangeStrategies exchangeStrategies =
                ExchangeStrategies
                        .builder()
                        .codecs(codecConfigurer -> codecConfigurer
                                .defaultCodecs()
                                .jackson2JsonEncoder(new Jackson2JsonEncoder(objectMapperBean.getobjectMapper(),MediaType.APPLICATION_JSON)))
                        .build();

        return WebClient
                .builder()
                .clientConnector(new ReactorClientHttpConnector(httpClient))
                .exchangeStrategies(exchangeStrategies)
                .build();
    }

我不确定问题出在哪里。有人可以帮我吗? #springboot #webclient

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。