-
0 votesanswersviews
带管道的Reactor Netty TcpServer
我在反应堆netty之前组建一个Netty Tcp服务器的方法是创建服务器bootsrap并添加我的自定义管道类 . 使用Reactor-Netty有TcpServer.create(),但似乎我必须创建一个新的功能接口,它接受NettyInbound和NettyOutbound并返回一个Mono . 但是,如果我想添加一个构建我的管道的ChannelInitializer,我必须阻止获取Nett... -
1 votesanswersviews
Reactor-Netty:意外的消息类型:PooledUnsafeDirectByteBuf
我有一个HttpServer和一个HttpClient . 如果我在任何一方使用Netty的HttpServerCodec和HttpObjectAggregator,我就会收到错误 . 服务器代码 HttpServer server = HttpServer.create(opts -> opts.listen(8092).afterChannelInit(channelInit ->... -
4 votesanswersviews
如何在Spring Webflux / Reactor Netty Web应用程序中执行阻塞调用
在我的用例中,我有一个带有Reactor Netty的Spring Webflux微服务,我有以下依赖项: org.springframework.boot.spring-boot-starter-webflux (2.0.1.RELEASE) org.springframework.boot.spring-boot-starter-data-mongodb-reactive (2.0.1... -
0 votesanswersviews
Reactor-netty TCPClient无法接收响应
我正在尝试在缺乏文档的最新reactor-netty版本上做一些项目前的经验;我正在使用0.8.0.M3版本 . 我用这个tcp服务器开发了一个简单的spring boot应用程序,它可以正常启动并且似乎可以工作: @PostConstruct public void startServer() throws InterruptedException { TcpServer.create(... -
8 votesanswersviews
Spring 5 webflux如何在Webclient上设置超时
我正在尝试在我的WebClient上设置超时,这是当前代码: SslContext sslContext = SslContextBuilder.forClient().trustManager(InsecureTrustManagerFactory.INSTANCE).build(); ClientHttpConnector httpConnector = new ReactorClientH... -
0 votesanswersviews
在Spring Boot反应式Web应用程序上启用SSL,并在控制台中对该打印进行http调用时出现异常噪音
在我创建了我的spring boot反应式Web应用程序以支持SSL之后,当我尝试对服务器进行http调用时,它会在控制台中的异常跟踪下面打印 . 作为应用程序所有者,我无法阻止任何人使用我的服务 . 但我应该能够防止在控制台中进行跟踪打印,尤其是在反应性Web应用程序中,IO操作成本很高 . 有什么想法防止这种情况? Edit 3 : 2018-10-01 14:11:18.440 ERROR ... -
0 votesanswersviews
SSDP协议最简单的Reactor / Netty实现是什么?
我尝试了很多UdpClient,UdpServer,Spring Integration Ip模块的东西,包装DatagramSocket接收方法返回Flux,但我根本无法从标准SSDP 239.255.255.250:1900收到任何响应 . 奖励积分也用于向SSDP发送数据包 . -
1 votesanswersviews
WebClient停止从Flux读取时的异常
我创建了一个返回无限Flux的服务器和一个异步读取响应对象的客户端 . 我希望客户取消订阅Flux并停止处理它 . 服务器的控制器: @GetMapping(path = "/infinite", produces = TEXT_EVENT_STREAM_VALUE) public Flux<String> getStreamOfLongs() { retu... -
1 votesanswersviews
Spring WebFlux webclient处理ConnectTimeoutException
我使用Spring WebFlux webclient进行REST调用 . 我已经在 3000 毫秒上配置了连接超时,因此: WebClient webClient = WebClient.builder() .clientConnector(new ReactorClientHttpConnector(options -> options .option(Chann...