netty相关内容
我刚刚将spark项目从2.2.1升级到2.3.0，以在下面找到版本控制例外.我有依赖于datastax的spark-cassandra-connector.2.0.7和cassandra-driver-core.3.4.0，而后者又依赖netty 4.x，而spark 2.3.0使用3.9.x. spark 2.3.0中引入了引发异常的类org.apache.spark.network.u
..
我实现了一个扩展SimpleChannelHandler的处理程序，并覆盖了一些方法，例如channelConnected，messageReceived.但是，我想知道如何对其进行单元测试? 我搜索了"netty单元测试"，发现一篇文章其中说考虑使用CodecEmbedder，但是我仍然不确定如何开始.关于如何对Netty代码进行单元测试，您有任何示例或建议吗? 非常感谢. 解
..
您好，我有一个带有处理程序的Netty Server，该处理程序应该接受字符串.似乎最多只能接收1024个字节的内容.我如何增加缓冲区大小.我已经尝试过 bootstrap.setOption("child.sendBufferSize", 1048576); bootstrap.setOption("child.receiveBufferSize", 1048576); 没有成功.
..
我一直在尝试编写一个HTTP客户端以同时获取多个提要(最多1k)，这也是学习Netty 4的练习. 我的问题是，是否有很好的解释说明新的ByteBuf基础结构如何工作?谁“拥有"它们，如何共享它们(是吗?)? ChannelPipeline中的每个ChannelHandler是否都有自己的ByteBuf? 这是一个让我感到困惑的例子: 我将以下类的实例添加到HTTP客户端管道中:
..
根据书Netty in Action v10，reference counting用于处理ByteBuf的合并.但是JVM并不了解净引用计数，因此JVM仍可以GC ByteBuf.如果是这样，为什么我们仍然需要关心引用计数并手动调用release()方法? 我从书中引用了一些添加一些上下文. 引用计数的折衷之一是用户必须 消费消息时要小心.虽
..
我有同时使用TCP和UDP协议的应用程序.主要假设是客户端通过TCP协议连接到服务器，并且在建立连接时将发送UDP数据报. 我必须支持两种连接服务器的方案: -服务器运行时客户端连接 -客户端在服务器关闭时进行连接，然后重试连接，直到服务器再次启动 对于第一种情况，一切工作正常:我同时使用了两个连接. 问题出在第二种情况.当客户端尝试通过TCP进行几次连接并最终连接时，UDP连接功能将引发异
..
我需要使客户端能够建立许多连接.我使用Netty 4.0.不幸的是，所有现有示例都没有显示如何创建大量连接. public class TelnetClient { private Bootstrap b; public TelnetClient() { b = new Bootstrap(); } public void connect(St
..
我正在实现将Web-Servlet和纯Java应用程序混合在一起的混合服务器应用程序. java应用程序管理着用于远程设备的数千个套接字，而Web应用程序与用户进行交互以设置/读取任何套接字的状态. Java NIO或 Apache-MINA与Jboss-Netty 似乎是套接字的不错选择应用程序. 第一个问题是，我可以在同一服务器上同时运行两个应用程序(带有Web界面的Servlet
..
我现在正在尝试通过两种方式的SSL握手来设置Netty，其中客户端和服务器都在场并验证证书. 这似乎未在SslHandler中实现.有没有人这样做?我想它将在SslHandler.handshake操作中运行并委托给javax.net.ssl.SSLEngine? 是否有任何提示/技巧/预先存在的实现? 谢谢！ ANSWER(stackoverflow不允许我按正常方式发布
..
我正在尝试确定客户端是否已从netty关闭套接字连接.有办法吗? 解决方案 在通常情况下，客户端通过close()关闭套接字并且TCP关闭握手已成功完成，请使用channelInactive()(或channelClosed() 3)事件将被触发. 但是，在不寻常的情况下(例如，由于断电或LAN电缆未插入而使客户端计算机脱机)，可能要花费大量时间，直到您发现连接实际上已断开.要检测到
..
我是新手.我想开发一种服务器，该服务器旨在接收可能来自少数客户端的请求(例如Max的2个客户端).但是每个客户端将不断向服务器发送许多请求.服务器必须处理此类请求并响应客户端.因此，在此我假设即使配置了多个工作线程，也可能没有用，因为只有2个活动连接.工作线程再次阻塞，直到它处理并响应客户端.因此，请让我知道如何处理此类问题. 如果我在工作线程中使用threadpoolexecutor以多线程方式
..
我的意思是NioEventLoopGroup(threadsAmount)构造函数的一个参数.如果我理解得很好，那么我们需要多个线程来接受传入连接的情况就很少见了. 在哪种情况下，我们需要一个以上的线程来接受传入的连接?我在想，也许什么时候连接处理程序很轻巧，寿命很短. 解决方案 通常，如果您在不同的ServerBoostrap之间共享NioEventLoopGroup.
..
我用Netty编写了一个简单的UDP服务器，该服务器简单地在日志中打印出接收到的消息(帧).为此，我创建了一个简单的帧解码器解码器和一个简单的消息处理程序.我也有一个客户端，可以按顺序和/或并行发送多个请求. 当我将客户端测试器配置为依次发送几百个请求时，它们之间的延迟很小，使用Netty编写的服务器会正确接收所有请求.但是目前，我增加了客户端中的并发请求数量(例如100个)，加上顺序的
..
我正在评估 AsyncHttpClient 用于大负载(〜1M HTTP请求). 对于每个请求，我想使用AsyncCompletionHandler调用回调，该回调会将结果插入到阻塞队列中 我的问题是:如果我要在一个紧密的循环中发送异步请求，那么AsyncHttpClient将使用多少个线程? (我知道您可以设置最大值，但显然您有丢失请求的风险，我已经看到它此处) 我目前在以下版本中使
..
我添加了-Dio.netty.leakDetection.level=ADVANCED用于生产中的泄漏检测. 还有一些日志: 错误io.netty.util.ResourceLeakDetector-泄漏:在垃圾回收之前未调用ByteBuf.release().参见 http://netty.io/wiki/reference-counted-objects.html有关更多信息. 警告:因
..
我正在使用Netty 4.1.17-Final. 我编写了发送和接收100 MB随机ASCII的代码.直到ByteBuf变为100 MB时，解码器才会读取. @Override public void decode(ByteBuffer _in, List _out) { if (_in.remaining() == size) { // size = 10
..
当我从源头构建网络时，构建失败于 [INFO] Netty/Transport/Native/Epoll .......................失败[5.927 s] 我收到的错误消息是 [错误]无法在项目netty-transport-native-epoll上执行目标org.fusesource.hawtjni:maven-hawtjni-plugin:1.10:bu
..
我正在使用Netty 4.1.6. 是否可以使用log4j2作为内部记录器来设置netty? Eclipse提示我以下语句已贬值. InternalLoggerFactory.setDefaultFactory(new Log4J2LoggerFactory()); 你能告诉我怎么做吗? 解决方案 感谢Ferrybig的提示. 我正在详细说明如何在log4j2上执行此操作.
..
我正在使用Sun的JDK 1.6.0_26和NIO(带有Netty)，在lsof中，我看到了数百个anon_inode的文件描述符: $ lsof -np 11225 | fgrep -w anon_inode java 11225 nobody 57u 0000 0,9 0 1386 anon_inode java
..
我正在使用ktor 0.9.5.我正在尝试一个简单的例子.但是当尝试连接到服务器时，我得到了ERR_EMPTY_RESPONSE.这是我的代码. fun main(args: Array) { embeddedServer(Netty, port = 8080, host = "localhost") { install(DefaultHeaders)
..
