快捷導(dǎo)航

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

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

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

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

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

服務(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é)果：