warten Sie, bis FB die Daten abruft

Ich bauen möchte, eine Methode, die zurückgibt einen child Wert in FireBase. Ich habe versucht, so etwas zu tun:

public String getMessage(){

    root.child("MessagesOnLaunch").child("Message").addListenerForSingleValueEvent(new ValueEventListener() {
        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            message = (String) dataSnapshot.getValue();
            Log.i("4r398", "work");
        }

        @Override
        public void onCancelled(FirebaseError firebaseError) {
            Log.e("error", firebaseError.getMessage());
        }
    });
    return message;
}

Das problem ist, dass die Methode gibt null das ist wahrscheinlich, weil die Methode nicht warten, bis der listener beendet und zurück null weil seine default-Wert von message.
Wie kann ich diese Methode warten, bis der Hörer tritt und dann den Rückgabewert.

übernehmen root gespeichert ist, auf die Klasse (und die Klasse ist nicht gc ' ed ist), es sollte keine Rolle spielen, dass die Funktion abgeschlossen ist
Sie können nicht synchron Rückkehr eine asynchrone Wert. Die message variable hier ist völlig sinnlos, da es nicht an der Zeit, die es gibt--man muss die Daten vom server abgerufenen ersten. Stattdessen getMessage() sollte entweder akzeptieren Sie einen Rückruf von einer Art oder ein Ereignis auslösen. Es ist eine Anleitung für diese Konzepte, chocked voll von Beispielen und Tipps.
mit dieser Antwort. Ich habe vor dem gleichen Problem und gelöst mit EventBus.

InformationsquelleAutor ben | 2015-06-05

Stellen eine Schnittstelle

 public interface OnGetDataListener {
    //this is for callbacks
    void onSuccess(DataSnapshot dataSnapshot);
    void onStart();
    void onFailure();
}

Erklären Sie die folgende Funktion readData()

public void readData(Firebase ref, final OnGetDataListener listener) {
    listener.onStart();
    ref.addListenerForSingleValueEvent(new ValueEventListener() {
        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            listener.onSuccess(dataSnapshot);
        }

        @Override
        public void onCancelled(FirebaseError firebaseError) {
            listener.onFailure();
        }
    });

}

Aufruf der readData () - Funktion wie folgt

readData(root.child("MessagesOnLaunch").child("Message"), new OnGetDataListener() {
                @Override
                public void onSuccess(DataSnapshot dataSnapshot) {

               //got data from database....now you can use the retrieved data


                }
                @Override
                public void onStart() {
                    //when starting
                    Log.d("ONSTART", "Started");
                }

                @Override
                public void onFailure() {
                    Log.d("onFailure", "Failed");
                }
            });

readData() aufgerufen werden kann, in Ihrem getMessage () - Methode oder auch innerhalb von onCreate()

Ich folgte diesen Anweisungen, um den Punkt, und ich bin immer noch erleben exakt das gleiche Problem wie OP. Ich verstehe nicht, wie soll ich meinen code zu strukturieren, so dass ich in der Lage bin, die Verwendung der Daten in der FB-Datenbank

InformationsquelleAutor Joseph Varghese

6

Können Sie CountDownLatch.
Dies ist, wie Sie es verwenden können.
```
public String getMessage(){
   CountDownLatch done = new CountDownLatch(1);
   final String message[] = {null}; 
   root.child("MessagesOnLaunch").child("Message").addListenerForSingleValueEvent(new ValueEventListener() {

    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        message[0] = (String) dataSnapshot.getValue();
        System.out.println("worked");
        done.countDown();
    }

    @Override
    public void onCancelled(FirebaseError firebaseError) {
        System.out.println("failed"+firebaseError.getMessage());
    }
});

try {
    done.await(); //it will wait till the response is received from firebase.
} catch(InterruptedException e) {
    e.printStackTrace();
}
return message[0];
}
```
- Dies ist ein großartiger Weg, um zu lösen das warten auf die Antwort
- message ist nicht deklariert. Wenn Sie erklären message am Anfang der Funktion als String message = null es hat erklärt zu werden final zu oder es wird nicht kompilieren. Und dann ist da seine endgültige kannst du nicht updaten message mehr innerhalb onDataChange. Das ist so frustrierend. Fast keine Möglichkeit zum abrufen von Daten aus onDataChange zur Außenwelt in einem sauberen Stück code.
- Fantastischer Weg, um dies zu tun! @Zod Verwenden Sie eine endgültige AtomicReference-oder array-wrapper-g/Satz der Meldung
- Man könnte auch hinzufügen public synchronized String getMessage() zu der Signatur der Methode, um sicherzustellen, dass nur ein thread ist ein Aufruf dieser Methode zu einem Zeitpunkt. Ohne empirische Tests bewiesen, ich war immer die falsche message zurückgegeben etwa 10% der Zeit, die beim ausführen dieser Methode parallel (z.B. zwei oder mehr Anfragen kommen in dein servlet in der gleichen Zeit, so dass zwei threads den Aufruf dieser Methode in der gleichen Zeit).
- hier habe ich verpasst-das "message" - variable, das ist verwirrend für den Anwender auf der Suche nach Antworten. @NathanAdams korrekt ist. Ich werde Bearbeiten Sie die Antwort. Nathan Dank für die Klarstellung.
InformationsquelleAutor Tirupati Singh
3

