Netty并行处理程序处理

文章/答案/技术大牛

发布

1回答

parallel-processing、netty、blocking

按照别处的建议，我正在尝试在Netty管道中并行化我的最后一个入站处理程序 public final class EchoServer { group.shutdownGracefully();} 作为测试，我有十个并发连接的客户端，并且我正在测量处理所有请求的执行时间我正在尝试将执行时间降低到2秒以下，以证明并行处理。

浏览 30提问于2019-04-27得票数 2

回答已采纳

1回答

Netty可以处理具有多个线程的单个管道吗？

concurrency、netty、pipelining

我有一个Netty4应用程序，它使用单个网络连接(或者更准确地说，单个IP多播组)以高吞吐量接收消息，因此管道中所有通道处理程序的处理基本上都是单线程的。有没有办法将Netty配置为并行处理，以便使用多个内核？我正在考虑多线程的“流水线模式”，也就是synchronous concurrency。像这样的东西是内置的吗--或者我必须在Netty管道之外自己实现它？

浏览 17提问于2020-12-07得票数 0

2回答

Netty websocket和Rest在同一个Java应用程序中

rest、websocket、netty、javax.ws.rs

我有一个现有的Java应用程序，它公开REST服务。我想在同一个应用程序中添加一个新特性来处理web套接字请求(使用netty)以及现有的REST服务。我怎样才能做到这一点而不改变我的休息服务呢？

浏览 11提问于2018-10-11得票数 1

回答已采纳

1回答

如何并行处理部分有序的消息？

netty、netty4

基于Netty的应用程序目前，所有这些都在线程上运行，就像在一个TCP连接上一样。我想知道如何并行化2，困难在于消息不能被并行地处理，因为消息是有部分顺序的。您可以认为这是一个key(message)函数，并且该函数返回相同结果的所有消息都需要按顺序处理，但是如果结果不同，它们可以并行</

浏览 5提问于2021-11-30得票数 0

回答已采纳

1回答

netty客户端上的Java输入

java、input、netty、system.in

我实际上正在使用Netty编写一个客户端-服务器程序，但我陷入了一个自上周以来无法解决的问题中。因为它是一个相当大的程序，所以我不能粘贴我所有的代码，但是，我开始使用Netty的github ()中的这个例子。

浏览 7提问于2016-12-01得票数 0

2回答

基于Java和Netty的聊天服务器

java、nio、netty

我想用Java和Netty实现一个聊天服务器。我的问题是:我应该在Netty的连接处理程序中完成所有工作吗？

浏览 0提问于2011-10-01得票数 2

回答已采纳

1回答

Netty消息处理程序

java、netty

我正在使用netty构建一个应用程序。在应用程序中，我需要处理传入和传出消息。要求是应用程序将发送的任何消息都应该由特定的处理程序处理，而进入应用程序的任何消息都应该由另一个特定的处理程序处理。但是，我希望在两个处理程序之间交换消息，以便能够跟踪发送的消息响应，因为请求消息也将发送到应用程序。请任何想法的hwo来实现这样的要求

浏览 0提问于2013-03-18得票数 0

1回答

Jetty ALPN/NPN没有正确配置

java、google-app-engine、grpc、google-cloud-pubsub

不是复制的 | | +- io.netty:netty-codec-socks:jar:4.1

浏览 19提问于2018-02-13得票数 0

回答已采纳

1回答

如何使用netty运行websocket服务器而不处理其他类型的HTTP请求(如GET和POST)。

websocket、netty

我使用Netty4.1.1运行websocket服务器。只想处理websocket而不处理其他类型的HTTP请求(如GET和POST)。在用于WebSocketServerProtocolHandler的Netty中，它说： “这个处理程序为您运行websocket服务器做了所有繁重的工作。它负责websocket握手以及控制帧的处理(Close、Ping、Pong)。文本和二进制数据帧将传递给管道中的下一个处理程序(由您实现)以进行

浏览 0提问于2016-06-29得票数 0

1回答

Netty是否同时修改传递的ChannelBuffers

java、netty

