如何在服务器套接字JAVA中读取所有Inputstream

Question

我在我的一个项目中使用Java.net。我写了一个从客户端获取输入流的应用服务器。但是有时候我的（缓冲的）输入流不能得到客户端发送到我的服务器的所有输出流。我怎么能写一个等待或类似的东西，我的输入流得到客户端的所有输出流？

（我的输入流不是字符串）

private Socket clientSocket;
private ServerSocket server;
private BufferedOutputStream outputS;
private BufferedInputStream inputS;
private InputStream inBS;
private OutputStream outBS;

server = new ServerSocket(30501, 100);
clientSocket = server.accept();

public void getStreamFromClient()  {
    try {
        outBS = clientSocket.getOutputStream();
        outputS = new BufferedOutputStream( outBS);
        outputS.flush();

        inBS = clientSocket.getInputStream();
        inputS = new BufferedInputStream( inBS );

    } catch (Exception e) {
        e.printStackTrace();
    }
}

谢谢。

Answer 1

你可以像这样读取你的BufferedInputStream。它将读取数据，直到到达流的末尾，由-1表示。

inputS = new BufferedInputStream(inBS);
byte[] buffer = new byte[1024];    //If you handle larger data use a bigger buffer size
int read;
while((read = inputS.read(buffer)) != -1) {
    System.out.println(read);
    // Your code to handle the data
}

Answer 2

int c;
    String raw = "";
    do {
        c = inputstream.read();
        raw+=(char)c;
    } while(inputstream.available()>0);

输入流。available（）仅在读取一个字节后显示可用字节，因此请执行。。虽然

Answer 3

您遇到的问题与TCP流性质有关。

例如，从服务器发送100个字节并不意味着第一次读取时将在客户端读取100个字节。也许从服务器发送的字节会以几个TCP段的形式到达客户端。

您需要实现一个循环，在这个循环中，您可以一直阅读，直到收到整个消息。让我举一个例子，用DataInputStream代替BufferedinputStream。举个简单的例子。

假设您事先知道服务器将发送100字节的数据。

在客户端，你需要写：

byte[] messageByte = new byte[1000];
boolean end = false;
String dataString = "";

try 
{
    DataInputStream in = new DataInputStream(clientSocket.getInputStream());

    while(!end)
    {
        int bytesRead = in.read(messageByte);
        dataString += new String(messageByte, 0, bytesRead);
        if (dataString.length == 100)
        {
            end = true;
        }
    }
    System.out.println("MESSAGE: " + dataString);
}
catch (Exception e)
{
    e.printStackTrace();
}

现在，通常一个节点（此处的服务器）发送的数据大小事先不知道。然后，您需要定义自己的小型协议，用于服务器和客户端（或任意两个节点）之间的通信，并使用TCP进行通信。

最常见和最简单的是定义TLV：类型、长度和值。因此，您定义从服务器发送到客户端的每条消息都带有：

• 1字节指示类型（例如，它也可以是2或其他）。
• 1字节（或其他）的消息长度
• N字节的值（N表示长度）。

所以你知道你必须接收至少2个字节，第二个字节你知道你需要读多少个字节。

这只是一个可能协议的建议。你也可以去掉“类型”。

所以它会是这样的：

byte[] messageByte = new byte[1000];
boolean end = false;
String dataString = "";

try 
{
    DataInputStream in = new DataInputStream(clientSocket.getInputStream());
    int bytesRead = 0;

    messageByte[0] = in.readByte();
    messageByte[1] = in.readByte();

    int bytesToRead = messageByte[1];

    while(!end)
    {
        bytesRead = in.read(messageByte);
        dataString += new String(messageByte, 0, bytesRead);
        if (dataString.length == bytesToRead )
        {
            end = true;
        }
    }
    System.out.println("MESSAGE: " + dataString);
}
catch (Exception e)
{
    e.printStackTrace();
}

下面的代码经过编译，看起来更好。它假设提供长度的前两个字节以二进制格式到达，即网络端（big-endian）。对于消息的其余部分，不要关注不同的编码类型。

import java.nio.ByteBuffer;
import java.io.DataInputStream;
import java.net.ServerSocket;
import java.net.Socket;

class Test
{
    public static void main(String[] args)
    {
        byte[] messageByte = new byte[1000];
        boolean end = false;
        String dataString = "";

        try 
        {
            Socket clientSocket;
            ServerSocket server;

            server = new ServerSocket(30501, 100);
            clientSocket = server.accept();

            DataInputStream in = new DataInputStream(clientSocket.getInputStream());
            int bytesRead = 0;

            messageByte[0] = in.readByte();
            messageByte[1] = in.readByte();
            ByteBuffer byteBuffer = ByteBuffer.wrap(messageByte, 0, 2);

            int bytesToRead = byteBuffer.getShort();
            System.out.println("About to read " + bytesToRead + " octets");

            //The following code shows in detail how to read from a TCP socket

            while(!end)
            {
                bytesRead = in.read(messageByte);
                dataString += new String(messageByte, 0, bytesRead);
                if (dataString.length() == bytesToRead )
                {
                    end = true;
                }
            }

            //All the code in the loop can be replaced by these two lines
            //in.readFully(messageByte, 0, bytesToRead);
            //dataString = new String(messageByte, 0, bytesToRead);

            System.out.println("MESSAGE: " + dataString);
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
    }
}