实现Appstore SDK IAP

private SampleIapManager sampleIapManager; // 商店购买收据数据（可选）
protected void onCreate(final Bundle savedInstanceState) // 在onCreate中实现PurchasingListener
{
  super.onCreate(savedInstanceState);
  // setupApplicationSpecificOnCreate();
  
  // 使用AppstoreSDK注册ApplicationContext，并启动检索DRM许可证的请求
  // 使用LicensingListener的实现（此处命名为LicensingCallback）
  LicensingService.verifyLicense(this.getApplicationContext(), new LicensingCallback());
  
  setupIAPOnCreate();
}

private void setupIAPOnCreate() {
  sampleIapManager = new SampleIapManager(this);

  final SamplePurchasingListener purchasingListener = new SamplePurchasingListener(sampleIapManager);
  Log.d(TAG, "onCreate：注册PurchasingListener");

  PurchasingService.registerListener(this.getApplicationContext(), purchasingListener);
  PurchasingService.enablePendingPurchases(); // 启用待定购买

  Log.d(TAG, "Appstore SDK模式: " + LicensingService.getAppstoreSDKMode()); // 检查应用是否处于测试模式
}

// ...
private String currentUserId = null;
private String currentMarketplace = null;

// ...

public void onUserDataResponse(final UserDataResponse response) {

  final UserDataResponse.RequestStatus status = response.getRequestStatus();

  switch (status) {
    case SUCCESSFUL:
      currentUserId = response.getUserData().getUserId();
      currentMarketplace = response.getUserData().getMarketplace();
      break;

   case FAILED:
      // 客户未在设备上登录亚马逊，或者
      // 应用和亚马逊应用商店之间存在连接问题。
      // 在此设备上暂时对用户禁用应用内购买，
      // 直到成功检索到有关用户和产品的详细信息。
      // 当getProductData方法成功检索到ProductData时，
      // 会重新启用购买。
      iapManager.disableAllPurchases();
      break;
   case NOT_SUPPORTED:
      // 设备不支持IAP功能。
      // 在此设备上对用户禁用应用内购买。
      iapManager.disableAllPurchases();
      break;
  }
}

@Override
protected void onResume() // 仅调用onResume中的getPurchaseUpdates
{
  super.onResume();

//...

  PurchasingService.getUserData();

//...

  PurchasingService.getPurchaseUpdates(false);
}

public class MyPurchasingListener implements PurchasingListener {
   boolean reset = false;
   //...

   public void onPurchaseUpdatesResponse(final PurchaseUpdatesResponse response) {
     //...
     // 处理收据
     switch (response.getRequestStatus()) {
       case SUCCESSFUL:
         for (final Receipt receipt : response.getReceipts()) {
           // 处理收据
         }
         if (response.hasMore()) {
           PurchasingService.getPurchaseUpdates(reset);
         }
         iapManager.refresh();
         break;
       case FAILED:
         // 如果存在用户数据，FAILED表示亚马逊应用商店端存在问题。
         // 请在一段时间后重试。
         // 对此设备暂时禁用应用内购买，
         // 直到成功检索到有关用户和产品的详细信息。
         // 当getProductData方法成功检索到ProductData时，会重新启用购买。
         iapManager.disableAllPurchases();
         break;
       case NOT_SUPPORTED:
         // 设备不支持IAP功能。
         // 对此设备禁用应用内购买。
         iapManager.disableAllPurchases();
     }
   }
   //...
}

public void onPurchaseUpdatesResponse(final PurchaseUpdatesResponse response) {
// ....
switch (status) {
case SUCCESSFUL:
	iapManager.setAmazonUserId(response.getUserData().getUserId(), response.getUserData().getMarketplace());
	for (final Receipt receipt : response.getReceipts()) {
		iapManager.handleReceipt(receipt, response.getUserData());
	}
	if (response.hasMore()) {
		PurchasingService.getPurchaseUpdates(false);
	}
	iapManager.refreshOranges();
	break;
}
// ...
}              

