Блог

У меня есть 2 экземпляра моего приложения, запущенных на 2 устройствах. Оба устройства прослушивают одни и те же изменения узла БД с использованием onChildChanged метода. Когда новый дочерний узел добавляется к прослушиваемому узлу onChildChanged , событие запускается только на том же устройстве, на котором был добавлен этот новый узел. На втором устройстве onChildChanged событие по какой-то причине не запускается.

Но если я использую onChildAdded метод для прослушивания, то это событие onChildAdded правильно запускается на обоих устройствах, когда узел, который изменяется, который мы прослушиваем, обновляется вновь добавленным дочерним узлом.

Я согласен с тем, что onChildChanged это срабатывает только тогда, когда какой-либо из узлов-потомков фактически изменяется (не добавляется новый дочерний узел) на всех устройствах. Но почему onChildChanged запускается только на том устройстве, которое выполнило добавление нового узла?

Короче говоря, возникает вопрос: почему, когда на устройстве новый дочерний узел добавлен в БД onChildAdded , он запускается как на устройствах A, так и на устройствах B и onChildChanged запускается только на устройстве A (а не на B)?

Связанные документы: https://firebase.google.com/docs/database/admin/retrieve-data
https://firebase.google.com/docs/reference/android/com/google/firebase/database/ChildEventListener

Обновить:

Я обнаружил, что ServerValue.timestamp вызывает такое поведение. Без ServerValue.timestamp когда мы добавляем новый дочерний узел и прослушиваем изменения родительского узла, событие onChildChanged никогда не срабатывало. Только если мы используем ServerValue.timestamp в качестве одного из полей вновь добавленного дочернего узла, событие onChildChanged происходит, НО только на устройстве, которое добавило этот новый дочерний узел со значением метки времени сервера. Я понимаю, что это, скорее всего, срабатывает, потому что сначала создается новый дочерний узел с заполнителем поля метки времени, а затем этот узел обновляется сервером, когда в обязательное поле записывается метка реального времени. Итак, теперь вопрос: почему не все устройства с экземплярами этого приложения получают событие onChildChanged в случае, если мы используем ServerValue.timestamp?

 class _MyHomePageState extends State<MyHomePage> {
  
  final String dbDataPath = 'root/chatroom0001/messages';
  DatabaseReference dbRef = FirebaseDatabase.instance.reference ();
  StreamSubscription <Event> _messagesChangedSubscription;
  List <String> _lMessages = List <String> ();

  Future <List <String>> fetchMessages (String dbDataPath) async {
    List <String> lMessages = List <String> ();
    final DataSnapshot dataMessages = await dbRef.child (dbDataPath).once ();

    dataMessages.value.forEach ((k, v) => {
      lMessages.add (v ['message'])
    });

    return lMessages;
  }

  @override
  void initState () {
    super.initState ();

    DatabaseReference messagesRef = dbRef.child (dbDataPath);

    fetchMessages (dbDataPath).then ((lMessages) {
      _lMessages = lMessages;
      setState (() {});
    });

    _messagesChangedSubscription = dbRef.child (dbDataPath).onChildChanged.listen ((event) {
      fetchMessages (dbDataPath).then ((lMessages) {
        _lMessages = lMessages;
        setState (() {});
      });
    });
  }

  @override
  void dispose () {
    super.dispose ();

    _messagesChangedSubscription.cancel ();
  }

  @override
  Widget build (BuildContext context) {
    return Scaffold (      
      body: Container (
        color: Colors.red, child: ListView.builder (
          itemCount: _lMessages.length,
          itemBuilder: (context, i) {
            return Container (padding: EdgeInsets.all (5), child: Text (_lMessages [i], style: TextStyle (fontWeight: FontWeight.bold, fontSize: 20.0)));
          }
        )
      ),
      floatingActionButton: FloatingActionButton (
        onPressed: () {
          DatabaseReference messagesRef = dbRef.child (dbDataPath);
          DatabaseReference newChatMessageRef = messagesRef.push ();
          newChatMessageRef.set ({
            'message': 'Hello Google!',
            'date': ServerValue.timestamp
          });
        },
      ),
    );
  }
}
  

Вот исходный код тестового проекта:
https://drive.google.com/file/d/1j3eHbD_3UxOhWWmZRfSoKqa-r9dyEwbV/view?usp=sharing

Этот код:

   DatabaseReference newChatMessageRef = messagesRef.push ();
  newChatMessageRef.set ({
    'message': 'Hello Google!',
    'date': ServerValue.timestamp
  });
  

Приведет к двум событиям записи на клиенте, который вносит изменения:

1. Локальная оценка немедленно запускает локальное событие при выполнении этого кода.
2. Затем, когда клиент получает фактическое значение с сервера, он запускает другое событие для конечного значения.

Удаленные клиенты, прослушивающие этот же узел, увидят только второе событие. Это может быть либо onValue событие, onChildAdded либо onChildChanged событие или, в зависимости от типа используемого прослушивателя и локального состояния.

Итак, на клиенте, вносящем изменения: если вы используете onValue прослушиватель, вы увидите два события значений, в то время как если вы используете onChild прослушиватели на родительском узле, вы увидите onChildAdded для локального события, а затем onChildChanged для конечного значения.