【问题标题】:How to read multiple types of data from socket on java如何从java上的socket读取多种类型的数据
【发布时间】:2019-11-08 15:56:10
【问题描述】:

我写了一些文件传输应用程序。在客户端和服务器之间,我发送 3 种类型的数据:

1) 一些“命令词”,例如 READY_FOR_UPLOAD。

2) 一些可序列化的数据

3) 字节数组中的大文件。

我在服务器套接字上获得客户端连接并为每个客户端创建新线程。

    try (BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
    PrintWriter out = new PrintWriter(clientSocket.getOutputStream(),true);
    InputStream inputStream = clientSocket.getInputStream();
    ObjectInputStream objectInputStream = new ObjectInputStream(inputStream)) {}

我使用资源尝试创建这些流,没有问题。

我用:

1) "in" 用于从客户端读取消息:

    String line;
    while ((line = in.readLine()) != null) {
      System.out.println(line);
    }

2)“out”用于发送消息。

3)"inputStream" 用于接收文件:

    try (FileOutputStream fileOutputStream = new  
              FileOutputStream("D:\\testDownload.zip");
         BufferedOutputStream bufferedOutputStream = new 
               BufferedOutputStream(fileOutputStream)
            ) {
                byte[] buffer = new byte[1024 * 100];
                int read;
                while ((read = inputStream.read(buffer)) != -1) {
                   bufferedOutputStream.write(buffer, 0, read);
                }

            }

4) 可序列化数据的“objectInputStream”:

    Object object;
    if ((object = objectInputStream.readObject()) != null) {
        if (object instanceof File) {
              File file = (File) object;
              System.out.println(file.getAbsolutePath());
              System.out.println(file.length());
          }
     }

虽然我单独使用它们 - 没有问题。但我首先需要阅读“命令词”,即在我的胎面方法运行开始时。

    public void run() {
    try (BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
    PrintWriter out = new PrintWriter(clientSocket.getOutputStream(),true);
    InputStream inputStream = clientSocket.getInputStream();
    ObjectInputStream objectInputStream = new ObjectInputStream(inputStream)) {
      String line;
     if ((line = in.readLine()) != null) {
      System.out.println(line);

     there i should try to read other types of data
    }
    }

如果这不是“命令字”,我可以尝试读取可序列化数据或文件数据。但这是一个问题!我可能会尝试读取一行,但它可以是文件数据的可序列化数据的一部分,并且因为 inputsream 读取“一对一”字节方法,我不能尝试像可序列化或文件数据那样读取它,因为输入不再完整,我在“readLine()”中读取了一些数据。在尝试读取数据之前,我应该知道收到的数据类型。怎么办?

【问题讨论】:

  • 多次包装相同的 InputStream 或 OutputStream 并同时使用包装的实例可能会导致难以诊断错误,因为这些流可能会进行内部缓冲。您实际上要做的是将不同的输出流多路复用到单个输出流上。要使其工作,您需要定义一个协议,让接收器明确地恢复流。

标签: java sockets serversocket


【解决方案1】:

您需要创建一个协议 - 规则客户端和服务器如何在它们之间交换信息。 当您写入数据时,您指定要发送的数据类型及其大小。并且不要在 Socket 上使用 ObjectInputStream 和 ObjectOutputStream - 将数据转换为字节数组,以便在写入时知道大小,然后再将它们转换回来。以字节形式发送数据。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2020-12-14
    • 2021-04-05
    • 2019-08-02
    • 2020-01-02
    • 2019-08-28
    • 1970-01-01
    • 2016-05-13
    • 1970-01-01
    相关资源
    最近更新 更多