protected void onResume() // 仅在onResume中验证产品SKU
{
   super.onResume();

   // ...

   final Set <string>productSkus =  new HashSet<string>();
   productSkus.add( "com.amazon.example.iap.consumable" );
   productSkus.add( "com.amazon.example.iap.entitlement" );
   productSkus.add( "com.amazon.example.iap.subscription" );
   PurchasingService.getProductData(productSkus); // 触发PurchasingListener.onProductDataResponse()

   Log.v(TAG,  "正在通过亚马逊验证SKU" );
   }

public class MyPurchasingListener implements PurchasingListener {
   //  ...

   public void onProductDataResponse(final ProductDataResponse response) {
     switch (response.getRequestStatus()) {
       case SUCCESSFUL:
         for ( final String s : response.getUnavailableSkus()) {
           Log.v(TAG,  "不可用SKU：" + s);
         }
         // 客户无法购买SKU。
         // 禁用不可用SKU的购买。
         iapManager.disablePurchaseForSkus(response.getUnavailableSkus());
         // 启用所有可用SKU的购买
         iapManager.enablePurchaseForSkus(response.getProductData());
         iapManager.refresh();

         final Map <string,>products = response.getProductData();
         for (final String key : products.keySet()) {
           Product product = products.get(key);
           Log.v(TAG, String.format( "产品：%s\n 类型：%s\n SKU：%s\n 价格：%s\n 描述：%s\n" , product.getTitle(), product.getProductType(), product.getSku(), product.getPrice(), product.getDescription()));
         }
         break;

       case FAILED:
         Log.v(TAG,  "ProductDataRequestStatus: FAILED" );
         // 如果存在用户数据，FAILED表示亚马逊应用商店端存在问题。
         // 请在一段时间后重试。
         // 对此设备暂时禁用应用内购买，
         // 直到成功检索到有关用户和产品的详细信息。
         // 当getProductData方法成功检索到ProductData时，会重新启用购买。
         iapManager.disableAllPurchases();
         break;
       case NOT_SUPPORTED:
         // 设备不支持IAP功能。
         // 对此设备禁用应用内购买。
         iapManager.disableAllPurchases();
     }
   }

   //  ...
}

  public void onBuyOrangeClick(final View view) {
     final RequestId requestId = PurchasingService.purchase(MySku.ORANGE.getSku());
     Log.d(TAG, "onBuyOrangeClick: requestId (" + requestId + ")");
  }

public void onPurchaseResponse(final PurchaseResponse response) {
	switch (status) {
    // ...
    case SUCCESSFUL:
      final Receipt receipt = response.getReceipt();
      iapManager.setAmazonUserId(response.getUserData().getUserId(), response.getUserData().getMarketplace());
      Log.d(TAG, "onPurchaseResponse: receipt json:" + receipt.toJSON());
      iapManager.handlePurchase(receipt, response.getUserData());
      iapManager.refresh();
      break;
    case ALREADY_PURCHASED:
      // 客户已经拥有购买商品的有效权利。
      // 应用和亚马逊应用商店不同步。重新同步亚马逊应用商店中的所有购买。
      PurchasingService.getPurchaseUpdates(true);
      break;
    case INVALID_SKU:
      Log.d(TAG,
            "onPurchaseResponse：无效SKU！onProductDataResponse应已将购买按钮禁用。");
      final Set<String> unavailableSkus = new HashSet<String>();
      unavailableSkus.add(response.getReceipt().getSku());
      iapManager.disablePurchaseForSkus(unavailableSkus);
      break;
    case FAILED:
      // 客户在完成购买旅程之前退出
      Log.d(TAG, "onPurchaseResponse：失败，因此从本地储存中删除购买请求");
      iapManager.showPurchaseFailedMessage(response.getReceipt().getSku());
      break;
    case NOT_SUPPORTED:
      Log.d(TAG, "onPurchaseResponse：失败，因此从本地储存中删除购买请求");
      iapManager.showPurchaseFailedMessage(response.getReceipt().getSku());
      // 设备不支持IAP功能。
      // 对此设备禁用应用内购买。
      iapManager.disableAllPurchases();
      break;
	}
}

