- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我正在使用 java 1.6 开发即时通讯工具。 IM 使用多线程 - 主线程、接收和 ping。对于 tcp/ip 通信,我使用了 SocketChannel。从服务器接收更大的包裹似乎存在问题。服务器而不是服务器发送了几个包,这就是问题开始的地方。前 8 个字节表示包的类型以及包的大小。这就是我阅读的方式:
public void run(){
while(true){
try{
Headbuffer.clear();
bytes = readChannel.read(Headbuffer); //ReadableByteChannel
Headbuffer.flip();
if(bytes != -1){
int head = Headbuffer.getInt();
int size = Headbuffer.getInt();
System.out.println("received pkg: 0x" + Integer.toHexString(head)+" with size "+ size+" bytes);
switch(head){
case incoming.Pkg1: ReadWelcome(); break;
case incoming.Pkg2: ReadLoginFail();break;
case incoming.Pkg3: ReadLoginOk();break;
case incoming.Pkg4: ReadUserList();break;
case incoming.Pkg5: ReadUserData();break;
case incoming.Pkg6: ReadMessage();break;
case incoming.Pkg7: ReadTypingNotify();break;
case incoming.Pkg8: ReadListStatus();break;
case incoming.Pkg9: ChangeStatus();break;
}
}
}catch(Exception e){
e.printStackTrace();
}
}
}
在测试期间一切都很好,直到我登录我的帐户并导入我的好友列表。我向服务器发送状态请求,他给我发回了 80 个联系人中的大约 10 个。所以我想出了这样的东西:
public synchronized void readInStatus(ByteBuffer headBuffer){
byteArray.add(headBuffer); //Store every buffer in ArrayList
int buddies = MainController.controler.getContacts().getSize();
while(buddies>0){
readStuff();
readDescription();
--buddies;
}
}
每个 readStuff() 和 readDescription() 都会检查每个参数大小以及缓冲区中的剩余字节:
if(byteArray.get(current).remaining() >= 4){
uin = byteArray.get(current).getInt();
}else{
byteArray.add(Receiver.receiver.read());
current = current +1;
uin = byteArray.get(current).getInt();
}
而 Receiver.receiver.read() 是:
public ByteBuffer read(){
try {
ByteBuffer bb = ByteBuffer.allocate(40000);
bb.order(ByteOrder.LITTLE_ENDIAN);
bytes = readChannel.read(bb);
bb.flip();
return bb;
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
因此,应用程序已启动、记录,然后发送联系人。服务器只发回我的列表的一部分。但在方法 readInStatus(ByteBuffer headBuffer) 中,我尝试强制列表的其余部分。现在有趣的部分 - 一段时间后它到达 Receiver.receiver.read() 并在 bytes = readChannel.read(bb) 上它停止了,我不知道为什么,没有错误,甚至在一段时间后什么也没有,我没有想法。我整整一周都在奋斗,但我没有找到解决方案。我将不胜感激任何建议。谢谢。
<小时/>感谢您的回复。是的,我正在使用阻塞 SocketChannel,我尝试过非阻塞,但它变得疯狂并且失控,所以我跳过了这个想法。关于我期望的字节 - 这有点奇怪,因为它只在头部给我一次大小,但它的第一部分的大小而不是整个包,其他部分根本不包含头字节。我无法预测它会有多少字节,原因是 - 具有 255 字节容量的描述。这正是我在以下位置创建变量 buddies 的原因:public synchronized void readInStatus(ByteBuffer headBuffer)
这基本上是我的好友列表的长度,在读取每个字段之前,我会检查是否还有足够的字节,如果没有,我会执行read()。但描述之前的最后一个字段是传入描述长度的整数。但在完成某些处理之前,无法确定包的长度。 @robert 你认为在这种情况下我应该再次尝试切换到非阻塞 SocketChannel 吗?
最佳答案
问题很可能是您发送的字节数少于您尝试读取的字节数。您可能错过了一些内容、写错了顺序、误读了尺寸字段或类似的内容。
我想我可以通过添加跟踪代码来计算和记录读取和写入的字节数、名义数据包大小等来解决这个问题。然后运行并比较跟踪,看看哪里开始不同步。
关于java - ReadableByteChannel 在读取(bytebuffer)时挂起,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/7307783/
我有一个空的 byteBuffer 分配为 data = ByteBuffer.allocateDirect(layerSize(0, faces - 1, 0, levels - 1) * laye
虽然存在 ByteBuffer.put(ByteBuffer) 方法,但 ByteBuffer.get(ByteBuffer) 似乎丢失了?我应该如何从较大的 ByteBuffer 读取较小的 Byt
我在 Dart Web 应用程序中加载二进制文件,其中包含压缩音频数据作为二进制数据的一部分。当数据通过 http 请求加载时,它作为一个 ByteBuffer 出现,我理解它是 Dart 对 JS
假设我有一个列表/数组列表或字节缓冲区数组(List 或 ByteBuffer[]) 是否可以由此直接从上述数组中获取字节,而无需遍历所有项或计算它们的总大小?我正在寻找这样的东西: ByteBuff
我有一个或多个 ByteBuffer,其中包含一条消息的部分内容。现在我想阅读此消息,但我不想将 N ByteBuffer 复制到一个中。我的解析器需要一个包含完整消息的 ByteBuffer,但我的
如果已知它是其他缓冲区? 我知道这可以通过非直接数组支持的 ByteBuffer 使用 arrayOffset() 方法来完成,如下所示: int getRelativeBufferOffset(By
如何在 Dart 中将 ByteBuffer 的字节快速复制到另一个更大的 ByteBuffer(以非零偏移量)? 有一些缓慢的方法可以做到这一点。一种是将每个都转换为 Uint8List 并一次复制
嘿嘿, ByteBuffers 以及 netty 的 ByteBuff 使用索引来存储它们当前“所在”的位置。在我的应用程序开始时,我加载 ByteBuffers/ByteBuffs 中的多个文件以便
我知道 flip() 将当前缓冲区位置设置为 0,并将限制设置为上一个缓冲区位置,而 rewind() 只是将当前缓冲区位置设置为 0。 在下面的代码中,我使用 rewind() 或 flip() 得
我有一个数组 ByteBuffer s(实际上代表整数)。我想在数组中分离唯一和非唯一的 ByteBuffer(即整数)。因此我使用这种类型的 HashSet: HashSet columnsSet
我的代码中有一个 java.nio.ByteBuffer: ByteBuffer bb = ByteBuffer.allocateDirect(1024); ... 我希望能够将其替换为 ByteBu
我需要将代码从 Java 移植到 C#。在Java代码中,使用了方法“ByteBuffer.flip()”和“ByteBuffer.slice”,不知道怎么翻译。 我读过这个问题 ( An equiv
以下 Java 代码可以编译,但在运行时会出错: # javac ByteBufTest.java # java ByteBufTest Exception in thread "main" java
我有一个方法如下,它已经正常运行了很长时间: private String loadFromFile(){ RandomAccessFile inFile = null; FileCh
用户在测试中遇到了此崩溃。我的第一个猜测是这与内存有关,但除此之外我没有什么可做的。更深入地研究代码,我认为这可能是主线程问题,但看起来监听器在后台线程上被删除,所以我怀疑这就是原因。 我认为在应用程
以下代码(此为简化版)以前在jdk1.6中运行良好,现在在jdk 1.7下断言失败。 ByteBuffer buffer = ...; buffer.mark(); char c = (char) b
我有一个 10MB 的二进制文件。我需要以不同大小的 block (例如 300、273 字节)读取它。为了阅读,我使用 FileChannel 和 ByteBuffer。现在,对于每次读取迭代,我都
我想要做的是获取一个十进制整数,将其转换为十六进制,然后分隔字节。 据我了解,ByteBuffer 是实现此目的的最佳方法。整数不会超过65535,因此十六进制数保证为2个字节。例如,我有一个整数 4
我正在写一些使用 ByteBuffer 的东西s。在 docs of the API它说 There is no way to free a buffer explicitly (without JV
我正在尝试读取一个短数组,转换其元素并将它们放入字节数组中。我使用 ByteBuffer 并收回此异常: 线程“main”中的异常 java.lang.IndexOutOfBoundsExceptio
我是一名优秀的程序员,十分优秀!