nodejs简单实现TCP服务器端和客户端的聊天功能示例

作者:wwwjiahuan 时间:2024-05-03 15:55:56 

本文实例讲述了nodejs简单实现TCP服务器端和客户端的聊天功能。分享给大家供大家参考,具体如下:

服务器端


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程序设计有所帮助。

来源:http://blog.csdn.net/wwwjiahuan/article/details/63683685

标签:nodejs,TCP,聊天
0
投稿

猜你喜欢

  • python清除字符串里非数字字符的方法

    2023-08-12 02:47:32
  • 对python字典元素的添加与修改方法详解

    2023-10-19 09:36:04
  • python判断列表的连续数字范围并分块的方法

    2021-01-18 12:04:19
  • 四种Python机器学习超参数搜索方法总结

    2022-03-19 17:29:22
  • python破解WiFi教程代码,Python蹭网原理讲解

    2022-09-05 20:14:43
  • javascript ImgBox透明遮罩层背景图片展示

    2024-02-27 04:51:07
  • 基于element-ui中el-select下拉框选项过多的优化方案

    2023-07-02 17:00:50
  • python获取array中指定元素的示例

    2021-09-11 15:37:43
  • 解决大字段在Form中Post出错的方法

    2008-04-17 14:00:00
  • 30秒学会30个超实用Python代码片段【收藏版】

    2021-08-04 17:13:32
  • C#使用DataSet Datatable更新数据库的三种实现方法

    2024-01-13 23:38:20
  • asp如何制作一个弹出式的调查窗口?

    2010-06-29 21:24:00
  • nicedit 轻量级编辑器 使用心得

    2023-03-03 23:49:08
  • linux系统使用python监控apache服务器进程脚本分享

    2021-10-15 00:15:41
  • python使用ctypes模块调用windowsapi获取系统版本示例

    2023-05-04 08:46:48
  • python matplotlib库绘制散点图例题解析

    2023-08-14 03:12:56
  • Python数据类型--字典dictionary

    2023-06-19 12:49:53
  • asp如何读取一个文件内容?

    2009-11-19 17:23:00
  • Pycharm使用之设置代码字体大小和颜色主题的教程

    2021-09-07 00:27:14
  • Mysql8.0递归查询的简单用法示例

    2024-01-22 16:06:42
  • asp之家 网络编程 m.aspxhome.com