在Netty中，有人知道传递给上游事件处理程序的ChannelBuffer (在您从ChannelEvent /或MessageEvent转换它之后)是否会在您处理它的同时被Netty框架并发写入吗？例如，假设下面的方法在一个类中扩展了SimpleChannelHandler，并被绑定为netty服务器上的处理程序：public void messageReceived(ChannelHandlerContext我问这个

浏览 2提问于2011-12-01得票数 2

回答已采纳

2回答

Netty 4与JCA WorkManager集成

netty、jca

关于将Netty 3与JCA资源适配器集成的问题已经被问到了。但是，在Netty 4中，线程似乎被大量重构，而且这种方法不起作用(首先没有NioServerSocketChannelFactory类)。相反，我只使用JMS队列(入站和出站)作为EE应用程序和使用netty的独立服务器之间的集成点，并且运行良好。

浏览 5提问于2014-06-18得票数 0

回答已采纳

1回答

Netty 4中的阻塞

java、sockets、netty

有没有办法在Netty 4客户端中以阻塞模式运行一些代码？我找不到任何关于如何在阻塞模式下运行某些代码的问题或示例。

浏览 2提问于2015-07-08得票数 0

1回答

在Netty* 4.1中，何时在关闭服务器上的通道后删除管道中的处理程序？*

java、netty、nio

因此，我们正在生产服务器上从Netty 3.9迁移到Netty 4.1。在这两个版本中，添加和删除ChannelHandler的方式似乎有所不同。而在Netty 4.1中，管道有时只显示很少的处理程序，或者根本不显示任何处理程序，而在Netty 3.9中，所有的处理程序都是存在的。所有这些都是在关闭通道引用之后完成的。这是意料之中的吗？在通道关闭后，Netty (在3.9和4.1中)何时删除管道中的

浏览 9提问于2017-07-04得票数 1

回答已采纳

1回答

使用多个线程处理单个连接

netty

根据这种逻辑，我设法以不同的顺序处理响应和请求。是否有任何配置强制每个连接使用多个线程？这是解决问题的正确方法吗？我用的是netty 5。非常感谢。

浏览 0提问于2014-11-09得票数 2

回答已采纳

1回答

使用Netty和Disruptor性能有什么关系吗？

java、protocol-buffers、netty、disruptor-pattern

我想在Netty中实现传输和解码部分。我的问题是:向Disruptor的环形缓冲区性能发布解码消息是否有意义--或者Disruptor提供的额外性能将被内部Netty调度所否定？我应该为Netty提供两个线程(一个用于“接受”，另一个用于“连接”组)，还是一个更好？也许，我应该在Netty的处理程序中按长度字段拆分消息，并在Disruptor的处理程序中执行解码吗？

浏览 0提问于2014-04-10得票数 6

回答已采纳

1回答

在Netty4中，为什么在OutboundHandler中同时读写

netty

我在Netty4中有一个问题，I/O事件由ChannelInboundHandler或ChannelOutboundHandler处理第一个问题是为什么在ChannelOutboundHandler

浏览 1提问于2014-03-12得票数 5

2回答

Ktor、Netty和增加每个端点的线程数

multithreading、kotlin、netty、ktor

使用Ktor和Kotlin 1.5来实现Netty支持的REST服务。关于这项服务的几件事： "Work“需要相当长的时间才能完成。是一个唯一的客户机端点，它与此服务并行发送多个请求。我们使用来自单个客户端的并行请求运行负载测试，并且注意到服务器上只有两个实际处理请求的线程。这不是一个资源短缺的问题--有大量的网络、内存、CPU等等，不管我们并行触发了多少请求--总是有两个线程在忙着，而其他线程则处于空闲状态。我们是否可以配置一个参数来增加可用于处理特定端点请求的线程数？

浏览 4提问于2022-02-16得票数 3

1回答

Netty处理程序中的Spring事务支持

spring、hibernate、transactions、netty

我正在使用以下版本：现在，我有一个运行良好的Netty服务器--服务器的根、管道工厂和拥有一切的服务器的基本但是，在处理程序中，这些处理程序是有状态的，并且是根据用户所处的状态动态创建的- @Transactional不工作。我很确定我能理解原因。我甚至有一个“解决方案”--但不是很好。考虑到上面的技术，让我的@Transactional符号在Netty处理程序<

浏览 3提问于2012-05-19得票数 3

2回答

对多个客户端使用Netty4

netty

我正在使用Netty4创建一个服务器，它需要服务于多个客户端连接。ServerBootstrap是用父线程和工作线程组构造的。这些EventLoopGroup用于处理SocketChannel和频道的所有事件和IO。” 据我所知，ParentExecutor组将处理任何传入的连接，并将其传递给子执行器组执行。我怀疑它是通过SingleThreadEventExecutor以单线程方式处理的？

浏览 5提问于2013-10-29得票数 0

回答已采纳

1回答

从网络中提取数据(而不是推动更好的背压控制)？

netty

是否有人知道netty http服务器的api是否允许应用程序告诉netty何时从套接字读取更多数据？在这个示例中，我看到使用者注册了一个处理程序，但是我想控制何时调用使用者，并告诉netty停止从套接字中获取数据，直到我处理完当前块。我希望有一个有背压的异步消费者。否则，如何告诉netty (不要向我提供更多数据或提供更多数据)如何异步处理netty中的数据并在此期间暂停netty (对于此请求

浏览 4提问于2016-06-08得票数 1

回答已采纳

点击加载更多