这篇文章主要介绍了nodejs如何实现TCP服务器端和客户端聊天功能，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。
创新互联长期为数千家客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为永靖企业提供专业的
做网站、网站设计，
永靖网站改版等技术服务。拥有十载丰富建站经验和众多成功案例,为您定制开发。
具体如下：
服务器端
var net = require('net');
var server = net.createServer();
//聚合所有客户端
var sockets = [];
//接受新的客户端连接
server.on('connection', function(socket){
console.log('got a new connection');
sockets.push(socket);
//从连接中读取数据
socket.on('data', function(data){
console.log('got data:', data);
//广播数据
//每当一个已连接的用户输入数据，就将这些数据广播给其他所有已连接的用户
sockets.forEach(function(otherSocket){
if (otherSocket !== socket){
otherSocket.write(data);
}
});
//删除被关闭的连接
socket.on('close', function(){
console.log('connection closed');
var index = sockets.indexOf(socket);
sockets.splice(index, 1);
});
});
});
server.on('error', function(err){
console.log('Server error:', err.message);
});
server.on('close', function(){
console.log('Server closed');
});
server.listen(4000);客户端
var net = require('net');
var port = 4000;
var quitting = false;
var conn;
var retryTimeout = 3000; //三秒，定义三秒后重新连接
var retriedTimes = 0; //记录重新连接的次数
var maxRetries = 10; //最多重新连接十次
process.stdin.resume(); //process.stdin流来接受用户的键盘输入，这个可读流初始化时处于暂停状态，调用流上的resume()方法来恢复流
process.stdin.on('data', function(data){
if (data.toString().trim().toLowerCase() === 'quit'){
quitting = true;
console.log('quitting');
conn.end();
process.stdin.pause();
} else {
conn.write(data);
}
});
//连接时设置最多连接十次，并且开启定时器三秒后再连接
(function connect() {
function reconnect() {
if (retriedTimes >= maxRetries) {
throw new Error('Max retries have been exceeded, I give up.');
}
retriedTimes +=1;
setTimeout(connect, retryTimeout);
}
conn = net.createConnection(port);
conn.on('connect', function() {
retriedTimes = 0;
console.log('connect to server');
});
conn.on('error', function(err) {
console.log('Error in connection:', err);
});
conn.on('close', function() {
if(! quitting) {
console.log('connection got closed, will try to reconnect');
reconnect();
}
});
//打印
conn.pipe(process.stdout, {end: false});
})();感谢你能够认真阅读完这篇文章，希望小编分享的“nodejs如何实现TCP服务器端和客户端聊天功能”这篇文章对大家有帮助，同时也希望大家多多支持创新互联成都网站设计公司，关注创新互联成都网站设计公司行业资讯频道，更多相关知识等着你来学习!
另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、网站设计器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。
本文题目：nodejs如何实现TCP服务器端和客户端聊天功能-创新互联
文章出自：
http://cdkjz.cn/article/dcodgg.html
