Событие сокета IO запускается несколько раз NodeJS

Question

Я создаю приложение для викторины в NodeJS и Android с использованием socket.IO,

Я сталкиваюсь с проблемой, когда отправляю событие quizzoStatus с сервера, событие запускается один раз, второй раздважды и т. д.

Здесь я прикрепляю свой фрагмент кода

///server side: NodeJS
socket.on('sendQuizzoAnsPoints', async (data)=>{
          try {
              const obj = JSON.parse(data);
              const game = await QuizzoPlayModel.findOne({_id:obj.gameId});
              const player = await UserModel.findOne({_id: game.playerId});
              const opponent = await UserModel.findOne({_id: game.opponentId});
              if(obj.userId == game.opponentId){
                  let update = {
                      opponentPoints: game.opponentPoints + obj.points || 0,
                      opponentWA: game.opponentWA + obj.wrongAns || 0,
                  };
                  await QuizzoPlayModel.findByIdAndUpdate(obj.gameId, update).lean().exec();
                  userNamespace.to(player.socketId).emit('quizzoStatus', {
                      fullName: opponent.fullName,
                      points: game.playerPoints + obj.points,
                      wrongAns: obj.wrongAns,
                      gameId: obj.gameId
                  });
              }
              if(obj.userId == game.playerId) {
                  let update = {
                      playerPoints: game.playerPoints + obj.points || 0,
                      playerWA: game.playerWA + obj.wrongAns || 0,
                  };
                  await QuizzoPlayModel.findByIdAndUpdate(obj.gameId, update).lean().exec();
                  userNamespace.to(opponent.socketId).emit('quizzoStatus', {
                      fullName: player.fullName,
                      points: game.playerPoints+ obj.points,
                      wrongAns: obj.wrongAns,
                      gameId: obj.gameId
                  });
              }
          } catch (e) {
              console.log(e);
          }
        });

Здесь я слушаю событие с именем sendQuizzoAnsPoints, а затем отправляю событие игроку или противнику в другом событии с именемquizzoStatus.

Событие quizzoStatus запускается несколько раз с сервера на андроид.Здесь я прикрепил код Android

/// Android code
socket.emit("sendQuizzoAnsPoints", new Gson().toJson(quizzoStatusRequestDto)); 
socket.on("quizzoStatus", new Emitter.Listener(){
           @Override
           public void call(Object... args){
               runOnUiThread(new Runnable(){
                   @Override
                   public void run(){
                       Log.e("opponet point", opponentPoints + " " + quizzoStatusResponseDto.getPoints());
                   }
               });
           }
       });

Answer 1

Проблема в Android.Вы назначаете нового слушателя каждый раз, не удаляя его.Вам нужно создать переменную этого Emmiter слушателя и удалить его onDestroy или куда-нибудь еще, когда работа будет завершена:

    //variable of Emmiter.Listener
    Emmiter.Listener quizzoStatus = new Emitter.Listener(){
        @Override public void call(Object... args){
            runOnUiThread(new Runnable(){
                @Override public void run(){
                    Log.e("opponet point", opponentPoints + " " + quizzoStatusResponseDto.getPoints());
                }
            });
        }
    };

    //assigning the listener
    socket.on("quizzoStatus", quizzoStatus);
    . . . .
    @Override protected void onDestroy(){
        super.onDestroy();
        //removing the listener...
        socket.off("quizzoStatus", quizzoStatus);
    }

Надеюсь, это сработает