我正在尝试在 GCE 端点中验证由 Android 中的 Firebase 身份验证库创建的客户端 token 。

可以找到如何执行此操作的指南 here

基本上我需要从端点调用此代码 fragment (即服务器后端代码而不是 android 代码)。

FirebaseAuth.getInstance().verifyIdToken(idToken)
    .addOnSuccessListener(new OnSuccessListener<FirebaseToken>() {
        @Override
        public void onSuccess(FirebaseToken decodedToken) {
            String uid = decodedToken.getUid();
            // ...
        }
});

假设我想执行该代码并将用户返回到 android 客户端代码。我应该怎么做？

这是我的示例代码，没有任何意义。但它证明了我想做什么!

@ApiMethod(name = "serverAuth")
public MyUser serverAuth(@Named("token") String token) {
    FirebaseAuth.getInstance().verifyIdToken(token)
            .addOnSuccessListener(new OnSuccessListener<FirebaseToken>() {
                @Override
                public void onSuccess(FirebaseToken decodedToken) {
                    String uid = decodedToken.getUid();
                    String email = decodedToken.getEmail();
                    String name = decodedToken.getName();
                    Map<String, Object> claims = decodedToken.getClaims();

                    String claimString = "";

                    for (Object claim : claims.values()) {
                        claimString += claims.toString();
                    }

                    MyUser user = new MyUser(uid, email, name, claimString);
                    //How to return this user?

                }
            });

    //This is compile error since user varriable does not exist here    
    return user;

}

我用谷歌搜索如何在 GCE 端点中执行异步代码。但无处可去。我得到的是关于代码执行的一些东西，它在完成之前一直阻塞，然后返回给用户。但是如何编写代码才能使上述异步代码变得阻塞？

最佳答案

CountDownLatch 是您需要的魔法类。它会让您等到 OnSuccessListener 实际完成。

以这种方式调整您的方法:(我删除了导致创建 MyUser 的步骤，以便专注于重点。)

@ApiMethod(name = "serverAuth")
public MyUser serverAuth(@Named("token") String token) {
    final List<MyUser> users = new ArrayList<>();
    final CountDownLatch cdl = new CountDownLatch(1);
    FirebaseAuth.getInstance().verifyIdToken(token)
            .addOnSuccessListener(new OnSuccessListener<FirebaseToken>() {
                @Override
                public void onSuccess(FirebaseToken decodedToken) {
                    // ... init uid, email, name and claimString
                    users.add(new MyUser(uid, email, name, claimString));
                    cdl.countDown();
                }
            });
    try {
        cdl.await(); // This line blocks execution till count down latch is 0
    } catch (InterruptedException ie) {

    }
    if (users.size() > 0) {
        return users.get(0);
    } else {
        return null ;
    }
}

这是您需要的基本版本。恕我直言，它还需要 2 个改进:

• 您还应该考虑失败的可能性:

  FirebaseAuth.getInstance().verifyIdToken(token)
  .addOnSuccessListener(new OnSuccessListener<FirebaseToken>() {
      @Override
      public void onSuccess(FirebaseToken decodedToken) {
          cdl.countDown();
      }
  }).addOnFailureListener(new OnFailureListener() {
      @Override
      public void onFailure(@NonNull Exception e) {
          // log error, ...
          cdl.countDown();
      }
  });
  

• 您还应该考虑没有调用任何监听器的可能性。在这种情况下，您的方法将永远不会返回。为避免这种情况，您可以在 await() 方法上设置一个超时:

  try {
       // This line blocks execution till count down latch is 0
       // or after 30 seconds.
      cdl.await(30l, TimeUnit.SECONDS);
  } catch (InterruptedException ie) {
  
  }
  

就是这样。希望这可能有所帮助。

关于java - Google Cloud Endpoint 在端点中执行异步代码，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/40732961/