netty

    0热度

    3回答

    在Netty服务器端是否有监听器,当客户端意外关闭时(比如当客户端m/c中的LAN电缆被移除时)会收到通知。 DefaultChannelHandler中的方法都没有被调用。假设在LAN电缆拔出时客户端处于不活动状态(不发送/接收任何数据)。 或者我们是否必须在服务器端实施Keep-Alive监视器来检查通道是否有效?

    6热度

    3回答

    我在protocol buffers中指定了一个协议。传输层正在利用Netty的Protocol Buffers支持 - 其重要性在于Netty的ProtobufDecoder只接受一种类型的MessageLite。 现在,我想在这个频道下面发送各种不同的消息类型,每个子类型都有与之相关的结构化信息。协议缓冲区没有继承机制,所以我使用了一种组合。我不确定我是否以正确的方式开展工作。 我的方法是使用

    4热度

    1回答

    我探索netty在虚拟机之间进行通信对象。我分别使用ObjectEncoder & ObjectDecoder来序列化这些。 我很快发现此解决方案限于最大1MB大小的对象。由于我打算沟通较大的对象,并且我不打算限制这个尺寸,所以我使用Integer.MAX_VALUE来设置最大帧长度。 不幸的是,它看起来像这个值被拾取以初始化一些缓冲区,从而导致不必要的GC并且非常可能在OutOfMemory中。

    0热度

    1回答

    我用游戏来开发我的项目和嵌入式netty3我的应用程序服务器 请检查下面的测试代码: package controllers; import java.io.File; import java.io.IOException; import java.util.HashMap; import java.util.Map; import java.util.concurrent.atomic

    0热度

    1回答

    我有一个严重的问题。我有一种情况,我需要向netty发送多个消息,这些消息都是由骆驼在同一个地方生成的,然后得到每条消息的响应。 的代码是类似的东西: from("direct:status") .split().method("splitMessage", "split").to("direct:device") from("direct:device") .to("netty:tcp:

    5热度

    2回答

    我在netty中实现了一个服务器,该服务器处理用户请求,与中间件通话并发送响应。与往返中间件相比,I/O预计可以忽略不计,所以为了最大限度地减少阻塞,我在OrderedMemoryAwareThreadPoolExecutor之上的管道中有一个ExecutionHandler。目前没有问题。 我正在研究服务器在重负载下的行为。根据过去的协议经验,我们往往会被偶然的DOS攻击所淹没 - 通常是用户的

    1热度

    2回答

    我想使用Netty和Protobuf来实现消息分发服务器。分发者将是一个知道基本protobuf消息并且具有扩展名的服务器,并将它们传递给注册这些扩展名的其他类。 Protobuf允许在单独文件中声明扩展名,因此分发者不需要知道扩展名的格式。然而,这似乎与Netty管道协同工作,我需要创建带有知道所有扩展的ExtensionRegistry的ProtobufDecoder,否则我会遇到描述为her

    4热度

    2回答

    我使用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 11225 nobody 61u 0000 0,9 0

    1热度

    1回答

    我一直在netty工作几个月,现在我有一个很大的问题。 我试图做一个MMO游戏,我想有非玩家角色(NPC)可以到处移动游戏,反应真实的用户交互(以及对其他用户不可见,以及实时) 。 什么是最好的方法来做到这一点? 我在想我可以创建一个“假用户”,但我不知道如何将它连接到我使用的套接字服务器。 顺便说一句:我使用TCP连接到服务器,从iPhone设备作为客户端。 谢谢!

    0热度

    2回答

    是否可以构建支持Range requests的管道?另外,如果我想自己实现这样的支持,有人能指出我应该看的API部分吗? (由https://github.com/webbit/webbit/issues/49启发)