问题标签 [netty]

添加对使用 SSL 的 netty 通道加密的支持。

需要一些参考资料和示例代码。

文档http://docs.jboss.org/netty/3.2/guide/pdf/netty.pdf仅指它可以使用 SSLHandler。

使用 JBOSS Netty，我正在尝试将数据连续发送到连接的客户端。在下面的示例中，我尝试每 5 秒向客户端发送一次时间，只要客户端连接（channelConnected）。

但这不起作用。只有当我评论 while 循环时它才有效。

举个简单的例子，假设我想在 netty 中只使用 2 个工作线程来处理 3 个同时的 TCP 客户端连接，我该怎么做？

问题 A) 使用下面的代码，我的第三个连接没有从服务器获取任何数据 - 连接就在那里。注意 - 我的工作执行程序和工作人员计数如何为 2。所以如果我有 2 个工作线程和 3 个连接，是否所有三个连接都应该由 2 个线程提供服务？

B) 另一个问题是 - netty 是否使用 java.util.concurrent 的 CompletionService？它似乎没有使用它。另外，我没有看到任何执行 executor.submit 或 future.get 的源代码所以所有这些都增加了它如何处理和提供数据到比它的工作线程更多的连接的混乱？

C）我对netty如何处理10000多个同时TCP连接感到迷茫......它会创建10000个线程吗？每个连接的线程不是一个可扩展的解决方案，所以我很困惑，因为我的测试代码没有按预期工作。

我用这个例子 进行性能测试

有人说netty的性能好快。它可以处理 1,00,000+ 并发请求/秒（查看以下链接）

http://www.jboss.org/netty/performance/20090303-mheath.html

http://www.jboss.org/netty/performance/20090607-asalihefendic.html

但是当我尝试使用这个示例时，它只给我 107 个请求/秒和 1000 个并发请求

给我建议问题出在哪里

有人可以分享任何网络示例或参考突出netty的性能基准。

以下是来自 ConcurrentWeakKeyHashMap.java 的 isEmpty() 方法， https://github.com/netty/netty/blob/master/src/main/java/org/jboss/netty/util/internal/ConcurrentWeakKeyHashMap.java

为什么它需要 mcsum，if(mcsum!= 0) {..} 块在做什么？

更重要的是，我如何获得

评估为真？

编辑： 如果块现在在 ConcurrentWeakKeyHashMapTest中，则评估上述代码

本质上 1 个线程持续监控 concurrentMap，而另一个线程持续添加/删除相同的密钥对值

I've used Mina and Netty, but now I'm in the market for a lightweight library that may also be used in Android. I prefer Nio or AsyncIo over standard io implementations.

Update 1
The lack of responses really makes me think I should write my own library. Right now I'm using raw NIO and its not a lot of fun.

我希望实现一个 JCA 资源适配器来接受来自 J2EE 容器内的套接字连接。

我需要能够以某种方式使用WorkManager来管理 netty 的NioServerSocketChannelFactory中的线程 非常感谢任何帮助。

我有一个在远程主机上运行的程序，我需要连接、握手，然后收听消息。我已经设置了以下骆驼路线：

我的问题是如何使这项工作？如果我使用

<from uri="netty:tcp://192.168.0.111:50001?decoders=#decoders&amp;sync=false" />

它因绑定错误而失败。

如何在不修改服务器的情况下设置连接以响应特定端口？

我正在使用 ChunkedWriteHandler 来处理 ChunkedFile 并遇到以下情况，如果我将 ChunkedFile 写入 channelFuture 侦听器内的通道，

我得到了 java.nio.channels.ClosedChannelException 和 java.lang.NullPointerException

当我做 clientChannel.write()

我知道使这项工作的唯一方法是：-不使用侦听器-并添加 Thread.sleep(1000)

我做错了什么？

完整代码（也在http://github.com/lydonchandra/netty/blob/master/src/test/java/org/jboss/netty/handler/stream/ChunkedWriteHandlerTest.java）

我目前正在使用 Play！1.2.2 及其新的 Netty 客户端框架。

虽然可以让 HTTP 和 HTTPS 异步服务，但我还没有找到一种简单的方法来强制执行 SSL。有谁用过Play！有执行 SSL 的简单方法吗？不确定我是否需要创建重定向，或者是否可以在conf文件中快速解决。