基于主题的消息传递

/**
 * 请求ADM向TopicBasedMessaging注册您的安全配置文件。
 */
public void tbmRegistration(String clientSecret, String accessToken) throws Exception
{
    // 消息的JSON负载表示。
    JSONObject payload = new JSONObject();

    //添加clientSecret值，该值用于创建标头中提供的accessToken。
    payload.put("clientSecret", clientSecret);


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

    //建立基本URL。
    String admUrlTemplate = "https://api.amazon.com/v1/messaging/topic/registrations";

    URL admUrl = new URL(admUrlTemplate);

    // 为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("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("错误： 向TBM注册安全配置文件的请求失败，并附带" +
                                         "%d响应代码和如下消息：%s"，
                                         responseCode, errorContent));
    }
    else
    {
        // 请求成功。响应包含向TopicBasedMessaging注册的安全配置文件。
        String responseContent = parseResponse(conn.getInputStream());
        JSONObject parsedObject = new JSONObject(responseContent);

        String message = parsedObject.getString("message");
        
        //您可以从消息中提取安全配置文件，以验证其是否与用于
        //创建请求标头中使用的accessToken的安全配置文件相同。
        
    }

}

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();
}

final ADM adm = new ADM(this);
// subscribeToTopic()是异步的；
//如果subscribeToTopic()成功，将经由onSubscribe()回调通知您的应用。
//如果subscribeToTopic()失败，则onSubscribeError()回调。
adm.subscribeToTopic("weather");

final ADM adm = new ADM(this);
//unsubscribeFromTopic()是异步的；
//如果unsubscribeFromTopic()成功，您的应用将经由onUnsubscribe()回调得到通知。
//如果unsubscribeFromTopic()失败，则onUnsubscribeError()回调。
adm.unsubscribeFromTopic("weather");

try {
    Log.d(TAG, "subscribeToTopic: 尝试订阅主题：" + topic);
    adm.subscribeToTopic(topic);
} catch (Error e) {
    Log.d(TAG, "subscribeToTopic: 发送了错误，错误消息为" + e.getMessage());
}

public class MyADMMessageHandler extends ADMMessageHandlerJobBase{
    @Override
    protected void onSubscribe(final Context context, final String topic) {
        //在这里写下成功订阅的逻辑，例如
        //通知客户
        //将详细信息发送至服务器
    }

    @Override
    protected void onSubscribeError(final Context context, final String topic, final String errorId) {
        //根据错误ID在此处编写订阅错误的逻辑
    }

    @Override
    protected void onUnsubscribe(final Context context, final String topic) {
        //在这里写下成功取消订阅的逻辑，例如
        //通知客户
        //将详细信息发送至服务器
    }

    @Override
    protected void onUnsubscribeError(final Context context, final String topic, final String errorId) {
        //根据错误ID在此处编写取消订阅错误的逻辑
    }

}

/**
 *请求ADM将您的消息传递给订阅了给定主题的应用的特定实例。
 */
public void sendMessageToTopic(String topic, 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通知支持的键值对可以从文档中找到
    // (https://developer.amazon.com/zh/docs/adm/message-types.html#notification).
    JSONObject notification = new JSONObject();
    notification.put("title", "ADM消息通知");
    notification.put("body", "我们为您提供了最新优惠！");
    payload.put("notification", notification);

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

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

    // 为消息添加优先级。优先级的值决定了当设备处于低电耗/空闲模式时，
    // 消息会不会传送。
    payload.put("priority", "high");
    
    //将主题添加到消息正文中，同时使用该主题将消息传递到应用实例。
    payload.put("topic", topic);


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

    //建立基本URL
    String admUrlTemplate = "https://api.amazon.com/v1/messaging/topic/messages";

    URL admUrl = new URL(admUrlTemplate);

    // 为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("错误： 发送消息至主题%s的请求失败，并附带" +
                                         "%d响应代码和如下消息：%s"，
                                         topic, responseCode, errorContent));
    }
    else
    {
        // 请求成功。响应包含messageId，
        //其与发送的消息以及向其发送消息的主题相关联的ID。

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

        String messageId = parsedObject.getString("messageId");
        //如果消息未传递到任何应用实例，
        //则可以用ADM传达messageId以解决问题。
}

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();
}