java - 500 错误 - 使用 AcrCloud RESTful api 上传音频文件

Question

我使用AcrCloud RESTful 服务 将音频文件 上传到名为demo 的音频和视频存储桶 >。我遇到了 500 Internal Server Error。这表明我的签名是正确的(当签名不正确 时，我得到了一个422)。我怀疑不正确的部分是多部分发布请求的构造

我的代码:

import com.xperiel.common.logging.Loggers;
import com.google.api.client.http.ByteArrayContent;
import com.google.api.client.http.GenericUrl;
import com.google.api.client.http.HttpContent;
import com.google.api.client.http.HttpHeaders;
import com.google.api.client.http.HttpMediaType;
import com.google.api.client.http.HttpRequestFactory;
import com.google.api.client.http.HttpResponse;
import com.google.api.client.http.MultipartContent;
import com.google.api.client.http.MultipartContent.Part;
import com.google.api.client.http.javanet.NetHttpTransport;
import com.google.common.collect.ImmutableMap;
import com.google.common.io.BaseEncoding;
import com.google.common.io.CharStreams;

import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
import java.util.Map.Entry;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;

public class TestAcrCloudSignature {

  private static final String ACCESS_KEY = "xxxx"; // confidential
  private static final String SECRET_KEY = "yyyy"; // confidential
  private static final String URL = "https://api.acrcloud.com/v1/audios";

  private static HttpRequestFactory requestFactory = new NetHttpTransport().createRequestFactory();
  private static final Logger logger = Loggers.getLogger();

  public static void main(String [] args) {

    String filePath = "/Users/serena/Desktop/ArcCloudMusic/Fernando.m4a";
    String httpMethod = HttpMethod.POST.toString();
    String httpUri = "/v1/audios";
    String signatureVersion = "1";
    long timestamp = System.currentTimeMillis();
    String stringToSign = getStringToSign(httpMethod, httpUri, signatureVersion, timestamp);
    String signature = getSignature(stringToSign);

    logger.log(Level.INFO, "Timestamp:\t" + timestamp);
    HttpResponse response = null;
    try {
      ImmutableMap<String, String> params = ImmutableMap.of(
          "title", "fernando",
          "audio_id", "1",
          "bucket_name", "demo",
          "data_type", "audio");
      byte[] audio = getAudioFileTo(filePath);

      String strResponse = sendMultiPartPostRequest(
          "",
          params,
          ImmutableMap.of("audio-file", new Pair<>("Fernando.m4a", audio)),
          signatureVersion,
          signature,
          timestamp);
      logger.log(Level.INFO, "RESPONSE:" + strResponse);
    } catch (Exception e) {
      logger.log(Level.WARNING, "Response:  " + response);
      logger.log(Level.WARNING, "Exception: " + e.getMessage());
      e.printStackTrace();
    }
  }

  private static String getStringToSign(String method, String httpUri, String signatureVersion, long timestamp) {
    String stringToSign = method+"\n"+httpUri+"\n"+ACCESS_KEY+"\n"+signatureVersion+"\n"+timestamp;
    logger.log(Level.INFO, "String to Sign:\t" + stringToSign);
    return stringToSign;
  }

  private static String getSignature(String stringToSign) {
    String signature = BaseEncoding.base64().encode(hmacSha1(stringToSign));
    logger.log(Level.INFO, "Signature:\t" + signature);
    return signature;
  }

  private static byte[] hmacSha1(String toSign) {
    try {
      Mac mac = Mac.getInstance("HmacSHA1");
      mac.init(new SecretKeySpec(SECRET_KEY.getBytes(), "HmacSHA1"));
      return mac.doFinal(toSign.getBytes());
    } catch (NoSuchAlgorithmException | InvalidKeyException e) {
      throw new RuntimeException(e);
    }
  }

  private enum HttpMethod {
    GET, POST, PUT, DELETE,
  }

  private static byte[] getAudioFileTo(String filePath){
    File file = new File(filePath);
    byte[] buffer = null;
    try {
      InputStream fis = new FileInputStream(file);
      buffer = new byte[(int) file.length()];
      fis.read(buffer, 0, buffer.length);
      fis.close();
    } catch (IOException e) {
      logger.log(Level.WARNING, "IOException: " + e.getMessage());
    }
    return buffer;
  }

