发送消息

/**
 *请求ADM将消息传送到您的特定应用实例。
 */
public void sendMessageToDevice(String registrationId, String accessToken) throws Exception
{
    // 消息的JSON负载表示。
    JSONObject payload = new JSONObject();

    // 为您的消息内容定义键/值对，并将它们添加到
    // 消息负载。
    JSONObject data = new JSONObject();
    data.put("firstKey", "firstValue");
    data.put("secondKey", "secondValue");
    payload.put("data", data);

    // 添加一个整合键。如果多条消息正在等待传递给
    // 具有相同的整合键的特定应用实例，则ADM将会尝试传递
    // 最近添加的项目。
    payload.put("consolidationKey", "ADM_Enqueue_Sample");

    // 向消息添加值为1天的expires-after值。如果目标应用实例
    // 在expires-after时间期限内未联机，则不会传递消息。
    payload.put("expiresAfter", 86400);

    // 为消息添加优先级。优先级的值决定了当设备处于低电耗/空闲模式时，
    // 消息会不会传送。
    payload.put("priority", "high");


    // 将JSON对象中的消息转换为字符串。
    String payloadString = payload.toString();

    // 建立基本URL，其中包括要使用所需应用实例的
    // 注册ID替换的部分。因为我们使用String.format创建
    // URL，所以%1$s字符指定要替换的部分。
    String admUrlTemplate = "https://api.amazon.com/messaging/registrations/%1$s/messages";

    URL admUrl = new URL(String.format(admUrlTemplate,registrationId));

    // 为POST请求生成HTTPS连接。您无法通过HTTP建立
    // 连接。
    HttpsURLConnection conn = (HttpsURLConnection) admUrl.openConnection();
    conn.setRequestMethod("POST");
    conn.setDoOutput(true);

    // 设置内容类型和接受标头。
    conn.setRequestProperty("content-type", "application/json");
    conn.setRequestProperty("accept", "application/json");
    conn.setRequestProperty("X-Amzn-Type-Version", "com.amazon.device.messaging.ADMMessage@1.0");
    conn.setRequestProperty("X-Amzn-Accept-Type", "com.amazon.device.messaging.ADMSendResult@1.0");

    // 添加授权令牌作为标头。
    conn.setRequestProperty("Authorization", "Bearer " + accessToken);

    // 获取连接的输出流并写入消息负载。
    OutputStream os = conn.getOutputStream();
    os.write(payloadString.getBytes(), 0, payloadString.getBytes().length);
    os.flush();
    conn.connect();

    // 从连接获取响应代码。
    int responseCode = conn.getResponseCode();

    // 检查我们是否收到了失败响应，如果是，则获取失败的原因。
    if( responseCode != 200)
    {
        if( responseCode == 401 )
        {
            // 如果收到401响应代码，则表明访问令牌已过期。令牌应刷新
            // 并且可以重试此请求。
        }

        String errorContent = parseResponse(conn.getErrorStream());
        throw new RuntimeException(String.format("ERROR: The enqueue request failed with a " +
                                         "%d response code, with the following message: %s",
                                         responseCode, errorContent));
    }
    else
    {
        // 请求成功。响应包含您的应用的特定实例的规范注册ID，
        // 它与用于请求的ID可能不同。

        String responseContent = parseResponse(conn.getInputStream());
        JSONObject parsedObject = new JSONObject(responseContent);

        String canonicalRegistrationId = parsedObject.getString("registrationID");

        // 检查两个注册ID是否不同。
        if(!canonicalRegistrationId.equals(registrationId))
        {
            // 此时应使用此特定应用实例的正确注册ID来
            // 更新存储注册ID值的数据结构。
        }
    }

}

private String parseResponse(InputStream in) throws Exception
{
    // 从输入流中读取并转换为字符串。
    InputStreamReader inputStream = new InputStreamReader(in);
    BufferedReader buff = new BufferedReader(inputStream);

    StringBuilder sb = new StringBuilder();
    String line = buff.readLine();
    while(line != null)
   {
      sb.append(line);
      line = buff.readLine();
    }

    return sb.toString();
}