Node.js - 写完后错误

Question

我已经使用在Raspberry pi 3上运行的Node.js设置了TCP服务器。我使用Android客户端与服务器通信（来自[this] [1]教程的代码） 。只有当客户端连接到第一次连接时，我才会收到来自服务器的响应。

当我尝试向它发出另一个请求时，请求被接收并处理，但在发送响应时，出现错误提示：write after end。

码（编辑）：

var net = require('net'); 
var devList = []; 
var dev_msg; 

function serverCallback(socket){ 
    console.log("-----------------------------------------------------"); 

    socket.setNoDelay(true); 

    socket.on('data', function(data){ 
     var req = data.toString(); 

     console.log(req); 

     InitSystems(socket); 
    }); 

    socket.on('error', function(err){ 
     console.log(""+err); 
    }); 

    socket.on('end', function(){ 
     console.log("Write end"); 
    }); 
} 


function InitSystems(socket){ 
    socket.write("Message 1: Hi!"); 
    socket.end(); 

    //After 2nd request from client 
    socket.write("Message 2: Event has successfully taken place!"); //<-- Error here 
    socket.end(); 
} 

console.log("Server now running!"); 

var netServer = net.createServer(serverCallback); 
netServer.listen(6969); 

编辑： 的Android代码：

try{ 
      socket = new Socket("192.168.1.13", 6969); 

      socket.setSoTimeout(24 * 60 * 60 * 1000); 
      socket.setKeepAlive(true); 

      dOut = new DataOutputStream(socket.getOutputStream()); 

      dOut.writeUTF("INIT"); 
      dOut.flush(); 

      ba = new ByteArrayOutputStream(1024); 
      buffer = new byte[1024]; 

      int bytesRead; 
      is = socket.getInputStream(); 

      while((bytesRead = is.read(buffer)) != -1){ 
       ba.write(buffer, 0, bytesRead); 
       res += ba.toString("UTF-8"); 
      } 

      Log.d(TAG, res); 

      connStat = true; 
     }catch (UnknownHostException e) { 
      Log.d(TAG, e.toString()); 
     } catch(SocketException e){ 
      Log.d(TAG, e.toString()); 
     } catch (IOException e){ 
      try{ 
       Thread.sleep(2100); 
      }catch (Exception e1){ 

      }finally { 
       connStat = false; 
      } 
     } catch (Exception e) { 
      Log.d(TAG, e.toString()); 
     } 

提前感谢！

Answer 1

这是你的问题（就像你评论）：一个end()被称为

function InitSystems(socket){ 
    socket.write("Message 1: Hi!"); 
    socket.end(); 

    //After 2nd request from client 
    socket.write("Message 2: Event has successfully taken place!"); //<-- Error here 
    socket.end(); 
} 

你正在做一个后write()，它不允许你这样做。您可以将套接字视为连接在您（服务器）和客户端之间的线路。只要插座打开，您就可以在电线上来回发送消息。一旦你致电end()，电线被切断（插座关闭），你不能再发送信息。任何尝试这样做都会导致您收到的错误。

另外值得注意的是，在您拨打socket.end()后JavaScript仍然执行，因此每次调用该函数时，您的代码都会尝试到write -> end -> write -> end。我不太确定你想要达到什么目的，但是你不需要拨打socket.end()，直到你完全使用socket并且不想再发送任何消息。

如果你要有条件地写邮件，您将需要保持某种状态是这样的：

var reqCount = 0; 
function InitSystems(socket){ 
    switch (reqCount) { 
     case 0: 
      socket.write("Message 1: Hi!"); 
      break; 
     case 1: 
      socket.write("Message 2: Event has successfully taken place!"); 
      break; 
    } 

    // You may want to do something to signify the end of a message 
    socket.write('END OF MESSAGE'); 
    reqCount++; 
}