使用Java从Firebase抓取数据

Question

我在下面的这段代码中遇到了问题，该代码几乎逐字从Firebase SDK
Java文档复制而来。我是真正的语言（例如Java）的新手，它来自PHP和JavaScript的webdev背景。

基本上，addListenerForSingleValueEvent不会触发以向我返回数据。我注意到这是因为系统打印输出不会触发，因此我认为监听事件没有触发。

我怀疑这与我有限的知识有关，函数本身是如何工作的，就像我缺少有关类和函数如何交互的结构知识一样。

任何帮助，将不胜感激，谢谢。

class FireBase {
public static void main(String[] args) throws IOException {
    // Fetch the service account key JSON file contents
    FileInputStream serviceAccount = new FileInputStream("key.json");

    // Initialize the app with a service account, granting admin privileges
    FirebaseOptions options = new FirebaseOptions.Builder()
        .setCredential(FirebaseCredentials.fromCertificate(serviceAccount))
        .setDatabaseUrl("https://ssworks-adwords.firebaseio.com/")
        .build();
    FirebaseApp.initializeApp(options);

    // As an admin, the app has access to read and write all data, regardless of Security Rules
    DatabaseReference ref = FirebaseDatabase
        .getInstance()
        .getReference("petitions");
    ref.addListenerForSingleValueEvent(new ValueEventListener() {
        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            System.out.println("Before Get Value");
            Object document = dataSnapshot.getValue();
            System.out.println(document);
        }

        @Override
        public void onCancelled(DatabaseError arg0) {
            // TODO Auto-generated method stub
            System.out.println("This didn't work");
        }
    });
}

}

Answer 1

如果您有通过某个类的main函数在命令行上调用的java程序，则必须阻止该main函数在数据库侦听器启动之前返回。否则，程序将立即终止，并且监听器将永远不会触发。重要的是要记住，所有Firebase侦听器都是异步的，并且Firebase管理其自己的守护程序线程以与服务器进行通信。

对于使一个简单的程序等待侦听器触发的情况，可以使用这种模式来阻止主线程等待侦听器：

CountDownLatch latch = new CountDownLatch(1);
ref.addListenerForSingleValueEvent(new ValueEventListener() {
    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        System.out.println("onDataChange: " + dataSnapshot);
        latch.countDown();
    }

    @Override
    public void onCancelled(DatabaseError databaseError) {
        System.out.println("onCanceled: " + databaseError);
        latch.countDown();
    }
});
latch.await();

使用CountDownLatch不是唯一的选择。您可以执行任何您要确保进程不停止的操作，包括简单地将主线程休眠的时间长于侦听器触发的时间。