- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
嗯,我使用netty框架java,通过concox设备协议(protocol)处理消息,我的应用程序收到的消息似乎与预期的不同。
收到的消息就像
EF BF BD EF BF BD EF BF BD 0D 0A 78 78 1F 12 13 0A 1C 0F 12 1D EF BF BD
预期应该是
78 78 23 12 10 03 1D 0F 17 12 C7 02 6B 6E 38 0C 39 71 00 0B 15 0E 01 CC 00 24 95 00 13 93 0002 3D 7C 01 09 27 35 0D 0A
78 78 是起始位0D 0A是停止位
这可能是什么?我们将此应用程序库用于许多协议(protocol)并且它们可以工作支持人员说这可能是缓冲区连接的问题,但我不知道怎么可能。
我可以处理起始位和停止位位置错误的问题。但预期的信息仍然要大得多。
文档链接是http://www.iconcox.in/images/tr-06-protocol.pdf
我们的代码
public abstract class ExtendedObjectDecoder implements ChannelUpstreamHandler {
@SuppressWarnings("rawtypes")
public void handleUpstream(
ChannelHandlerContext ctx, ChannelEvent evt) throws Exception {
if (!(evt instanceof MessageEvent)) {
ctx.sendUpstream(evt);
return;
}
MessageEvent e = (MessageEvent) evt;
Object originalMessage = e.getMessage();
System.out.println((String) originalMessage);
}
}
管线
@Override
public void initTrackerServers(List<TrackerServer> serverList) {
serverList.add(new TrackerServer(new ServerBootstrap()) {
@Override
protected void addSpecificHandlers(ChannelPipeline pipeline) {
pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(4096, "$", "\0"));
pipeline.addLast("stringEncoder", new StringEncoder());
pipeline.addLast("stringDecoder", new StringDecoder());
pipeline.addLast("objectDecoder", new EquipProtocolDecoder(EquipProtocol.this));
}
});
serverList.add(new TrackerServer(new ConnectionlessBootstrap()) {
@Override
protected void addSpecificHandlers(ChannelPipeline pipeline) {
pipeline.addLast("stringEncoder", new StringEncoder());
pipeline.addLast("stringDecoder", new StringDecoder());
pipeline.addLast("objectDecoder", new EquipProtocolDecoder(EquipProtocol.this));
}
});
}
最佳答案
Netty 被设计为实际协议(protocol)之上的一个简化层,因此继承了许多语义。
一个重要的语义是 TCP 是一种基于流的协议(protocol),这意味着当您读取任何数据时,您会按顺序获取所有数据,但数据可能分布在多个数据包中,或者所有数据可能都在同一个数据包中。
您的代码没有正确处理这个问题,这导致了您的问题。
您的情况发生的是远程发送 2 个“协议(protocol)特定数据包”,读取后,这些数据包与“tcp 数据包”混合在一起
Aaaaa Bbbbb Cccc Ddddd
Aaa aaaBbbbCccccDdddd
您需要一些东西来再次重建原始消息。
目前,您的管道存在一个 StringDecoder
,后面是您的业务处理程序。不幸的是,StringDecoder
不适合处理原始传入数据的任务,并且可以actually cause corruption处理原始传入数据时。
幸运的是,“tr-06”在每个数据包中都有一个长度字段。 (检测起始位和停止位的存在是不可靠的,因为它们也可能位于数据包内)我们可以使用此长度字段将“字节流”再次解码为“数据包”。让我们从文档中收集一些信息协议(protocol):
iv.Data Packet Format
The communication is transferred asynchronously in bytes.The total length of packets is (10+N) Bytes
...
4.2.Packet Length
Length = Protocol Number + Information Content + Information Serial Number + Error Check, totally (5+N)Bytes, because the Information Content is a variable length field.
我们最终希望使用预构建解决方案来“构建”字节,因此让我们阅读 DelimiterBasedFrameDecoder
的文档。我们可以看到“5 字节 header 末尾有 3 字节长度字段,不剥离 header ”的示例与我们的需要非常匹配,但并不完全如此。让我们根据这些示例计算正确的数据:
我们在协议(protocol)示例中看到长度字段位于起始位之后,并且起始位为2个字节长,因此偏移量变为2
lengthFieldOffset = 2
根据文档,数据包长度字段为1,意味着它支持长度最大为255字节的数据包
lengthFieldLength = 1
这是一个很难计算的问题,Netty 假设数据包长度是数据包中包含长度字段之后的所有字节,因此让我们从 Netties 角度计算它,看看它是如何排列的。
Netty:1 + N + 2 + 2 + 2
协议(protocol):1 N + 2 + 2
lengthAdjustment = 2
我们需要将长度字段调整2
我们不想删除任何字节(如果您对起始位和停止位不感兴趣,您可能需要稍后启用此功能)
initialBytesToStrip = 0
让我们把它们放在一起:
@Override
protected void addSpecificHandlers(ChannelPipeline pipeline) {
pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(255, 2, 1, 2, 0));
pipeline.addLast("stringEncoder", new StringEncoder());
pipeline.addLast("stringDecoder", new StringDecoder());
pipeline.addLast("objectDecoder", new EquipProtocolDecoder(EquipProtocol.this));
}
关于java - 使用 Netty 收到的消息是否可能出现故障或受到限制?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58594055/
我有一个静态类。 static class AppDirectory { public static string PACSTEMP = Path.Combine(Path.GetTempPa
我已经设置了一个启用了推送通知的 iOS 应用。 我可以将消息推送到应用程序,例如角标(Badge)计数工作并相应更新。 但我从未在锁屏或其他地方看到标准的推送通知弹出窗口,但手机会振动,因此消息会通
我们有一个带有 Web 应用程序和一堆 Windows 服务的系统,它们在做一些后台工作。 每当我们需要对系统进行更实质性的更改时,我们最终不得不发出 IIS 重置,然后手动重新启动所有相关的 Win
我有以下几行 John SMith: A Pedro Smith: B Jonathan B: A John B: B Luis Diaz: A Scarlet Diaz: B 我需要获得所有获得
我正在编写一个 Java 客户端(在 weblogic 10.3 上)来调用一个安全的网络服务。我已获得安装在 cacerts、DemoIdentity.jks 和 DemoTrust,jks 中的客
已关闭。此问题不符合Stack Overflow guidelines 。目前不接受答案。 这个问题似乎偏离主题,因为它缺乏足够的信息来诊断问题。 更详细地描述您的问题或 include a mini
我正在尝试调用void方法addToList,该方法将通过用户传递给它的两个字符串除外。我检查了dataSource类,以确保它确实接受了那些作为参数。问题是我在该方法调用上始终收到标识符>预期错误,
我的任务:使用scanner方法从一行数据中提取字符串、 float 和整数。 数据格式为: Random String, 240.5 51603 Another String, 41.6 59087
这个问题已经有答案了: What causes a java.lang.ArrayIndexOutOfBoundsException and how do I prevent it? (25 个回答)
首先我实例化一个游戏状态 class GameState extends state{ ArrayList levels; int currentLevelID; public GameState()
已关闭。这个问题是 not reproducible or was caused by typos 。目前不接受答案。 这个问题是由拼写错误或无法再重现的问题引起的。虽然类似的问题可能是 on-top
我有一个实现为单例的 Controller 对象,它有一个可以随时驱逐对象的缓存。当一个对象即将被删除时,我想通知任何使用此 Controller 的类,以便它们能够做出适当的响应。我对这种行为的第一
因此,我尝试跨集群发送消息,该消息将包含一个 User 对象,该对象是一个可序列化类。 当我发送 String 或 int 时,它工作正常,消息发送没有问题,并且集群上的所有 channel 都收到它
我试图创建的程序是一个基本游戏,用户输入网格大小,选择 block 接收增加分数的奖品、从分数中夺走分数的强盗或结束游戏的炸弹。我收到堆栈流错误,但我不明白为什么? 抱歉,代码量很大,我只是无法找到问
使用此代码我会得到什么ConcurrentModificationException?我有一个同步(监听器)锁。 private void notifyListeners(MediumRenditio
我想在捕获 DeadlineExceededError 后正确退出。我还剩下多少钱来清理? 例如, try: do_some_work() except DeadlineExceededError
我有 2 个 Intranet 站点: http://intranetv1/ http://intranetv2/ v1基于.NET 1.1,v2基于.NET 3.5 在 v1 上,我创建了一个网页,
我有一个在 Linux 3.12 上运行的 C 程序。该程序产生几个子进程。其中一个进程会生成一个线程,该线程运行一段时间然后终止。当该子进程运行时,它会执行 epoll_wait()。 epoll_
我能够将 APNS 集成到我的应用程序中。现在我想在用户点击它或用户在使用应用程序时收到通知时处理通知。我使用下面的代码在收到通知时显示警报对话框: func application(applicat
当我试图在浏览器上运行这段代码时,出现了以下错误。"错误响应错误代码:501消息:不支持的方法(“POST”)。错误码解释:501-服务器不支持该操作。" 浏览器控制台出现以下错误: "1.加载资源失
我是一名优秀的程序员,十分优秀!