Netty - EventLoop队列监控 - 腾讯云开发者社区

文章/答案/技术大牛

发布

1回答

Netty - EventLoop队列监控

spring-boot、reactor-netty

我将Netty服务器用于Spring引导应用程序。有没有办法监控Netty服务器的队列大小，这样我们就可以知道队列是否已满，服务器是否无法接受任何新请求？此外，如果队列已满或无法接受新请求，netty服务器是否会记录日志？

浏览 41提问于2020-10-30得票数 1

回答已采纳

1回答

为什么Netty使用“多生产者单用户”队列？

netty

Netty-4的线程模型是：每个EventLoop(线程)都拥有自己的taskQueue，此队列仅由该EventLoop(线程)操作。那么taskQueue of EventLoop是如何由“多生产者”操作的呢？

浏览 2提问于2018-12-11得票数 0

回答已采纳

2回答

为了了解一些Netty模块的问题，我们实现了对Netty事件循环队列的监视。监视器使用io.netty.util.concurrent.SingleThreadEventExecutor#pendingTasks方法，它适用于大多数模块，但对于每秒处理几千个HTTP请求的模块，SingleThreadEventExecutor) eventExecutor; factory.registerGauge("EventLoopGroup-" + componentName, "<e

浏览 2提问于2015-10-04得票数 16

2回答

对多个客户端使用Netty4

netty

我正在使用Netty4创建一个服务器，它需要服务于多个客户端连接。ServerBootstrap是用父线程和工作线程组构造的。

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

回答已采纳

1回答

在网络编程中如何管理定时器任务如心跳？

network-programming、netty

在netty源代码中，有Read/WriteTimeoutHandler和HashedWheelTimer类。我想知道netty是如何使用它的？作为猜测，netty是否会记录最新的消息发送/写入时间，并使用HashedWheelTimer to scheduler Read/WriteTimeoutHandler作为计时器任务来检查超时？我还不是netty框架的家人，只想知道netty管理器定时器任务是如何完成的。除了netty，欢迎任何其他关于如何设计心

浏览 0提问于2018-05-12得票数 0

1回答

Quarkus无视kubernetes dns升级vertx dns解析器

java、kubernetes、quarkus、vert.x

] (vert.x-eventloop-thread-1) -Dio.netty.allocator.numDirectArenas: 22022-05-06 06:54:24,779 DEBUG] (vert.x-eventloop-thread-1) -Dio.netty.allo

浏览 16提问于2022-05-06得票数 0

回答已采纳

1回答

为什么Netty使用老板和work事件循环而不是一个事件循环？

netty

我有个关于Netty的问题。它似乎使用老板eventLoop继续接受连接，而另一个工作人员eventLoop继续执行数据I/O。源代码显示，一个eventLoop将重复调用select/poll/epoll。因此，将有多个eventLoop烧掉CPU。为什么netty不能只使用一个事件循环来处理服务器侦听套接字和接受的套接字？

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

回答已采纳

1回答

在deeplearning4j中可视化训练进度在启动服务器时抛出错误

java、visualization、deeplearning4j

[vert.x-eventloop-thread-0] DEBUG io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numDirectArenas: 16

浏览 134提问于2021-02-23得票数 1

回答已采纳

1回答

了解Netty内部结构

java、netty

在我对Netty的理解中，传入的消息传递给eventLoop(只有一个eventLoop，一个线程)。接下来，EventLoop不处理它，而是将它传递给ExecutorService(它在池中保存多个线程)以供执行。所有这些都是在NIO的帮助下实现的。EventLoop等待传入的消息，并通过选择器、键、通道等传递消息。我说的对吗？使用Netty 4

浏览 12提问于2019-05-29得票数 0

1回答

如何每隔5秒netty (Server)进行一次操作

java、netty

我之前在workerman php工作，创建了一个websocket服务器，但由于我经常在java上工作，所以我决定学习netty，我想知道如何每5秒向所有用户发送hello消息，在workerman

浏览 37提问于2019-06-08得票数 0

回答已采纳

1回答

