Android'de Çevrimdışı Özellikleri Etkinleştirme

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, ağ bağlantısı tekrar kurulduğunda tüm yazma işlemlerini yeniden gönderir.

Disk kalıcılığını etkinleştirdiğinizde uygulamanız verileri cihaza yerel olarak yazar. Böylece, kullanıcı veya işletim sistemi uygulamayı yeniden başlatsa bile uygulamanız çevrimdışıyken durumu koruyabilir.

Disk kalıcılığını yalnızca bir satır kodla etkinleştirebilirsiniz.

Kotlin+KTX

Firebase.database.setPersistenceEnabled(true)OfflineActivity.kt

Java

FirebaseDatabase.getInstance().setPersistenceEnabled(true);OfflineActivity.java

Kalıcı Davranış

Kalıcılığı etkinleştirdiğinizde, kullanıcı veya işletim sistemi uygulamayı yeniden başlatsa bile Firebase Realtime Database istemcisinin çevrimiçiyken senkronize ettiği tüm veriler diskte kalır ve çevrimdışı olarak kullanılabilir. Böylece uygulamanız, önbellekte depolanan yerel verileri kullanarak online olduğu gibi çalışır. Yerel güncellemeler için dinleyici geri çağırmaları tetiklenmeye devam eder.

Firebase Realtime Database istemcisi, uygulamanız çevrimdışıyken gerçekleştirilen tüm yazma işlemlerinin sırasını otomatik olarak saklar. Kalıcılık etkinleştirildiğinde bu sıra diskte de tutulur. Böylece, kullanıcı veya işletim sistemi uygulamayı yeniden başlattığında yazmalarınızın tamamı kullanılabilir. Uygulama yeniden internete bağlandığında tüm işlemler Firebase Realtime Database sunucusuna gönderilir.

Uygulamanız Firebase Authentication kullanıyorsa Firebase Realtime Database istemcisi, uygulamanın yeniden başlatılmasında kullanıcının kimlik doğrulama jetonunu muhafaza eder. Uygulamanız çevrimdışıyken kimlik doğrulama jetonunun süresi dolarsa uygulamanız kullanıcının kimliğini yeniden doğrulayana kadar istemci yazma işlemlerini duraklatır. Aksi takdirde, yazma işlemleri güvenlik kuralları nedeniyle başarısız olabilir.

Verileri güncel tutma

Firebase Realtime Database, etkin dinleyiciler için verilerin yerel bir kopyasını senkronize eder ve depolar. Ayrıca, belirli konumları senkronize edebilirsiniz.

Kotlin+KTX

val scoresRef = Firebase.database.getReference("scores")
scoresRef.keepSynced(true)OfflineActivity.kt

Java

DatabaseReference scoresRef = FirebaseDatabase.getInstance().getReference("scores");
scoresRef.keepSynced(true);OfflineActivity.java

Firebase Realtime Database istemcisi bu konumlardaki verileri otomatik olarak indirir ve referansta etkin dinleyici olmasa bile senkronize halde tutar. Aşağıdaki kod satırını kullanarak senkronizasyonu tekrar kapatabilirsiniz.

Kotlin+KTX

scoresRef.keepSynced(false)OfflineActivity.kt

Java

scoresRef.keepSynced(false);OfflineActivity.java

Varsayılan olarak, önceden senkronize edilmiş 10 MB'lık veri ön belleğe alınır. Bu, çoğu uygulama için yeterli olacaktır. Önbellek, yapılandırılmış boyutundan fazla büyürse Firebase Realtime Database, en son kullanılan verileri tamamen siler. Senkronize edilen veriler önbellekten silinmez.

Çevrimdışı Verileri Sorgulama

Firebase Realtime Database, bir sorgudan döndürülen verileri çevrimdışıyken kullanmak üzere depolar. Çevrimdışıyken oluşturulan sorgular için Firebase Realtime Database, daha önce yüklenmiş veriler için çalışmaya devam eder. İstenen veriler yüklenmediyse Firebase Realtime Database, yerel önbellekten veri yükler. Ağ bağlantısı tekrar kullanılabilir olduğunda veriler yüklenir ve sorguyu yansıtır.

