我一直在测试客户端(用Java编写)和服务器(用C#/。NET编写)之间传输数据。

我尝试了TCP客户端和服务器,但是已经出现了当前刷新流的问题。我意识到flush并不总是刷新流,所以我想知道是否有任何方法可以在没有.flush()或更可靠的方式下刷新/发送流?


当前,客户端的重要部分如下所示(消息是字符串,serverSocket是Socket对象):

OutputStream output = serverSocket.getOutputStream();

byte[] buffer = message.getBytes();
int length = buffer.length;

output.write(ByteBuffer.allocate(4).putInt(length).array());
output.write(buffer);
output.flush();


服务器看起来像这样:

NetworkStream stream = client.GetStream ();

byte[] sizeBuffer = new byte[4];
int read = stream.Read (sizeBuffer, 0, 4);

int size = BitConverter.ToInt32 (sizeBuffer, 0);
Databaser.log ("recieved byte message denoting size: " + size);

byte[] messageBuffer = new byte[size];
read = stream.Read (messageBuffer, 0, size);

string result = BitConverter.ToString (messageBuffer);
Databaser.log ("\tmessage is as follows: '" + result + "'");


如果在代码中看不到,则客户端将发送4个字节,这些字节将合并为一个32位整数,即消息的长度。然后,我根据该长度读入消息,并使用内置的转换器将其转换为字符串。

正如我所说,我想知道如何刷新连接?我知道这段代码并不完美,但是我可以将其更改回使用网络上的TCP和UTF专用字符串消息传递时,但是无论哪种方式,直到客户端关闭或关闭,连接都不会从客户端发送任何信息连接。

最佳答案

也许问题出在字节顺序上。我有一个从平板电脑(java)发送到C#应用程序(Windows Intel)的应用程序,除了以下内容外,我使用的方法与您所做的类似

ByteBuffer iLength = ByteBuffer.allocate(4);
iLength.order(ByteOrder.LITTLE_ENDIAN);
iLength.putInt(length);
output.write(iLength.array(), 0, 4);
output.write(buffer);
output.flush();


Java使用BIG-ENDIAN,而Intel使用LITTLE-ENDIAN字节顺序。

10-07 19:17
查看更多