public void handlePurchase(final Receipt receipt, final UserData userData) {
    try {
        if (receipt.isCanceled()) {
            revokePurchase(receipt, userData);
        } else {
            // 亚马逊强烈建议您在服务器端验证收据
            if (!verifyReceiptFromYourService(receipt.getReceiptId(), userData)) {
                // 如果无法验证购买，
                // 请向客户显示相关的错误消息。
                mainActivity.showMessage("无法验证购买，请稍后重试。");
                return;
            }
            if (itemAlreadyPurcahsed(receipt, userData)) {
                    // 如果已经从其他商店购买商品，请调用
                    // 取消购买并向客户显示相关的错误消息。
                    cancelPurchase(receipt, userData);
                    return;
            }
            if (receiptAlreadyFulfilled(receipt.getReceiptId(), userData)) {
                // 如果之前已履行收据，请通知亚马逊
                // 应用商店收据被再次履行。
                PurchasingService.notifyFulfillment(receipt.getReceiptId(), FulfillmentResult.FULFILLED);
                return;
            }
            grantPurchase(receipt, userData);
        }
        return;
    } catch (final Throwable e) {
        mainActivity.showMessage("无法完成购买，请稍后重试。");
    }
}

private void grantConsumablePurchase(final Receipt receipt, final UserData userData) {
    try {
        // 此代码显示了一个基本的实现。在您的应用中，请确保您的
        // 逻辑是线程安全的、交易性的，并且稳健。

        // 在您的应用和服务器中创建购买信息，
        // 并向客户授予购买权限。
        createPurchase(receipt.getReceiptId(), userData.getUserId());
        final MySku mySku = MySku.fromSku(receipt.getSku(), userIapData.getAmazonMarketplace());
        // 验证SKU是否仍然适用。
        if (mySku == null) {
            Log.w(TAG, "收据中的SKU [" + receipt.getSku() + "]不再有效");
            // 如果SKU不再适用，请以
            // 状态UNAVAILABLE调用PurchasingService.notifyFulfillment。
            updatePurchaseStatus(receipt.getReceiptId(), null, PurchaseStatus.UNAVAILABLE);
            PurchasingService.notifyFulfillment(receipt.getReceiptId(), FulfillmentResult.UNAVAILABLE);
            return;
        }

        if (updatePurchaseStatus(receipt.getReceiptId(), PurchaseStatus.PAID, PurchaseStatus.FULFILLED)) {
            // 更新SQLite数据库中的购买状态成功。
            userIapData.setRemainingOranges(userIapData.getRemainingOranges() + 1);
            saveUserIapData();
            Log.i(TAG, "已成功将购买从PAID更新为FULFILLED，收据ID为：" + receipt.getReceiptId());
            // 将履行结果发送给亚马逊应用商店。亚马逊收到
            // 购买的履行结果后，亚马逊应用商店停止
            // 向应用发送购买收据的尝试。
            PurchasingService.notifyFulfillment(receipt.getReceiptId(), FulfillmentResult.FULFILLED);
        } else {
            // 更新SQLite数据库中的购买状态失败。
            // 状态已更改。
            // 这通常表示同一收据已由另一个
            // onPurchaseResponse或onPurchaseUpdatesResponse回调更新。
            // 此代码仅记录错误。
            Log.w(TAG, "未能将购买从PAID更新为FULFILLED，收据ID为：" + receipt.getReceiptId()
                       + "，状态已更改。");
        }

    } catch (final Throwable e) {
        // 如果由于任何原因应用无法履行购买，
        // 请在此处添加您自己的错误处理代码。
        // 在您下次调用PurchasingService.getPurchaseUpdates时，
        // 亚马逊会尝试再次发送消费品购买收据。
        Log.e(TAG, "未能授予消费品购买，错误为" + e.getMessage());
    }
}

private void cancelPurchase(final Receipt receipt, final UserData userData) {
  // 更新应用和服务器中的购买信息以确定
  // 客户是否有重复的购买尝试。
  // 使用UNAVAILABLE履行状态，
  // 通知亚马逊无法履行商品
   updatePurchaseStatus(receipt.getReceiptId(), null, PurchaseStatus.UNAVAILABLE);
   PurchasingService.notifyFulfillment(receipt.getReceiptId(), FulfillmentResult.UNAVAILABLE);
   return;
}