快捷導(dǎo)航

Nodejs之TCP服務(wù)端與客戶端聊天程序詳解

更新時間：2017年07月07日 11:21:03 作者：艾新覺羅

這篇文章主要為大家詳細介紹了Nodejs之TCP服務(wù)端與客戶端聊天程序，具有一定的參考價值，感興趣的小伙伴們可以參考一下

TCP是用來計算機之間進行通信的，通過編寫客戶端和服務(wù)端聊天的代碼，對于服務(wù)器與客戶端的工作步驟有了深刻的了解，在這里根據(jù)了不起的Node.js一書來總結(jié)一下。

TCP聊天程序需要用到Nodejs中的net模塊，net模塊是對TCP的封裝，用于創(chuàng)建TCP服務(wù)端與客戶端的。

服務(wù)器端

count：連接的客戶端個數(shù)；
users：用于存儲客戶端用戶昵稱的對象，對象值都為該客戶端的Socket，Socket是一個接口，用于服務(wù)端與客戶端通信。
net.createServer：是用來創(chuàng)建TCP服務(wù)器，傳遞的函數(shù)為connetion事件的監(jiān)聽器，connection事件在有客戶端連接上服務(wù)器后觸發(fā)，傳進去的參數(shù)conn是一個socket，即net.Socket的實例，是既可讀也可寫的。
conn：是回調(diào)函數(shù)的參數(shù)，每一個客戶端對應(yīng)的conn都是不一樣的，服務(wù)器會自動識別。
conn.write：是將數(shù)據(jù)發(fā)送到客戶端上。
nickname：是額戶端的昵稱，當(dāng)nickname為undefined時，代表客戶端還沒有輸入昵稱，需要輸入昵稱驗證，若不為空則已經(jīng)存儲，代表輸入的數(shù)據(jù)是對話，需顯示到其他的客戶端上。
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;//每個客戶端對應(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 () {//這里防止連接出錯，使用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流來接受用戶的鍵盤輸入，這個可讀流初始化時處于暫停狀態(tài)，調(diào)用流上的resume()方法來恢復(fù)流。
process.stdin.on('data', function(data){…})：是用來獲取鍵盤的輸入，并用client.write()將它發(fā)送到服務(wù)端。
stop：用來判斷客戶端是否是正常斷開連接。
net.createConnection：是用來創(chuàng)建于服務(wù)端的連接，并且給connect事件自動添加監(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中運行的，連接了3個客戶端的測試結(jié)果：