首頁  >  文章  >  web前端  >  詳解Nodejs之TCP服務端與客戶端聊天程序

詳解Nodejs之TCP服務端與客戶端聊天程序

零下一度
零下一度原創
2017-07-09 09:44:321222瀏覽

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

TCP是用來計算機之間進行通訊的,透過編寫客戶端和服務端聊天的程式碼,對於伺服器與客戶端的工作步驟有了深刻的了解,在這裡根據了不起的Node.js一書來總結一下。

TCP聊天程式需要用到Nodejs中的net模組,net模組是對TCP的封裝,用來建立TCP服務端與客戶端的。

伺服器端

count:連線的客戶端個數;
users:用於儲存客戶端使用者暱稱的對象,物件值都為該客戶端的Socket,Socket是一個接口,用於服務端與客戶端通訊。
net.createServer:是用來創建TCP伺服器,傳遞的函數為connetion事件的監聽器,connection事件在有客戶端連接上伺服器後觸發,傳進去的參數conn是一個socket ,即net.Socket的實例,是既可讀也可寫的。
conn:是回呼函數的參數,每個客戶端對應的conn都是不一樣的,伺服器會自動辨識。
conn.write:是將資料傳送到客戶端。
nickname:是額戶端的暱稱,當nickname為undefined時,代表客戶端尚未輸入暱稱,需要輸入暱稱驗證,若不為空則已經存儲,代表輸入的資料是對話,需顯示到其他的客戶端上。
conn.on('data',function (data){…}):是用來接收客戶端傳來的資料。


  /*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;//每个客户端对应的conn是不一样的
          for(var i in users){
            users[i].write(nickname+' join the romm\n');
          }
        }
      }else {
        conn.write('发送者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流來接受使用者的鍵盤輸入,這個可讀流初始化時處於暫停狀態,呼叫流上的resume()方法來恢復流。
process.stdin.on('data', function(data){…}):是用來取得鍵盤的輸入,並用client.write()將它傳送到服務端。
stop:用來判斷客戶端是否為正常斷開連線。
net.createConnection:是用來建立於服務端的連接,並且給connect事件自動新增監聽器,監聽器不接收參數。回傳的是 '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());//打印服务器发送的数据
  });
  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個客戶端的測試結果:

以上是詳解Nodejs之TCP服務端與客戶端聊天程序的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn