public List getContactsFromFirebase(){ FirebaseDatabase.getInstance().getReference().child(“Users”) .addListenerForSingleValueEvent(new ValueEventListener() { @Override public void onDataChange(DataSnapshot dataSnapshot) { for (DataSnapshot snapshot : dataSnapshot.getChildren()) { Users user = snapshot.getValue(Users.class); assert user != null; String contact_found = user.getPhone_number(); mContactsFromFirebase.add(contact_found); Log.i(“Test”, mContactsFromFirebase.toString()); }
} @Override public void onCancelled(DatabaseError databaseError) { } }); return mContactsFromFirebase; }
我似乎找不到错误。在上面的代码中,当我调用日志时,我从中获取值mContactsFromFirebase,但是该getContactsFromFirebase()方法返回一个空列表。请问你能帮帮我吗?
mContactsFromFirebase
getContactsFromFirebase()
从Firebase异步加载数据。由于从服务器获取数据可能需要一些时间,因此主要的Android代码会继续,并且Firebase onDataChange在数据可用时会调用您。
onDataChange
这意味着到您return mContactsFromFirebase那时它仍然是空的。看到此问题的最简单方法是放置一些日志语句:
return mContactsFromFirebase
System.out.println("Before attaching listener"); FirebaseDatabase.getInstance().getReference().child("Users") .addListenerForSingleValueEvent(new ValueEventListener() { @Override public void onDataChange(DataSnapshot dataSnapshot) { System.out.println("In onDataChange"); } @Override public void onCancelled(DatabaseError databaseError) { throw databaseError.toException(); // don't ignore errors } }); System.out.println("After attaching listener");
运行此代码时,它将打印:
附加监听器之前 附加监听器后 在onDataChange中
附加监听器之前
附加监听器后
在onDataChange中
这可能不是你预计的输出顺序。正如你可以看到线 后 回调函数被调用之前onDataChange。这就解释了为什么您返回的列表为空,或者(更正确地说)为什么返回时列表为空,并且仅在以后填充。
有几种方法可以处理这种异步加载。
最简单的解释是把返回列表中的所有代码 到 的onDataChange方法。这意味着该代码仅在数据加载后执行。最简单的形式:
public void onDataChange(DataSnapshot dataSnapshot) { for (DataSnapshot snapshot : dataSnapshot.getChildren()) { Users user = snapshot.getValue(Users.class); assert user != null; String contact_found = user.getPhone_number(); mContactsFromFirebase.add(contact_found); System.out.println("Loaded "+mContactsFromFirebase.size()+" contacts"); } }
但是还有更多方法,包括使用自定义回调(类似于Firebase自己的ValueEventListener):
ValueEventListener
Java :
public interface UserListCallback { void onCallback(List<Users> value); }
Kotlin :
interface UserListCallback { fun onCallback(value:List<Users>) }
现在,您可以将此接口的实现传递给您的getContactsFromFirebase方法:
getContactsFromFirebase
public void getContactsFromFirebase(final UserListCallback myCallback) { databaseReference.child(String.format("users/%s/name", uid)).addListenerForSingleValueEvent(new ValueEventListener() { @Override public void onDataChange(DataSnapshot dataSnapshot) { for (DataSnapshot snapshot : dataSnapshot.getChildren()) { Users user = snapshot.getValue(Users.class); assert user != null; String contact_found = user.getPhone_number(); mContactsFromFirebase.add(contact_found); System.out.println("Loaded "+mContactsFromFirebase.size()+" contacts"); } myCallback.onCallback(mContactsFromFirebase); } @Override public void onCancelled(DatabaseError databaseError) { throw databaseError.toException(); } }); }
fun getContactsFromFirebase(myCallback:UserListCallback) { databaseReference.child(String.format("users/%s/name", uid)).addListenerForSingleValueEvent(object:ValueEventListener() { fun onDataChange(dataSnapshot:DataSnapshot) { for (snapshot in dataSnapshot.getChildren()) { val user = snapshot.getValue(Users::class.java) assert(user != null) val contact_found = user.getPhone_number() mContactsFromFirebase.add(contact_found) System.out.println("Loaded " + mContactsFromFirebase.size() + " contacts") } myCallback.onCallback(mContactsFromFirebase) } fun onCancelled(databaseError:DatabaseError) { throw databaseError.toException() } })
然后这样称呼它:
getContactsFromFirebase(new UserListCallback() { @Override public void onCallback(List<Users> users) { System.out.println("Loaded "+users.size()+" contacts") } });
getContactsFromFirebase(object:UserListCallback() { fun onCallback(users:List<Users>) { System.out.println("Loaded " + users.size() + " contacts") } })
它不像同步加载数据时那样简单,但是它的优点是运行时不会阻塞主线程。