Örneğin bu kod, Firebase Gerçek Zamanlı Puan Veritabanı'ndaki son dört öğeyi sorgular

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}")
    }

    // ...
})OfflineActivity.kt

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());
    }

    // ...
});OfflineActivity.java

Kullanıcının bağlantısını kestiğini, çevrimdışı olduğunu ve uygulamayı yeniden başlattığını varsayalım. Uygulama, çevrimdışıyken aynı konumdan son iki öğeyi sorgular. Uygulama yukarıdaki sorgudaki dört öğenin tamamını yüklediğinden, bu sorgu son iki öğeyi başarıyla döndürecektir.

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}")
    }

    // ...
})OfflineActivity.kt

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());
    }

    // ...
});OfflineActivity.java

Yukarıdaki örnekte Firebase Realtime Database istemcisi kalıcı önbelleği kullanarak en yüksek puana sahip iki dinozor için "çocuklar tarafından eklenen" etkinlikleri düzenliyor. Ancak uygulama, online durumdayken bu sorguyu hiç yürütmediği için "value" etkinliği oluşturmaz.

Uygulama çevrimdışıyken son altı öğeyi isteseydi önbelleğe alınan dört öğe için "çocuk eklendi" etkinlikleri hemen alınacaktı. Cihaz tekrar internete bağlandığında Firebase Realtime Database istemcisi sunucuyla senkronize olur ve uygulama için son iki "alt ekleme" ve "value" etkinliğini alır.

İş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, Realtime Database sunucusuna gönderilir.

Varlığı Yönetme

Gerçek zamanlı uygulamalarda, istemcilerin ne zaman bağlanıp kesildiğini tespit etmek genellikle kullanışlı olur. Örneğin, istemcisinin bağlantısı kesildiğinde bir kullanıcıyı "çevrimdışı" olarak işaretlemek isteyebilirsiniz.

Firebase Veritabanı istemcileri, bir istemci Firebase Veritabanı sunucularıyla bağlantısı kesildiğinde veritabanına yazmak için kullanabileceğiniz basit temel öğeler sunar. Bu güncellemeler, istemcinin bağlantısının kesilmesinden bağımsız olarak gerçekleşir. Bu nedenle, bağlantı kesilse veya istemci çökse bile verileri temizleme konusunda bu güncellemelere güvenebilirsiniz. Ayarlama, güncelleme ve kaldırma gibi tüm yazma işlemleri, bağlantı kesildikten sonra gerçekleştirilebilir.

Bağlantı kesildikten sonra onDisconnect temel öğesini kullanarak veri yazmayla ilgili basit bir örneği burada bulabilirsiniz:

Kotlin+KTX

val presenceRef = Firebase.database.getReference("disconnectmessage")
// Write a string when this client loses connection
presenceRef.onDisconnect().setValue("I disconnected!")OfflineActivity.kt

Java

DatabaseReference presenceRef = FirebaseDatabase.getInstance().getReference("disconnectmessage");
// Write a string when this client loses connection
presenceRef.onDisconnect().setValue("I disconnected!");OfflineActivity.java

OnBağlantıyı Kesmenin İşleyiş Şekli

Bir onDisconnect() işlemi oluşturduğunuzda bu işlem Firebase Realtime Database sunucusunda barındırılır. Sunucu, kullanıcının istenen yazma etkinliğini gerçekleştirebildiğinden emin olmak için güvenliği kontrol eder ve uygulamanızın geçersiz olduğunu bildirir. 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ılırsa sunucu, güvenliği ikinci bir kez kontrol eder (işlemin hâlâ geçerli olduğundan emin olmak için) ve ardından etkinliği çağırır.

Uygulamanız, onDisconnect öğesinin doğru şekilde eklendiğinden emin olmak için yazma işleminde geri çağırmayı kullanabilir:

Kotlin+KTX

presenceRef.onDisconnect().removeValue { error, reference ->
    error?.let {
        Log.d(TAG, "could not establish onDisconnect event: ${error.message}")
    }
}OfflineActivity.kt

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());
        }
    }
});OfflineActivity.java

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()OfflineActivity.kt

Java

OnDisconnect onDisconnectRef = presenceRef.onDisconnect();
onDisconnectRef.setValue("I disconnected");
// ...
// some time later when we change our minds
// ...
onDisconnectRef.cancel();OfflineActivity.java