Nicht nutzen FB als Funktionen, die Werte zurückgeben - es geht gegen den asynchronen Charakter.

Plan code-Struktur, mit der FB für die Durchführung der Aufgabe, und dann in den Verschluss (blockieren), gehen Sie zum nächsten Schritt.

In deinem code, zum Beispiel, ändern Sie die Funktion nicht etwas zurückzugeben-und in der onDataChange, wie die Letzte Zeile Aufruf der nächsten Funktion zum aktualisieren der Benutzeroberfläche.
- Das ist alles schön und gut, aber im rest der Java-Welt, die wir verwenden, servlets und RestTemplates, die synchron sind. Google wirft in einem asynchronen Bibliothek wirklich die Dinge verkompliziert.
- ja, möglich ist es nützlich, nur für android-Einsatz nur
InformationsquelleAutor Vladyslav Ulianytskyi

Als @CMikeB1 kommentiert eine andere Antwort in der java-Welt, wenn wir den Umgang mit servlets und Dienstleistungen, die Ruhe, die wir verwenden, synchronisieren Aufrufe von Operationen durchführen, wäre es sinnvoll, beide Optionen im sdk FB-admin, so daß der Entwickler wählen, welche zu benutzen ist abhängig von seinem Fall verwenden.

Machte ich meine Umsetzung warten muss, Lesen Sie die sync-Daten mit ApiFuture, die die aktuelle Schnittstelle, verabschiedet von der sdk an die FB-admin. hier ist ein link!

public DataSnapshot getMessage() {
    final SettableApiFuture<DataSnapshot> future = SettableApiFuture.create();
    databaseReference.child("MessagesOnLaunch").child("Message").addListenerForSingleValueEvent(new ValueEventListener() {
        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            future.set(dataSnapshot);
        }

        @Override
        public void onCancelled(DatabaseError databaseError) {
            future.setException(databaseError.toException());
        }
    });
    try {
        return future.get();
    } catch(InterruptedException | ExecutionException e) {
        e.printStackTrace();
        return null;
    }
}

InformationsquelleAutor Pedro Bacchini

Überlasse ich dies hier, um jedem zu helfen, der Gesichter das gleiche problem wie ich. @Tirupati Singh code sieht nett aus, aber ich schrieb meine Antwort unten sein, warum es für mich nicht funktioniert. Mit Atomarer Typ gearbeitet -

public AtomicInteger getMessage(){
        final AtomicBoolean done = new AtomicBoolean(false);
        final AtomicInteger message1 = new AtomicInteger(0);

        //assuming you have already called firebase initialization code for admin sdk, android etc
       DatabaseReference root = FirebaseDatabase.getInstance().getReference("server");
       root.child("MessagesOnLaunch").child("Message").addListenerForSingleValueEvent(new ValueEventListener() {

        public void onDataChange(DataSnapshot dataSnapshot) {
            message1.set((Integer) dataSnapshot.getValue()); 
            done.set(true);
        }

        public void onCancelled(DatabaseError error) {
            //TODO Auto-generated method stub

        }
    });
    while (!done.get());

    return message1;
}

Hinweis: die Funktion kann nur durch die return-message Typ Integer. Ich konnte nicht get it to work for String als keine Atomaren Typ String. Hoffe, das hilft!

InformationsquelleAutor Zod

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.