java socket 问题

[phttc]

socket 通信

java 作客户端（ java.net.Socket ）， c++为服务端（ libevent ）

普通的单包发送和接收都没有问题..

但是当 java 发一个包过去， c++回复多个包的时候，，

java 端只接收到了第一个包。。。服务端显示所有的包都正常发送，但是 java 端没收到。

java 端的接收线程代码：

InputStream is ＝ mSocket.getInputStream();

while(true){

byte[] buffer = new byte[10240];

is.read(buffer);

...

...

}

各位大大，能不能给点思路

[binbinyouliiii]

socket 我都快忘了，我记得我以前写的好像是阻塞，然后新开线程

[Presageee]

有定义协议吗，一个包一个包的读，每次读定长包头，解析包体长度读包体。一次性 read(buffer)肯定不行的

[loqixh]

粘包了，先学习 socket 原理

[phttc]

@Presageee 对的，就是自定义协议的。。协议里会写当前是第几个包，一共有几个包。。。一次 read 就读出一条协议嘛，，读第二条的时候就阻塞在 read 里了，说明输入流已经是空的了。。

[phttc]

@loqixh 不好意思，我没说清楚。。我的包指的是我自己在代码里实现的分包，自定义协议里会写当前是第几个包，一共有几个包。。。不是底层的 TCP 包。。

[hcymk2]

@phttc
buffer 数组的长度？

[ovear]

flush 了么

[gamexg]

byte[] buffer = new byte[10240];
is.read(buffer);

先把 buffer 打出来，应该还是拆包部分没做好。

[skydiver]

TCP 是流协议，没有包的概念… x3

需要的话要自己分包

[hustfox]

一般都是在包里加长度字段，根据长度字段来收数据的。因为如果 socket 包过长的话会自动拆分成多个包的。

[loqixh]

@phttc 这样是不行的，要用长度分割，要不就和 http 一样用符号分割,因为 socket 会缓存

[wwqgtxx]

阻塞在 read 中应该是填不满你的 10240 这么大的缓冲区，而不是没有数据

[anexplore]

c++端数据都 flush 出来了嘛 或者你试一下 c++端发完包就 close socket

[crazyxin1988]

is.read(buffer); 这样读取方式不对。一般这样读数据：

while((len = is.read(buffer)) != -1){

}

[phttc]

@wwqgtxx 跟缓冲区大小没关系的。。
@skydiver @hustfox @loqixh

举个栗子吧。。。

客户端 C ：（ askid=1;current=1;total=1;）你是谁？
服务端 S ：（ askid=1;current=1;total=3;）我
S ：（ askid=1;current=2;total=3;）是
S ：（ askid=1;current=3;total=3;）服务器


服务端日志显示三个包都成功发送了。但是客户端的日志里就只有（ current=1;total=3;）我 这么一条。

[anexplore]

@phttc 怎么判断的发送成功？ 建议还是 抓包看一下

[21grams]

建议用 wireshark 抓一下包， server 端和 client 端都要抓，首先要保证在 tcp 层上所有的数据确实是发出来了。

[phttc]

@anexplore @21grams 谢谢，找到原因了。服务端说发送成功，其实并没有发出来。。。正在研究服务端到底是什么情况。