Bağlantı Durumunu Algılama

Evde olmayla ilgili birçok özellik için uygulamanızın ne zaman çevrimiçi mi yoksa çevrimdışı mı olduğunu bilmesi faydalı olur. Firebase Realtime Database, /.info/connected adresinde özel bir konum sağlar. Bu konum, Firebase Realtime Database istemcisinin bağlantı durumu her değiştiğinde güncellenir. 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")
    }
})OfflineActivity.kt

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");
    }
});OfflineActivity.java

/.info/connected, değer istemcinin durumuna bağlı olduğundan Realtime Database istemcileri arasında senkronize edilmeyen bir boole değeridir. Diğer bir deyişle, bir istemci /.info/connected öğesini false olarak okursa bu, ayrı bir istemcinin de false olarak okuyacağını garanti etmez.

Android'de Firebase, bant genişliğini ve pil kullanımını azaltmak için bağlantı durumunu otomatik olarak yönetir. Etkin işleyici yoksa, bekleyen yazma veya onDisconnect işlemi yoksa ve goOffline yöntemiyle bağlantısı açıkça kesilmemişse Firebase, 60 saniye boyunca işlem yapılmadığında bağlantıyı kapatır.

İşleme Gecikmesi

Sunucu Zaman Damgaları

Firebase Realtime Database sunucuları, sunucuda oluşturulan zaman damgalarını veri olarak ekleyen bir mekanizma sağlar. onDisconnect ile birlikte kullanılan bu özellik, Realtime Database istemcisinin bağlantısının kesildiği zamanı güvenilir şekilde not etmenin kolay bir yolunu sunar:

Kotlin+KTX

val userLastOnlineRef = Firebase.database.getReference("users/joe/lastOnline")
userLastOnlineRef.onDisconnect().setValue(ServerValue.TIMESTAMP)OfflineActivity.kt

Java

DatabaseReference userLastOnlineRef = FirebaseDatabase.getInstance().getReference("users/joe/lastOnline");
userLastOnlineRef.onDisconnect().setValue(ServerValue.TIMESTAMP);OfflineActivity.java

Saat Sapma

firebase.database.ServerValue.TIMESTAMP çok daha doğru sonuç verir ve çoğu okuma/yazma işlemi için tercih edilir. Bununla birlikte, bazen Firebase Realtime Database sunucularına göre istemcinin saat sapmasını tahmin etmek faydalı olabilir. Firebase Realtime Database istemcilerinin sunucu süresini tahmin etmek amacıyla bildirilen yerel süreye (milisaniye cinsinden dönem süresi) eklediği değeri milisaniye cinsinden elde etmek için /.info/serverTimeOffset konumuna bir geri çağırma ekleyebilirsiniz. Bu ofsetin doğruluğunun ağ iletişimi gecikmesinden etkilenebileceğini ve bu nedenle özellikle saat süresindeki büyük (> 1 saniye) tutarsızlıkların keşfedilmesinde yararlı olduğunu unutmayın.

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")
    }
})OfflineActivity.kt

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");
    }
});OfflineActivity.java

Örnek Varlık Uygulaması

Bağlantı kesme işlemlerini bağlantı durumu izleme ve sunucu zaman damgalarıyla birleştirerek kullanıcı varlığı sistemi oluşturabilirsiniz. Bu sistemde her kullanıcı, bir Realtime Database istemcisinin online olup olmadığını belirtmek için verileri bir veritabanı konumunda depolar. Müşteriler, internete girdiklerinde bu konumu doğru olarak, bağlantıyı kestiklerinde ise zaman damgası olarak ayarlar. Bu zaman damgası, belirli bir kullanıcının en son ne zaman internete bağlı olduğunu gösterir.

Her iki komut da sunucuya gönderilmeden önce istemcinin ağ bağlantısının kesilmesi durumunda, olabilecek yarış koşullarını önlemek için uygulamanızın, bağlantı kesme işlemlerini kullanıcı online olarak işaretlenmeden önce sıraya koyması gerektiğini unutmayın.

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")
    }
})OfflineActivity.kt

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");
    }
});OfflineActivity.java