Nodejs之TCP服務(wù)端與客戶(hù)端聊天程序詳解
TCP是用來(lái)計(jì)算機(jī)之間進(jìn)行通信的,通過(guò)編寫(xiě)客戶(hù)端和服務(wù)端聊天的代碼,對(duì)于服務(wù)器與客戶(hù)端的工作步驟有了深刻的了解,在這里根據(jù)了不起的Node.js一書(shū)來(lái)總結(jié)一下。
TCP聊天程序需要用到Nodejs中的net模塊,net模塊是對(duì)TCP的封裝,用于創(chuàng)建TCP服務(wù)端與客戶(hù)端的。
服務(wù)器端
count:連接的客戶(hù)端個(gè)數(shù);
users:用于存儲(chǔ)客戶(hù)端用戶(hù)昵稱(chēng)的對(duì)象,對(duì)象值都為該客戶(hù)端的Socket,Socket是一個(gè)接口,用于服務(wù)端與客戶(hù)端通信。
net.createServer:是用來(lái)創(chuàng)建TCP服務(wù)器,傳遞的函數(shù)為connetion事件的監(jiān)聽(tīng)器,connection事件在有客戶(hù)端連接上服務(wù)器后觸發(fā),傳進(jìn)去的參數(shù)conn是一個(gè)socket,即net.Socket的實(shí)例,是既可讀也可寫(xiě)的。
conn:是回調(diào)函數(shù)的參數(shù),每一個(gè)客戶(hù)端對(duì)應(yīng)的conn都是不一樣的,服務(wù)器會(huì)自動(dòng)識(shí)別。
conn.write:是將數(shù)據(jù)發(fā)送到客戶(hù)端上。
nickname:是額戶(hù)端的昵稱(chēng),當(dāng)nickname為undefined時(shí),代表客戶(hù)端還沒(méi)有輸入昵稱(chēng),需要輸入昵稱(chēng)驗(yàn)證,若不為空則已經(jīng)存儲(chǔ),代表輸入的數(shù)據(jù)是對(duì)話(huà),需顯示到其他的客戶(hù)端上。
conn.on('data',function (data){…}):是用來(lái)接收客戶(hù)端傳來(lái)的數(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è)客戶(hù)端對(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');
});
客戶(hù)端
process.stdin.resume():process.stdin流來(lái)接受用戶(hù)的鍵盤(pán)輸入,這個(gè)可讀流初始化時(shí)處于暫停狀態(tài),調(diào)用流上的resume()方法來(lái)恢復(fù)流。
process.stdin.on('data', function(data){…}):是用來(lái)獲取鍵盤(pán)的輸入,并用client.write()將它發(fā)送到服務(wù)端。
stop:用來(lái)判斷客戶(hù)端是否是正常斷開(kāi)連接。
net.createConnection:是用來(lái)創(chuàng)建于服務(wù)端的連接,并且給connect事件自動(dòng)添加監(jiān)聽(tīng)器,監(jiān)聽(tīng)器不接收參數(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è)客戶(hù)端的測(cè)試結(jié)果:

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
nodejs檢測(cè)因特網(wǎng)是否斷開(kāi)的解決方案
這篇文章主要給大家介紹了關(guān)于nodejs如何檢測(cè)因特網(wǎng)是否斷開(kāi)的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家學(xué)習(xí)或者使用nodejs具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-04-04
玩轉(zhuǎn)NODE.JS(四)-搭建簡(jiǎn)單的聊天室的代碼
本篇文章主要介紹了利用NODE.JS搭建簡(jiǎn)單的聊天室的代碼,有需要的可以了解一下。2016-11-11
node.js中的fs.lchownSync方法使用說(shuō)明
這篇文章主要介紹了node.js中的fs.lchownSync方法使用說(shuō)明,本文介紹了fs.lchownSync的方法說(shuō)明、語(yǔ)法、接收參數(shù)、使用實(shí)例和實(shí)現(xiàn)源碼,需要的朋友可以參考下2014-12-12
node全局變量__dirname與__filename的區(qū)別
這篇文章主要介紹了node全局變量__dirname與__filename的區(qū)別,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2019-01-01
Node.js實(shí)現(xiàn)連接mysql數(shù)據(jù)庫(kù)功能示例
這篇文章主要介紹了Node.js實(shí)現(xiàn)連接mysql數(shù)據(jù)庫(kù)功能,簡(jiǎn)單分析了nodejs連接數(shù)據(jù)庫(kù)的操作步驟與相關(guān)實(shí)現(xiàn)技巧,需要的朋友可以參考下2017-09-09
Mac下通過(guò)brew安裝指定版本的nodejs教程
今天小編就為大家分享一篇Mac下通過(guò)brew安裝指定版本的nodejs教程,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-05-05
node.js中的fs.realpathSync方法使用說(shuō)明
這篇文章主要介紹了node.js中的fs.realpathSync方法使用說(shuō)明,本文介紹了fs.realpathSync的方法說(shuō)明、語(yǔ)法、接收參數(shù)、使用實(shí)例和實(shí)現(xiàn)源碼,需要的朋友可以參考下2014-12-12
nodejs實(shí)現(xiàn)bigpipe異步加載頁(yè)面方案
本文給大家分享的是使用nodejs結(jié)合bigpipe實(shí)現(xiàn)異步加載頁(yè)面的方案,非常的實(shí)用,也是以后前端性能優(yōu)化的一個(gè)方向,希望大家能夠喜歡。2016-01-01
Node如何后臺(tái)數(shù)據(jù)庫(kù)使用增刪改查功能
這篇文章主要介紹了Node如何后臺(tái)數(shù)據(jù)庫(kù)使用增刪改查功能,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-11-11

