我一直在测试客户端(用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字节顺序。