Java-сервер с использованием Firebase Admin SDK Асинхронные слушатели - PullRequest
Новая
       20

Java-сервер с использованием Firebase Admin SDK Асинхронные слушатели

0 голосов
/ 24 октября 2018

Я использую Firebase java admin skd для замены механизма Websocket на стороне сервера.Это мой код: 

public class HelloWorld {
public static void main (String[] args) throws  IOException {
    FileInputStream serviceAccount =
            new FileInputStream("/Users/d/firebase-adminsdk.json");
    FirebaseOptions options = new FirebaseOptions.Builder()
            .setCredentials(GoogleCredentials.fromStream(serviceAccount))
            .setDatabaseUrl("https://alien-program-209719.firebaseio.com")
            .build();
    FirebaseApp.initializeApp(options);

    final FirebaseDatabase database = FirebaseDatabase.getInstance();
    DatabaseReference ref = database.getReference("/Call/1");

    ref.addChildEventListener(new ChildEventListener() {
        @Override
        public void onChildAdded(DataSnapshot dataSnapshot, String prevChildKey) {
            System.out.println("this is the result" + dataSnapshot.getValue());
        }
        @Override
        public void onChildChanged(DataSnapshot dataSnapshot, String prevChildKey) {}
        @Override
        public void onChildRemoved(DataSnapshot dataSnapshot) {}

        @Override
        public void onChildMoved(DataSnapshot dataSnapshot, String prevChildKey) {}

        @Override
        public void onCancelled(DatabaseError databaseError) {
            System.out.println("The read failed: " + databaseError.getCode());
        }
    });
}

}

Мой вопрос заключается в том, как запустить мой код в качестве сервера.Итак, идея здесь в том, что я хочу использовать метод "onChildAdded" для прослушивания любого элемента, который будет добавлен в путь к моей базе данных / Call / 1.Итак, как мне это сделать?Спасибо заранее.

...