Firebase FireStore Query.get()未触发onCompleteListener问题求助

看起来你遇到了Firestore异步查询的典型问题，我来帮你拆解核心原因和修复方案：

核心问题：异步操作的时序错误 #

Firestore的get()方法是异步非阻塞的——当你调用它时，查询会在后台线程执行，主线程会直接继续往下走并返回你创建的jsonObject。这时候onComplete和onFailure回调还完全没执行，所以你返回的HashMap自然是空的。

另外你提到回调完全没触发，大概率是因为方法执行完毕后，当前上下文（比如Activity/Fragment实例）被销毁了，Firestore会自动取消未完成的任务，导致回调永远不会被调用。还有一种可能是Firestore安全规则限制了读取权限，但这种情况通常onFailure会触发，需要额外排查。

修复步骤 #

1. 先修正回调中的错误逻辑 #

在onComplete里，首先要判断任务是否成功，不然如果查询失败，调用task.getResult()会直接抛出异常：

@Override
public void onComplete(@NonNull Task<QuerySnapshot> task) {
    if (task.isSuccessful()) { // 先判断任务是否成功
        QuerySnapshot result = task.getResult();
        if (result.isEmpty()){
            jsonObject.put("isNull", "true");
            Log.d("TAG","DATA"+jsonObject.toString());
        } else{
            Log.d("TAG", "IN ON Complete - Found data");
            for (QueryDocumentSnapshot documentSnapshot: result){
                Map<String,Object> map = documentSnapshot.getData();
                jsonObject.put("isNull","false");
                jsonObject.put("LocationName", String.valueOf(map.get("place_name")));
                jsonObject.put("LocationAddress", String.valueOf(map.get("place_address")));
                Log.d("TAG","DATA"+jsonObject.toString());
            }
        }
    } else {
        // 处理任务失败的情况
        Log.d("TAG", "Task failed: " + task.getException().getMessage());
    }
}

2. 改用回调接口处理异步结果 #

Java不支持直接返回异步操作的结果，你需要定义一个自定义回调接口，让调用方在查询完成后获取结果：

第一步：定义回调接口

public interface MeetingPointCallback {
    void onResult(HashMap<String, String> result);
    void onError(Exception e);
}

第二步：修改方法，去掉返回值，接收回调参数

void doesMeetingPointExists(LatLng latLng, MeetingPointCallback callback) { 
    String lat = String.valueOf(latLng.getLatitude()); 
    String longi = String.valueOf(latLng.getLongitude()); 
    final HashMap<String,String> jsonObject = new HashMap<>(); 
    Query q = firebaseFirestore.collection("meeting_points")
            .whereEqualTo("latitude",lat)
            .whereEqualTo("longitude",longi); 
    q.get().addOnCompleteListener(new OnCompleteListener<QuerySnapshot>() { 
        @Override 
        public void onComplete(@NonNull Task<QuerySnapshot> task) { 
            if (task.isSuccessful()) {
                QuerySnapshot result = task.getResult();
                if (result.isEmpty()){
                    jsonObject.put("isNull", "true");
                    callback.onResult(jsonObject);
                } else{
                    for (QueryDocumentSnapshot documentSnapshot: result){
                        Map<String,Object> map = documentSnapshot.getData();
                        jsonObject.put("isNull","false");
                        jsonObject.put("LocationName", String.valueOf(map.get("place_name")));
                        jsonObject.put("LocationAddress", String.valueOf(map.get("place_address")));
                    }
                    callback.onResult(jsonObject);
                }
            } else {
                callback.onError(task.getException());
            }
        } 
    }).addOnFailureListener(new OnFailureListener() { 
        @Override 
        public void onFailure(@NonNull Exception e) { 
            Log.d("TAG", "Query failed: " + e.getMessage());
            callback.onError(e);
        } 
    }); 
}

第三步：调用方法时通过回调获取结果

doesMeetingPointExists(yourLatLng, new MeetingPointCallback() {
    @Override
    public void onResult(HashMap<String, String> result) {
        // 在这里处理查询结果，比如更新UI
        Log.d("TAG", "Final result: " + result.toString());
    }

    @Override
    public void onError(Exception e) {
        // 处理错误情况
        Timber.e("Error fetching meeting point: " + e.getMessage());
    }
});

3. 排查回调未触发的其他可能 #

• 检查Firestore安全规则：确保meeting_points集合允许当前用户读取，临时测试可设置规则为：

  rules_version = '2';
  service cloud.firestore {
    match /databases/{database}/documents {
      match /meeting_points/{document} {
        allow read, write: if true; // 仅测试用，上线后需替换为合适权限
      }
    }
  }
  

• 检查上下文生命周期：如果在Activity/Fragment中调用方法，要确保在组件销毁前（比如onDestroy）取消Firestore任务，避免在组件即将销毁时发起查询。可通过Task对象的cancel()方法取消任务。

额外建议 #

• 尽量避免用HashMap传递结果，建议创建专门的数据类（比如MeetingPoint）封装位置信息，提升代码可读性。
• 如果是Android项目，也可以使用LiveData观察异步结果，自动处理生命周期，避免内存泄漏。

内容的提问来源于stack exchange，提问作者Tirth Mehta