如何将通用文件发送到球衣服务并正确接收？

Question

我正在开发一项使用 Dropbox API 的 Jersey 服务。

我需要将通用文件发布到我的服务（该服务将能够管理每种类型的文件，就像使用 Dropbox API 一样）。

客户端

因此，我实现了一个简单的客户端：

• 打开文件，
• 创建到 URL 的连接，
• 设置正确的 HTTP 方法，
• 创建 FileInputStream 并写入使用字节缓冲区连接的输出流上的文件。

这是客户端测试代码。

public class Client {

  public static void main(String args[]) throws IOException, InterruptedException {
    String target = "http://localhost:8080/DCService/REST/professor/upload";
    URL putUrl = new URL(target);
    HttpURLConnection connection = (HttpURLConnection) putUrl.openConnection();

    connection.setDoOutput(true);
    connection.setInstanceFollowRedirects(false);
    connection.setRequestMethod("POST");
    connection.setRequestProperty("content-Type", "application/pdf");

    OutputStream os = connection.getOutputStream();

    InputStream is = new FileInputStream("welcome.pdf");
    byte buf[] = new byte[1024];
    int len;
    int lung = 0;
    while ((len = is.read(buf)) > 0) {
      System.out.print(len);
      lung += len;
      is.read(buf);
      os.write(buf, 0, len);
    }
  }
}

服务器端

我有一个方法：

• 获取一个InputStream作为参数，
• 创建一个与原始文件具有相同名称和类型的文件。

以下代码实现了接收特定PDF文件的测试方法。

@PUT
@Path("/upload")
@Consumes("application/pdf")
public Response uploadMaterial(InputStream is) throws IOException {
  String name = "info";
  String type = "exerc";
  String description = "not defined";
  Integer c = 10;
  Integer p = 131;
  File f = null;
  try {
    f = new File("welcome.pdf");

    OutputStream out = new FileOutputStream(f);
    byte buf[] = new byte[1024];
    int len;
    while ((len = is.read(buf)) > 0)
      out.write(buf, 0, len);
    out.close();
    is.close();
    System.out.println("\nFile is created........");
  } catch (IOException e) {
    throw new WebApplicationException(Response.Status.BAD_REQUEST);
  }

  //I need to pass a java.io.file object to this method
  professorManager.uploadMaterial(name, type, description, c,p, f);

  return Response.ok("<result>File " + name + " was uploaded</result>").build();
}

此实现仅适用于文本文件。如果我尝试发送一个简单的 PDF，收到的文件将不可读（在我将其保存到磁盘上之后）。

我怎样才能满足我的要求？有人可以建议我解决方案吗？

Answer 1

您的客户端代码有错误。

while ((len = is.read(buf)) > 0) {
  ...
  is.read(buf);
  ...
}

您在每次迭代中都会从 InputStream 读取两次。从循环体中删除 read 语句就可以了。

您还说过问题中提供的代码适用于文本文件。我认为这也行不通。从您尝试上传的文件中读取两次意味着您只上传了一半的内容。一半的文本文件仍然是文本文件，但一半的PDF只是垃圾，所以你无法打开后者。您应该仔细检查上传和保存的文本文件的内容是否与原始文件相同。