本教程详细介绍了如何在android应用中，利用google play billing library的querypurchasesasync()方法，可靠地检查用户的订阅状态。我们将探讨为何仅依靠purchasesupdatedlistener不足以全面管理订阅，并提供一套完整的实现方案，包括初始化、查询逻辑、结果处理以及关键的订阅确认机制，确保应用能准确判断用户是否拥有有效订阅。
在开发Android应用程序时，集成应用内购买（In-App Billing）功能，特别是订阅服务，是常见的需求。然而，确保应用能够准确识别用户是否拥有有效订阅，并在应用启动时进行验证，是实现可靠订阅管理的关键挑战之一。本教程将深入探讨如何利用Google Play Billing Library来解决这一问题。
Google Play Billing Library提供了PurchasesUpdatedListener来监听新的购买事件。当用户成功完成购买流程或取消支付时，此监听器会收到回调。然而，仅依靠此监听器不足以在应用启动时或任何需要时检查用户当前的订阅状态。PurchasesUpdatedListener主要用于处理新发生的购买事件，而不是查询已存在的有效订阅。
为了在应用启动时或任何需要时获取用户当前的订阅列表，我们需要主动查询Google Play商店，获取用户已购买且未过期的所有订阅。
Google Play Billing Library提供了queryPurchasesAsync()方法，用于异步查询用户已拥有的所有有效购买。这是检查用户订阅状态的核心方法。
在调用任何Billing Library方法之前，必须确保BillingClient已正确初始化并连接到Google Play服务。这通常在应用的onCreate()方法或相关的生命周期方法中完成。
public class MainActivity extends AppCompatActivity {
private BillingClient billingClient;
private static final String SUBSCRIPTION_SKU = "your_subscription_id"; // 替换为你的订阅商品ID
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
setupBillingClient();
}
private void setupBillingClient() {
billingClient = BillingClient.newBuilder(this)
.setListener(purchasesUpdatedListener) // 仍然需要监听新的购买事件
.enablePendingPurchases()
.build();
billingClient.startConnection(new BillingClientStateListener() {
@Override
public void onBillingSetupFinished(@NonNull BillingResult billingResult) {
if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.OK) {
// BillingClient已连接，可以查询购买信息
Log.d("BillingClient", "Billing setup finished successfully.");
checkSubscriptionStatus(); // 连接成功后立即检查订阅状态
} else {
Log.e("BillingClient", "Billing setup failed: " + billingResult.getDebugMessage());
}
}
@Override
public void onBillingServiceDisconnected() {
// 尝试重新连接
Log.w("BillingClient", "Billing service disconnected. Trying to reconnect...");
setupBillingClient();
}
});
}
// ... 其他代码 ...
}一旦BillingClient连接成功，就可以调用queryPurchasesAsync()来查询订阅。
private void checkSubscriptionStatus() {
if (billingClient.isReady()) {
billingClient.queryPurchasesAsync(BillingClient.SkuType.SUBS, (billingResult, purchasesList) -> {
if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.OK) {
boolean hasActiveSubscription = false;
for (Purchase purchase : purchasesList) {
// 检查购买状态是否为已购买且已确认
if (purchase.getPurchaseState() == Purchase.PurchaseState.PURCHASED && purchase.isAcknowledged()) {
// 进一步验证 SKU 是否为我们期望的订阅商品
// 注意：在Billing Library 5.0.0及更高版本中，getSku()已废弃，应使用getSkus()
if (purchase.getSkus().contains(SUBSCRIPTION_SKU)) {
hasActiveSubscription = true;
Log.d("SubscriptionCheck", "Active subscription found: " + purchase.getSkus());
// 更新应用UI或内部状态
updateSubscriptionUI(true);
break; // 找到一个有效订阅即可
}
} else if (purchase.getPurchaseState() == Purchase.PurchaseState.PENDING) {
Log.d("SubscriptionCheck", "Pending purchase found for SKU: " + purchase.getSkus());
// 处理待处理的购买，可能需要用户完成支付流程
} else if (purchase.getPurchaseState() == Purchase.PurchaseState.UNSPECIFIED_STATE) {
Log.d("SubscriptionCheck", "Unspecified state purchase found for SKU: " + purchase.getSkus());
// 可能是旧的购买，或者需要额外处理
}
// 对于未确认的购买，需要进行确认操作
if (purchase.getPurchaseState() == Purchase.PurchaseState.PURCHASED && !purchase.isAcknowledged()) {
acknowledgePurchase(purchase);
}
}
if (!hasActiveSubscription) {
Log.d("SubscriptionCheck", "No active subscription found.");
updateSubscriptionUI(false);
}
} else {
Log.e("SubscriptionCheck", "Error querying purchases: " + billingResult.getDebugMessage());
}
});
} else {
Log.w("SubscriptionCheck", "BillingClient is not ready. Cannot query purchases.");
// 可以尝试重新连接或等待连接成功
}
}Google Play要求所有购买（包括订阅）都必须在用户购买后的三天内进行确认。对于订阅，一旦确认，其状态将变为isAcknowledged = true。如果未在规定时间内确认，Google Play将自动退款给用户并撤销购买。
重要提示： 订阅产品不能被“消耗”（consume）。消耗操作仅适用于一次性商品。对于订阅，我们应该使用acknowledgePurchaseAsync()进行确认。
由于微信的大热，为了更好的方便使用微信的用户查询一些信息，这篇文章是入门级的微信公众平台开发教程，需要的朋友可以参考下 这篇入门教程将引导你完成如下任务： 创建百度云平台应用启用微信公众平台开发模式获取订阅、文字、图片、语音、视频消息回复文本、图文及音乐消息程序开发
1
// 这是用于处理新购买的监听器，当有新购买发生时会回调
private PurchasesUpdatedListener purchasesUpdatedListener = (billingResult, purchases) -> {
if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.OK && purchases != null) {
for (Purchase purchase : purchases) {
// 处理新购买，并进行确认
handleNewPurchase(purchase);
}
} else if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.USER_CANCELED) {
Log.d("PurchasesUpdated", "User canceled the purchase flow.");
// 更新UI或状态，表示用户取消
updateSubscriptionUI(false);
} else {
Log.e("PurchasesUpdated", "Error during purchase update: " + billingResult.getDebugMessage());
// 处理其他错误
updateSubscriptionUI(false);
}
};
// 处理新购买并进行确认
private void handleNewPurchase(Purchase purchase) {
if (purchase.getPurchaseState() == Purchase.PurchaseState.PURCHASED) {
if (!purchase.isAcknowledged()) {
acknowledgePurchase(purchase);
} else {
// 购买已确认，更新UI或状态
Log.d("PurchaseHandler", "Purchase already acknowledged: " + purchase.getSkus());
if (purchase.getSkus().contains(SUBSCRIPTION_SKU)) {
updateSubscriptionUI(true);
}
}
} else if (purchase.getPurchaseState() == Purchase.PurchaseState.PENDING) {
Log.d("PurchaseHandler", "Purchase is pending: " + purchase.getSkus());
// 可以在这里显示一个加载或待处理的UI
}
}
// 确认购买的方法
private void acknowledgePurchase(Purchase purchase) {
AcknowledgePurchaseParams acknowledgePurchaseParams =
AcknowledgePurchaseParams.newBuilder()
.setPurchaseToken(purchase.getPurchaseToken())
.build();
billingClient.acknowledgePurchase(acknowledgePurchaseParams, billingResult -> {
if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.OK) {
Log.d("AcknowledgePurchase", "Purchase acknowledged successfully: " + purchase.getSkus());
// 确认成功后，再次检查订阅状态或直接更新UI
if (purchase.getSkus().contains(SUBSCRIPTION_SKU)) {
updateSubscriptionUI(true);
}
} else {
Log.e("AcknowledgePurchase", "Error acknowledging purchase: " + billingResult.getDebugMessage());
}
});
}
// 示例：更新UI的方法
private void updateSubscriptionUI(boolean hasSubscription) {
// 根据hasSubscription的值更新UI，例如显示/隐藏高级功能
Log.d("SubscriptionUI", "User has subscription: " + hasSubscription);
// 假设 Constant.subscription 是一个全局状态变量
// Constant.subscription = hasSubscription;
// findViewById(R.id.premium_feature_button).setEnabled(hasSubscription);
}何时检查订阅状态：
服务器端验证： 为了最高级别的安全性和可靠性，强烈建议在服务器端验证购买。客户端查询到的购买信息可能被篡改。将purchaseToken发送到您的后端服务器，并使用Google Play Developer API进行验证。服务器端验证可以确保订阅的真实性，并处理订阅状态的复杂逻辑（如续订、降级、升级、暂停等）。
错误处理： 始终处理BillingResult中的错误码。例如，网络问题可能导致SERVICE_DISCONNECTED，需要实现重试逻辑。
商品ID管理： 将订阅商品的SKU（SUBSCRIPTION_SKU）定义为常量，避免硬编码。
处理多种订阅： 如果您的应用有多个订阅产品，queryPurchasesAsync()返回的purchasesList可能包含所有有效订阅。您需要根据SKU来识别具体是哪个订阅。
UI反馈： 在进行购买或查询操作时，提供适当的加载指示或错误消息，以提升用户体验。
通过结合BillingClient的初始化、queryPurchasesAsync()的主动查询以及acknowledgePurchaseAsync()的确认机制，您可以构建一个健壮的Android应用内订阅管理系统。记住，PurchasesUpdatedListener用于响应新购买，而queryPurchasesAsync()则用于获取当前所有有效的订阅。为了确保数据的完整性和安全性，强烈推荐将服务器端验证作为您订阅管理策略的一部分。
以上就是Android应用中用户订阅状态的可靠检查教程的详细内容，更多请关注php中文网其它相关文章！
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。
广告Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
538
收藏
