Uygulamanız ağı geçici olarak kaybetse bile Firebase uygulamaları çalışır bağlantı. Firebase, verilerin yerel olarak kalıcı hale getirilmesini sağlayan araçlar sunar. ve gecikmenin üstesinden gelebilirsiniz.
Disk Kalıcılığı
Firebase uygulamaları, geçici ağ kesintilerini otomatik olarak ele alır. Önbelleğe alınan veriler çevrimdışıyken kullanılabilir ve Firebase tüm yazma işlemlerini yeniden gönderir ağ bağlantısı geri geldiğinde.
Disk kalıcılığını etkinleştirdiğinizde, uygulamanız verileri yerel olarak Böylece kullanıcı, cihazı kullansa bile çevrimdışıyken bile uygulamanızın durumunu koruyabilir. veya işletim sistemi uygulamayı yeniden başlatır.
Disk kalıcılığını yalnızca bir satır kodla etkinleştirebilirsiniz.
Kotlin+KTX
Firebase.database.setPersistenceEnabled(true)
Java
FirebaseDatabase.getInstance().setPersistenceEnabled(true);
Kalıcı Davranış
Kalıcılığı etkinleştirerek Firebase Realtime Database istemcisinin depoladığı tüm veriler çevrimiçi olduğunda diskte kalır ve çevrimdışı kullanılabilir, Kullanıcı veya işletim sistemi uygulamayı yeniden başlatsa bile. Bu, uygulama, önbellekte depolanan yerel verileri kullanarak çevrimiçi olarak da çalışır. Yerel güncellemeler için dinleyici geri çağırmaları tetiklenmeye devam eder.
Firebase Realtime Database istemcisi otomatik olarak tüm uygulamanız çevrimdışıyken gerçekleştirilen yazma işlemleri. Kalıcılık etkinleştirildiğinde bu sıra, diskte de tutulur. Böylece tüm kullanıcı veya işletim sistemi tarafından kullanılabilir ve uygulamayı yeniden başlatır. Uygulama tekrar internete bağlandığında, işlemler Firebase Realtime Database sunucusuna gönderilir.
Uygulamanızda Firebase Authentication, Firebase Realtime Database istemcisi, kullanıcının kimlik doğrulamasını sürdürür uygulama yeniden başlatmalarında ne kadar jeton kullanıldığını gösterir. Uygulamanız çevrimdışıyken kimlik doğrulama jetonunun süresi dolarsa istemci duraklar uygulamanız, kullanıcının kimliğini yeniden doğrulayana kadar yazma işlemleri, aksi halde yazma işlemleri güvenlik kuralları nedeniyle başarısız olabilir.
Verileri güncel tutma
Firebase Realtime Database, farklı veri türlerinden bahsettik. Ayrıca, belirli konumları senkronize edilir.
Kotlin+KTX
val scoresRef = Firebase.database.getReference("scores") scoresRef.keepSynced(true)
Java
DatabaseReference scoresRef = FirebaseDatabase.getInstance().getReference("scores"); scoresRef.keepSynced(true);
Firebase Realtime Database istemcisi, verileri şu saatte otomatik olarak indirir: bu konumları senkronize eder ve referansta size yardımcı olur. Senkronizasyonu kapatabilirsiniz: sonraki kod satırını kullanın.
Kotlin+KTX
scoresRef.keepSynced(false)
Java
scoresRef.keepSynced(false);
Varsayılan olarak, önceden senkronize edilmiş 10 MB'lık veri ön belleğe alınır. Bu özellik, çoğu uygulama için yeterli olur. Önbellek, yapılandırılmış boyutuna sığmazsa Firebase Realtime Database, en kısa süre önce kullanılan verileri tamamen siler. Senkronize edilen veriler önbellekten silinmez.
Çevrimdışı Verileri Sorgulama
Firebase Realtime Database, bir sorgudan döndürülen verileri kullanım amacıyla depolar çevrimdışıyken de kullanılabilir. Çevrimdışıyken oluşturulan sorgular için Firebase Realtime Database, önceden yüklenmiş veriler için çalışmaya devam eder. İstenen veriler yüklenmediyse Firebase Realtime Database yüklenir yerel önbellekteki verileri içerebilir. Ağ bağlantısı tekrar kullanılabilir olduğunda, veriler yüklenir ve sorguyu yansıtır.
Örneğin, bu kod her Firebase Realtime Database puanda dört öğe
Kotlin+KTX
val scoresRef = Firebase.database.getReference("scores") scoresRef.orderByValue().limitToLast(4).addChildEventListener(object : ChildEventListener { override fun onChildAdded(snapshot: DataSnapshot, previousChild: String?) { Log.d(TAG, "The ${snapshot.key} dinosaur's score is ${snapshot.value}") } // ... })
Java
DatabaseReference scoresRef = FirebaseDatabase.getInstance().getReference("scores"); scoresRef.orderByValue().limitToLast(4).addChildEventListener(new ChildEventListener() { @Override public void onChildAdded(@NonNull DataSnapshot snapshot, String previousChild) { Log.d(TAG, "The " + snapshot.getKey() + " dinosaur's score is " + snapshot.getValue()); } // ... });
Kullanıcının bağlantısını kestiğini, çevrimdışı olduğunu ve uygulamayı yeniden başlattığını varsayın. Çevrimdışıyken uygulama, sayfadaki son iki öğeyi sorgular aynı konum. Bu sorgu son iki öğeyi başarıyla döndürecek çünkü uygulama yukarıdaki sorgudaki dört öğenin tümünü yüklemişti.
Kotlin+KTX
scoresRef.orderByValue().limitToLast(2).addChildEventListener(object : ChildEventListener { override fun onChildAdded(snapshot: DataSnapshot, previousChild: String?) { Log.d(TAG, "The ${snapshot.key} dinosaur's score is ${snapshot.value}") } // ... })
Java
scoresRef.orderByValue().limitToLast(2).addChildEventListener(new ChildEventListener() { @Override public void onChildAdded(@NonNull DataSnapshot snapshot, String previousChild) { Log.d(TAG, "The " + snapshot.getKey() + " dinosaur's score is " + snapshot.getValue()); } // ... });
Yukarıdaki örnekte Firebase Realtime Database müşterisi, "çocuk eklendi" en yüksek puanı alan iki dinozor için etkinlikler. kalıcı önbellek. Ancak bu, bir 'value' (değer) yaratmaz daha fazla bilgi sağlar. o sorguyu hiçbir zaman yürütmemiş olabilir.
Uygulama çevrimdışıyken son altı öğeyi istese bile "çocuk eklendi" için etkinlikleri anında sunar. cihaz tekrar çevrimiçi olursa, Firebase Realtime Database istemcisi senkronize edilir sunucuyla iletişim kurar ve son iki 'alt öğeyi' ekler ve "value" ekleyebilirsiniz.
İşlemleri Çevrimdışı Olarak Yönetme
Uygulama çevrimdışıyken yapılan tüm işlemler sıraya alınır. Uygulama ağ bağlantısını yeniden sağladığında işlemler şuraya gönderilir: Realtime Database sunucusu.
Varlığı Yönetme
Gerçek zamanlı uygulamalarda, istemcilerin ne zaman meşgul olduklarını veya bağlantıyı kesebilirsiniz. Örneğin, eğitime Bir kullanıcıyı "çevrimdışı" olarak işaretlemek istiyorsanız bağlantısı kesildiğinde.
Firebase Veritabanı istemcileri, veri kümelerini oluşturmak için kullanabileceğiniz basit İstemci Firebase Veritabanı ile bağlantısı kesildiğinde veri tabanına yazma sunucu. Bu güncellemeler, istemcinin bağlantısının kesilip kesilmediğinden bağımsız olarak, Böylece, bağlantınız kesilse bile verileri temizleme konusunda onlara güvenebilirsiniz. sorun olabilir. Şunlar dahil tüm yazma işlemleri: Güncelleme ve kaldırma işlemleri, bağlantı kesildikten sonra gerçekleştirilebilir.
Bağlantı kesildikten sonra
onDisconnect
temel öğesi:
Kotlin+KTX
val presenceRef = Firebase.database.getReference("disconnectmessage") // Write a string when this client loses connection presenceRef.onDisconnect().setValue("I disconnected!")
Java
DatabaseReference presenceRef = FirebaseDatabase.getInstance().getReference("disconnectmessage"); // Write a string when this client loses connection presenceRef.onDisconnect().setValue("I disconnected!");
OnBağlantıyı Kesmenin İşleyiş Şekli
Bir onDisconnect()
işlemi oluşturduğunuzda,
Firebase Realtime Database sunucusunda çalışıyor. Sunucu, güvenliği
Kullanıcının istenen yazma etkinliğini gerçekleştirebildiğinden emin olur ve
geçersizse uygulamanızı. Ardından sunucu,
bağlantıyı izler. Herhangi bir noktada bağlantı zaman aşımına uğrarsa veya
Realtime Database istemcisi tarafından aktif olarak kapatılmışsa sunucu,
ikinci kez (işlemin hâlâ geçerli olduğundan emin olmak için)
etkinliği tıklayın.
Uygulamanız, yazma işleminde geri çağırmayı kullanabilir
onDisconnect
öğesinin doğru şekilde eklendiğinden emin olmak için:
Kotlin+KTX
presenceRef.onDisconnect().removeValue { error, reference -> error?.let { Log.d(TAG, "could not establish onDisconnect event: ${error.message}") } }
Java
presenceRef.onDisconnect().removeValue(new DatabaseReference.CompletionListener() { @Override public void onComplete(DatabaseError error, @NonNull DatabaseReference reference) { if (error != null) { Log.d(TAG, "could not establish onDisconnect event:" + error.getMessage()); } } });
onDisconnect
etkinliği, .cancel()
aranarak da iptal edilebilir:
Kotlin+KTX
val onDisconnectRef = presenceRef.onDisconnect() onDisconnectRef.setValue("I disconnected") // ... // some time later when we change our minds // ... onDisconnectRef.cancel()
Java
OnDisconnect onDisconnectRef = presenceRef.onDisconnect(); onDisconnectRef.setValue("I disconnected"); // ... // some time later when we change our minds // ... onDisconnectRef.cancel();
Bağlantı Durumunu Algılama
Evde olmayla ilgili çoğu özellik açısından uygulamanıza faydalıdır.
çevrimiçi mi yoksa çevrimdışı mı olduğunu bilmektir. Firebase Realtime Database
/.info/connected
adresinde özel bir konum sağlar.
Firebase Realtime Database istemcisinin bağlantı durumu her seferinde güncellenir
anlamına gelir. Bir örnek verelim:
Kotlin+KTX
val connectedRef = Firebase.database.getReference(".info/connected") connectedRef.addValueEventListener(object : ValueEventListener { override fun onDataChange(snapshot: DataSnapshot) { val connected = snapshot.getValue(Boolean::class.java) ?: false if (connected) { Log.d(TAG, "connected") } else { Log.d(TAG, "not connected") } } override fun onCancelled(error: DatabaseError) { Log.w(TAG, "Listener was cancelled") } })
Java
DatabaseReference connectedRef = FirebaseDatabase.getInstance().getReference(".info/connected"); connectedRef.addValueEventListener(new ValueEventListener() { @Override public void onDataChange(@NonNull DataSnapshot snapshot) { boolean connected = snapshot.getValue(Boolean.class); if (connected) { Log.d(TAG, "connected"); } else { Log.d(TAG, "not connected"); } } @Override public void onCancelled(@NonNull DatabaseError error) { Log.w(TAG, "Listener was cancelled"); } });
/.info/connected
, bağımsız bir boole değeridir
değeri şu olduğundan Realtime Database istemci arasında senkronize edildi:
ve istemcinin durumuna bağlıdır. Başka bir deyişle,
/.info/connected
yanlış olarak okuyor, bu hayır
farklı bir istemcinin false (yanlış) değerini okuyacağını garanti edebilirsiniz.
Android'de Firebase, Android'de şunun için bağlantı durumunu otomatik olarak yönetir:
bant genişliğini ve pil kullanımını azaltır. Müşterinin etkin dinleyicisi yoksa
bekleyen yazma yok veya onDisconnect
işlemleri gerçekleştirmelerini sağlar ve
goOffline
yöntemi,
Firebase, 60 saniye boyunca hiçbir işlem yapılmazsa bağlantıyı kapatır.
İşleme Gecikmesi
Sunucu Zaman Damgaları
Firebase Realtime Database sunucuları, eklenecek bir mekanizma sağlar
sunucuda veri olarak oluşturulan zaman damgalarıdır. Bu özellik,
onDisconnect
, verilerinizi güvenilir bir şekilde not etmenin kolay bir yolunu sunuyor.
Realtime Database istemcisinin bağlantısının kesildiği saat:
Kotlin+KTX
val userLastOnlineRef = Firebase.database.getReference("users/joe/lastOnline") userLastOnlineRef.onDisconnect().setValue(ServerValue.TIMESTAMP)
Java
DatabaseReference userLastOnlineRef = FirebaseDatabase.getInstance().getReference("users/joe/lastOnline"); userLastOnlineRef.onDisconnect().setValue(ServerValue.TIMESTAMP);
Saat Sapma
firebase.database.ServerValue.TIMESTAMP
ise çok daha avantajlı
çoğu okuma/yazma işlemi için doğru ve tercih edilir.
bazen müşterinin saat sapmasını
tahmin etmek,
Firebase Realtime Database sunucuları için geçerli olacak. Siz
/.info/serverTimeOffset
konumuna geri arama ekleyebilir
Firebase Realtime Database istemcinin bu değeri milisaniye cinsinden elde etmek için
tahmin etmek için yerel olarak bildirilen zamana (milisaniye cinsinden dönem zamanı) ekleyin
anlamına gelir. Bu ofsetin doğruluğunun
ağ gecikmesidir, bu nedenle öncelikli olarak keşif sürecinde
büyük (> 1 saniye) tutarsızlıklar.
Kotlin+KTX
val offsetRef = Firebase.database.getReference(".info/serverTimeOffset") offsetRef.addValueEventListener(object : ValueEventListener { override fun onDataChange(snapshot: DataSnapshot) { val offset = snapshot.getValue(Double::class.java) ?: 0.0 val estimatedServerTimeMs = System.currentTimeMillis() + offset } override fun onCancelled(error: DatabaseError) { Log.w(TAG, "Listener was cancelled") } })
Java
DatabaseReference offsetRef = FirebaseDatabase.getInstance().getReference(".info/serverTimeOffset"); offsetRef.addValueEventListener(new ValueEventListener() { @Override public void onDataChange(@NonNull DataSnapshot snapshot) { double offset = snapshot.getValue(Double.class); double estimatedServerTimeMs = System.currentTimeMillis() + offset; } @Override public void onCancelled(@NonNull DatabaseError error) { Log.w(TAG, "Listener was cancelled"); } });
Örnek Varlık Uygulaması
Bağlantı kesme işlemlerini bağlantı durumu izlemeyle birleştirerek kullanıcı varlığı sistemi oluşturabilirsiniz. Bu sistemde, Her kullanıcı bir veri tabanında depolanan verileri veritabanının yerinde depolayıp depolamadığını Realtime Database müşteri online. Müşteriler bu konumu şu durumlarda doğru olarak ayarlar: internete giriyorlarsa ve bağlantıları kesildiğinde de bir zaman damgası gösteriyor. Bu zaman damgası belirtilen kullanıcının en son ne zaman çevrimiçi olduğunu gösterir.
Uygulamanızın, bağlantı kesme işlemlerini bir kullanıcı tarafından bağlanmadan önce sıraya koyması gerektiğini unutmayın. hiçbir yarış koşulu belirlememesi için, müşterinin ürünü veya hizmeti Her iki komut da sunucuya gönderilmeden önce ağ bağlantısı kesilir.
Basit bir kullanıcı varlığı sistemi aşağıda verilmiştir:
Kotlin+KTX
// Since I can connect from multiple devices, we store each connection instance separately // any time that connectionsRef's value is null (i.e. has no children) I am offline val database = Firebase.database val myConnectionsRef = database.getReference("users/joe/connections") // Stores the timestamp of my last disconnect (the last time I was seen online) val lastOnlineRef = database.getReference("/users/joe/lastOnline") val connectedRef = database.getReference(".info/connected") connectedRef.addValueEventListener(object : ValueEventListener { override fun onDataChange(snapshot: DataSnapshot) { val connected = snapshot.getValue<Boolean>() ?: false if (connected) { val con = myConnectionsRef.push() // When this device disconnects, remove it con.onDisconnect().removeValue() // When I disconnect, update the last time I was seen online lastOnlineRef.onDisconnect().setValue(ServerValue.TIMESTAMP) // Add this device to my connections list // this value could contain info about the device or a timestamp too con.setValue(java.lang.Boolean.TRUE) } } override fun onCancelled(error: DatabaseError) { Log.w(TAG, "Listener was cancelled at .info/connected") } })
Java
// Since I can connect from multiple devices, we store each connection instance separately // any time that connectionsRef's value is null (i.e. has no children) I am offline final FirebaseDatabase database = FirebaseDatabase.getInstance(); final DatabaseReference myConnectionsRef = database.getReference("users/joe/connections"); // Stores the timestamp of my last disconnect (the last time I was seen online) final DatabaseReference lastOnlineRef = database.getReference("/users/joe/lastOnline"); final DatabaseReference connectedRef = database.getReference(".info/connected"); connectedRef.addValueEventListener(new ValueEventListener() { @Override public void onDataChange(@NonNull DataSnapshot snapshot) { boolean connected = snapshot.getValue(Boolean.class); if (connected) { DatabaseReference con = myConnectionsRef.push(); // When this device disconnects, remove it con.onDisconnect().removeValue(); // When I disconnect, update the last time I was seen online lastOnlineRef.onDisconnect().setValue(ServerValue.TIMESTAMP); // Add this device to my connections list // this value could contain info about the device or a timestamp too con.setValue(Boolean.TRUE); } } @Override public void onCancelled(@NonNull DatabaseError error) { Log.w(TAG, "Listener was cancelled at .info/connected"); } });