如何通过Bootstrap配置Netty EmbeddedChannel？

testing、netty、plc4x

PLC4X的Java驱动程序大量使用Netty。我们还构建了大量所谓的“传输”，提供Netty用于通信的通道。其中一个传输是使用EmbeddedChannel的"TestTransport“。我正在努力使这个传输在Netty的引导机制中工作。我被卡住了。如果我不提供EventLoop，Bootstrap会抱怨没有EventLoop。如果我通过覆盖"init”方法从EmbeddedChannel获得EventLoop，EmbeddedChannel会抱怨已经配置了<em

浏览 3提问于2020-02-25得票数 1

1回答

如何截取rx-netty线程池中的代码

httpclient、netty、rx-netty

使用rx-netty http客户端，我将值作为http头，但我找不到一个钩子，在那里我可以在控制传递到netty线程池后读取此值，然后将其设置在netty线程的线程本地。

浏览 2提问于2015-12-31得票数 1

1回答

阻塞的vertx线程

java、mongodb、docker、maven-3、vert.x

: 818:36:10.013 [vert.x-eventloop-thread-0] DEBUG io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.chunkSizems

浏览 6提问于2020-07-08得票数 1

回答已采纳

1回答

在什么情况下eventloop.inEventLoop() ==是假的？

java、netty、nio、channel

我正在阅读netty 4源代码。eventLoop.inEventLoop()随处可见。据Netty说： register0(promise);

浏览 2提问于2020-01-03得票数 0

1回答

角中的FormGroup如果通过valueChanges相互倾听，就不能正确地看到其子程序的单个变化。

angular、observable、angular-reactive-forms、formgroups

我的情况很简单。有一个包含两个字段的html表单：此外，我还有两个订阅可以收听和记录更改： ngOnInit(){ firstName: new FormControl('', {updateOn: 'blur'}),

浏览 2提问于2019-10-11得票数 3

1回答

EntityManagerFactory已关闭-仅在特定计算机上

java、spring、hibernate、jpa

:341)2018-08-02 14:27:29,696 ERROR [stderr] (PG-JDBC EventLoop (6)) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRea

浏览 1提问于2018-08-03得票数 2

回答已采纳

1回答

Hono适配器无法连接到群集

openshift、okd、eclipse-hono

例如，当我部署amqp适配器(也发生在http和mqtt适配器上)时，我将从hono适配器获得以下日志记录：12:25:45.404 [vert.x-eventloop-threadout: messaging-hono-default.enmasse-infra.svc.cluster.local&#x

浏览 1提问于2019-01-07得票数 0

回答已采纳

1回答

避免在醒来时失去资源

java、multithreading、performance、netty、wakeup

我想避免花费大量CPU资源唤醒netty的线程。每次包被冲红，网络就会被唤醒。当我有大量的数据包发送，我有很多这样的唤醒，这是真的很难的CPU处理。我还试图合并频道的EventLoops，但似乎每个频道都有自己的EventLoop。

浏览 4提问于2021-12-07得票数 2

1回答

如何在类似代理的netty应用程序中传输请求

multithreading、tcp、netty

我正试图用netty4编写一个类似代理的应用程序，我想知道是否只能建立一个与一个后端服务器实例连接的通道，而不是每个前端连接一个通道(就像网络示例所做的那样)。或者有什么更好的办法来完成这件事？为了解决这个问题，在我的前端/后端通道之间添加一个多生产者-单一消费者队列，这

浏览 2提问于2014-04-27得票数 0

2回答

通过Netty的Channel.write()发送的消息在begin发送到网络时是否保持其顺序？

netty

我正在进行某种加密，这取决于通过Netty通道发送的消息的顺序。我所期望的是，如果我在消息B之前将消息A写入通道，那么它们应该按照我将它们写入通道的相同顺序发送到远程套接字。那么我需要的情况已经得到Netty的支持了吗？另一方面，Netty的Channel接受并发写入调用，我怀疑我的要求是否已经满足。

浏览 0提问于2012-01-31得票数 2

点击加载更多