  private static String sendMultiPartPostRequest(
      String path,
      ImmutableMap<String, String> parameters,
      ImmutableMap<String, Pair<String, byte[]>> blobData,
      String signatureVersion,
      String signature,
      long timestamp) {
    try {
      MultipartContent multipartContent = new MultipartContent();
      multipartContent.setMediaType(new HttpMediaType("multipart/form-data"));
      multipartContent.setBoundary("--------------------------0e94e468d6023641");

      for (Entry<String, String> currentParameter : parameters.entrySet()) {
        HttpHeaders headers = new HttpHeaders();
        headers.clear();
        headers.setAcceptEncoding(null);
        headers.set("Content-Disposition", "form-data; name=\"" + currentParameter.getKey() + '\"');
        HttpContent content = new ByteArrayContent(null, currentParameter.getValue().getBytes());
        Part part = new Part(content);
        part.setHeaders(headers);
        multipartContent.addPart(part);
      }

      for (Entry<String, Pair<String, byte[]>> current : blobData.entrySet()) {
        ByteArrayContent currentContent = new ByteArrayContent("application/octet-stream", current.getValue().second);
        HttpHeaders headers = new HttpHeaders();
        headers.clear();
        headers.setAcceptEncoding(null);
        headers.set("Content-Disposition", "form-data; name=\"" + current.getKey() + "\"; filename=\"" + current.getValue().first + '\"');
        headers.setContentType("application/octet-stream");
        multipartContent.addPart(new Part(headers, currentContent));
      }
      ByteArrayOutputStream out = new ByteArrayOutputStream();
      multipartContent.writeTo(out);

      HttpResponse response = requestFactory
          .buildPostRequest(new GenericUrl(URL + path), multipartContent)
          .setHeaders(new HttpHeaders()
              .set("access-key", ACCESS_KEY)
              .set("signature-version", signatureVersion)
              .set("signature", signature)
              .set("timestamp", timestamp))
          .execute();
      String responseString = CharStreams.toString(new InputStreamReader(response.getContent()));
      return responseString;
    } catch (IOException e) {
      throw new RuntimeException(e);
    }
  }

  private static class Pair<A, B> {
    final A first;
    final B second;

    Pair(A first, B second) {
      this.first = first;
      this.second = second;
    }
  }
}

我从 AcrCloud 得到的错误信息是:

500

{"name":"Internal Server Error","message":"There was an error at the server.","code":0,"status":500}

我可以使用此 cUrl 命令 上传音频文件:

Command: $ curl -H "access-key: xxxx" -H "signature-version: 1" -H "timestamp: 1439958502089" -H "signature: Nom6oajEzon260F2WzLpK3PE9e0=" -F "title=fernando" -F "audio_id=100" -F "bucket_name=demo" -F "data_type=audio" -F "audio_file=@/Users/serena/Desktop/ArcCloudMusic/Fernando.m4a" https://api.acrcloud.com/v1/audios

有没有人对如何调试有任何提示？或者有没有人通过 Java 以编程方式成功使用此服务？或者有人可以告诉我如何打印 HttpPOST 请求的内容吗？

UPDATE I have also tried using their java example on GITHUB found here:

https://github.com/acrcloud/webapi_example/blob/master/RESTful%20service/UploadAudios.java

我得到了同样的 500 错误

UPDATE I no longer get the 500 error when I run their code. I fiddled with the apache jar versions and now I can successfully use the java code found on git hub. For record, The version that I used that work with their github code is apache-http-codec-1.10, apache-http-client-4.5, apache-http-core-4.4.1, apache-http-mime-4.5. When i used apache-http-core-4.5 it did not work.

UPDATE I have written a file that prints out the signatures generated by the java code on github reference above, and my own code. The signatures match so I am convinced that issue in the way I am constructing the multipart post request. I have also written the contents of both post requests to file and the headers contain different information in a few spots.

Answer 1

感谢 Serena 的耐心等待，我们的团队现在正在对代码和 apache jar 进行详分割析。希望很快会有更新。

现在，如果有人遇到同样的问题，请使用以下 jar，如 https://github.com/acrcloud/webapi_example/blob/master/RESTful%20service/UploadAudios.java 中所述

// import commons-codec-<version>.jar, download from http://commons.apache.org/proper/commons-codec/download_codec.cgi
import org.apache.commons.codec.binary.Base64;

// import HttpClient,  download from http://hc.apache.org/downloads.cgi
/**
 *   
 *   commons-codec-1.1*.jar
 *   commons-logging-1.*.jar
 *   httpclient-4.*.jar
 *   httpcore-4.4.1.jar
 *   httpmime-4.*.jar
 * 
 * */