socket.on 事件被多次触发

var express = require('express');
var app = express();
var server = app.listen(3000);
var replyFromBot;
app.use(express.static('public'));
var socket = require('socket.io');
var io = socket(server);
io.sockets.on('connection' , newConnection);

function newConnection(socket) {
   console.log(socket.id);
   listen = true;
   socket.on('Quest' ,reply);
   function reply(data) {
     replyFromBot = bot.reply("local-user", data);
     console.log(socket.id+ " "+replyFromBot);
     socket.emit('Ans' , replyFromBot);
  }
}

我使用node.js socket.io和express创建了一个基于服务器的聊天机器人应用程序，但问题是当我第一次调用socket.on时，它会执行一次，第二次它会执行两次，第三次会执行三次，所以我已经通过在我的客户端上设置一个标志来解决这个问题，以便它只显示一次。我只是想知道我的代码在逻辑上是否正确我的意思是这是一个好的代码吗？因为如果客户第 10 次问问题，听众数组将有 10+9+8....+1 个听众，它会根据客户提出的问题数量继续增加。这不好

我尝试使用removeListener，它只删除一次侦听器，并且不会第二次回调。你们有什么推荐？我应该这样做还是有其他方法可以在调用 socket.on 时添加侦听器并在执行时删除它并在下次调用时再次添加侦听器

谢谢。

客户端代码：

function reply() {
  socket.emit('Quest' , Quest);
  flag = true;
  audio.play();
  socket.on('Ans', function(replyFromBot) {
  if(flag) {
    console.log("hi");
    var para = document.createElement("p2");
    x = document.getElementById("MiddleBox");
    para.appendChild(document.createTextNode(replyFromBot));
    x.appendChild(para);
    x.scrollTop = x.scrollHeight;
    flag = false;
  }
 });
}

该问题是由您的客户端代码引起的。每次您致电reply()您在客户端中设置了一个额外的函数socket.on('Ans', ...)事件处理程序这意味着它们会累积。你可以将其更改为socket.once()每次获得后它都会自行删除Ans信息。然后您还可以删除您的flag多变的。

function reply() {
  socket.emit('Quest' , Quest);
  audio.play();
  // change this to .once()
  socket.once('Ans', function(replyFromBot) {
    console.log("hi");
    var para = document.createElement("p2");
    x = document.getElementById("MiddleBox");
    para.appendChild(document.createTextNode(replyFromBot));
    x.appendChild(para);
    x.scrollTop = x.scrollHeight;
  });
}

Socket.io 并不是真正构建为请求/响应系统的，而这正是您尝试使用的系统。实现这一点的更好方法是使用acksocket.io 具有的功能这样您就可以得到直接回复Quest您发送的消息。

您还需要修复共享变量replyFromBot and listen在您的服务器上，因为一旦有多个用户使用您的服务器，这些并发问题就会发生。

更好的解决方案

更好的解决方案是使用acksocket.io 必须能够直接响应您发送的消息。为此，您需要将服务器更改为：

function newConnection(socket) {
    console.log(socket.id);
    socket.on('Quest', function(data, fn) {
      let replyFromBot = bot.reply("local-user", data);
      console.log(socket.id+ " "+replyFromBot);
      // send ack response
      fn(replyFromBot);
    });
}

并且，将您的客户端代码更改为：

function reply() {
    audio.play();
    socket.emit('Quest', Quest, function(replyFromBot) {
        console.log("hi");
        var para = document.createElement("p2");
        x = document.getElementById("MiddleBox");
        para.appendChild(document.createTextNode(replyFromBot));
        x.appendChild(para);
        x.scrollTop = x.scrollHeight;
    });
}

通过这种方式，您可以连接到消息的直接回复，因此它作为请求/响应的工作方式比您以前的方式要好得多。