Nodejs中怎么實(shí)現(xiàn)一個(gè)TCP服務(wù)端與客戶端聊天程序

今天就跟大家聊聊有關(guān)Nodejs中怎么實(shí)現(xiàn)一個(gè)TCP服務(wù)端與客戶端聊天程序，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

服務(wù)器端

count：連接的客戶端個(gè)數(shù)；
users：用于存儲(chǔ)客戶端用戶昵稱的對(duì)象，對(duì)象值都為該客戶端的Socket，Socket是一個(gè)接口，用于服務(wù)端與客戶端通信。
net.createServer：是用來創(chuàng)建TCP服務(wù)器，傳遞的函數(shù)為connetion事件的監(jiān)聽器，connection事件在有客戶端連接上服務(wù)器后觸發(fā)，傳進(jìn)去的參數(shù)conn是一個(gè)socket，即net.Socket的實(shí)例，是既可讀也可寫的。
conn：是回調(diào)函數(shù)的參數(shù)，每一個(gè)客戶端對(duì)應(yīng)的conn都是不一樣的，服務(wù)器會(huì)自動(dòng)識(shí)別。
conn.write：是將數(shù)據(jù)發(fā)送到客戶端上。
nickname：是額戶端的昵稱，當(dāng)nickname為undefined時(shí)，代表客戶端還沒有輸入昵稱，需要輸入昵稱驗(yàn)證，若不為空則已經(jīng)存儲(chǔ)，代表輸入的數(shù)據(jù)是對(duì)話，需顯示到其他的客戶端上。
conn.on('data',function (data){…})：是用來接收客戶端傳來的數(shù)據(jù)。

  /*server.js*/
  var net=require('net');
  var count=0;
  var users={};
  
  var server=net.createServer(function (conn) {
    conn.setEncoding('utf8');
    conn.write(count+' people are connected'
      +'\nplease write your nickname:');
    count++;
    var nickname;
    conn.on('data',function (data) {
      data=data.replace(/\r\n/,'');
      if(!nickname){
        if(users[data]){
          conn.write('\n nickname already used,try again:');
          return;
        }else {
          nickname=data;
          users[nickname]=conn;//每個(gè)客戶端對(duì)應(yīng)的conn是不一樣的
          for(var i in users){
            users[i].write(nickname+' join the romm\n');
          }
        }
      }else {
        conn.write('發(fā)送者nickname: '+nickname+'\n');
        for(var i in users){
          if(i!=nickname){
            users[i].write(nickname+': '+data+'\n');
          }
        }
      }
    });
    conn.on('close',function () {//這里防止連接出錯(cuò)，使用close而非end
      console.log(nickname+' client disconnected\n');
      count--;
      delete users[nickname];
    });
    conn.on('error',function (err) {
      console.log('Error in connection:'+ err+'\n');
    });
  }).listen(3000,function () {
    console.log('server is listenning on 3000');
  });

客戶端

process.stdin.resume()：process.stdin流來接受用戶的鍵盤輸入，這個(gè)可讀流初始化時(shí)處于暫停狀態(tài)，調(diào)用流上的resume()方法來恢復(fù)流。
process.stdin.on('data', function(data){…})：是用來獲取鍵盤的輸入，并用client.write()將它發(fā)送到服務(wù)端。
stop：用來判斷客戶端是否是正常斷開連接。
net.createConnection：是用來創(chuàng)建于服務(wù)端的連接，并且給connect事件自動(dòng)添加監(jiān)聽器，監(jiān)聽器不接收參數(shù)。返回的是 'net.Socket'。

  /*client.js*/
  var net=require('net');
  var stop = false;
  process.stdin.resume(); 
  
  process.stdin.on('data', function(data){
    if(data.toString().trim().toLowerCase()==='stop'){
      stop=true;
      console.log('connection stop\n');
      client.end();
    }else{
      client.write(data);
    }
  });
  
  var client=net.createConnection(3000,function () {
    console.log('connected to server!\n');
  });
  client.on('data', function(data) {
    console.log(data.toString());//打印服務(wù)器發(fā)送的數(shù)據(jù)
  });
  client.on('error', function(err) {
    console.log('Error in connection:'+ err+'\n');
  });
  client.on('close', function() {
    if(! stop) {
      console.log('connection got closed');
    }
  });

TCP聊天程序

這里是在git中運(yùn)行的，連接了3個(gè)客戶端的測(cè)試結(jié)果：

看完上述內(nèi)容，你們對(duì)Nodejs中怎么實(shí)現(xiàn)一個(gè)TCP服務(wù)端與客戶端聊天程序有進(jìn)一步的了解嗎？如果還想了解更多知識(shí)或者相關(guān)內(nèi)容，請(qǐng)關(guān)注億速云行業(yè)資訊頻道，感謝大家的支持。