Verileri Firebase'den eşzamanlı olarak yüklemek mümkün mü?

Question

Android uygulamamda bir WebView'un parçalarını Firebase üzerinden bağlanan bir eşden aldığım verilerle güncellemeye çalışıyorum. Bunun için gerekli verileri geri getirecek engelleme işlemlerini yürütmek yararlı olabilir. Örneğin, başka bir sohbet katılımcısının push.setValue() öğesinden önce bir şey yazmasını bekleyecek olan Sohbet örneğinin uygulanması. Firebase ile böyle bir davranış mümkün mü?

Answer 1

Düzenli bir JVM'de, bunu düzenli Java senkronizasyon ilkelleriyle gerçekleştirirsiniz. Örneğin

:

// create a java.util.concurrent.Semaphore with 0 initial permits 
final Semaphore semaphore = new Semaphore(0); 

// attach a value listener to a Firebase reference 
ref.addValueEventListener(new ValueEventListener() { 
    // onDataChange will execute when the current value loaded and whenever it changes 
    @Override 
    public void onDataChange(DataSnapshot dataSnapshot) { 
     // TODO: do whatever you need to do with the dataSnapshot 

     // tell the caller that we're done 
     semaphore.release(); 
    } 

    @Override 
    public void onCancelled(FirebaseError firebaseError) { 

    } 
}); 

// wait until the onDataChange callback has released the semaphore 
semaphore.acquire(); 

// send our response message 
ref.push().setValue("Oh really? Here is what I think of that"); 

Ama bu Android'de çalışmayacaktır. Ve bu iyi bir şey, çünkü bu tür bir engelleme yaklaşımını kullanıcı arayüzünü etkileyen herhangi bir şeyde kullanmak kötü bir fikir. Bu kodun etrafta yatan tek sebebi, bir birim testinde ihtiyacım olduğu için.

Gerçek kullanıcılara yönelik kodda, olay odaklı bir yaklaşıma gitmelisiniz.

// attach a value listener to a Firebase reference 
ref.addValueEventListener(new ValueEventListener() { 
    // onDataChange will execute when the current value loaded and whenever it changes 
    @Override 
    public void onDataChange(DataSnapshot dataSnapshot) { 
     // TODO: do whatever you need to do with the dataSnapshot 

     // send our response message 
     ref.push().setValue("Oh really? Here is what I think of that!"); 
    } 

    @Override 
    public void onCancelled(FirebaseError firebaseError) { 

    } 
}); 

net sonuç tam olarak aynıdır, ancak bu kodu: Yani "veri gelip sonra benim mesaj göndermek için beklemek" yerine, ben "verileri geldiğinde, benim mesaj göndermek edeceğini" senkronizasyon gerektirmez ve Android'de engellenmez. Paket com.google.android.gms.tasks adresindeki

Answer 2

;

Tasks.await (taskFromFirebase);

Answer 3

Veri eşzamanlı olarak başka bir veri alma yöntemi ile geldim. Ön koşul, kullanıcı arabiriminde olmamalıdır.

final TaskCompletionSource<List<Objects>> tcs = new TaskCompletionSource<>(); 

firebaseDatabase.getReference().child("objects").addListenerForSingleValueEvent(new ValueEventListener() { 

      @Override 
      public void onDataChange(DataSnapshot dataSnapshot) { 
       Mapper<DataSnapshot, List<Object>> mapper = new SnapshotToObjects(); 
       tcs.setResult(mapper.map(dataSnapshot)); 
      } 

      @Override 
      public void onCancelled(DatabaseError databaseError) { 
       tcs.setException(databaseError.toException()); 
      } 

     }); 

Task<List<Object>> t = tcs.getTask(); 

try { 
    Tasks.await(t); 
} catch (ExecutionException | InterruptedException e) { 
    t = Tasks.forException(e); 
} 

if(t.isSuccessful()) { 
    List<Object> result = t.getResult(); 
} 

Çözümü test ettim ve iyi çalışıyor, ama lütfen yanlış olduğumu kanıtlayın!