文档章节

nodejs简易聊天室

木头
 木头
发布于 2012/05/11 17:34
字数 245
阅读 3069
收藏 7

第一个nodejs简易聊天室

var net = require('net');

var clients = [];

function Client(stream) {
  this.name = null;
  this.stream = stream;
}

var server = net.createServer(function (stream) {
  stream.setEncoding('utf-8');
  var address = stream.remoteAddress;
  var client = new Client(stream);
  if (address === '127.0.0.1') {
    client.name = 'system';
    clients.push(client);
  } else {
    stream.write('请在10s内输入您的昵称!\n');
  }

  var timeout = setTimeout(function () {
    if (client.name === null) {
      stream.write('对不起,您已经超时!\n');
      stream.end();
    }
  }, 10000);

  stream.on('data', function(data) {
    if (client.name === null) {
      var name = data.match(/\S+/);
      name = name[0];
      var flag = false;
      for (var key in clients) {
        if (clients[key].name === name) {
          flag = true;
          stream.write('对不起,该昵称已被使用,请换个试试!\n');
          break;
        }
      }
      if (flag) {
        return;
      }
      client.name = name;
      console.log(client.name, '进入聊天室');
      stream.write('欢迎您进入聊天室!\n');
      clients.forEach(function(c) {
        c.stream.write(client.name+' 进入聊天室!\n');
      });
      clients.push(client);
      return;
    }

    clients.forEach(function(c) {
      if (c !== client) {
        c.stream.write(client.name+" : "+data);
      }
    });
  });

  stream.on('end', function() {
    var position = -1;
    clients.forEach(function(c, index) {
      if (c === client) {
        position = index;
      }
      if (c !== client && client.name !== null) {
        c.stream.write(client.name+' 离开了!\n');
      }
    });
    stream.end();
    if (position >= 0) {
      clients.splice(position, 1);
    }
  });

  stream.on('error', function(err) {
    var position = -1;
    clients.forEach(function(c, index) {
      if (c === client) {
        position = index;
      }
      if (c !== client && client.name !== null) {
        c.stream.write(client.name+' 异常退出!\n');
      }
    });
    stream.end();
    if (position >= 0) {
      clients.splice(position, 1);
    }
  });
});

server.listen(8000);

© 著作权归作者所有

共有 人打赏支持
上一篇: java删除list元素
下一篇: mongodb主从配置
木头
粉丝 6
博文 33
码字总数 8470
作品 0
无锡
高级程序员
私信 提问
加载中

评论(9)

木头
木头

引用来自“林海寻缘”的评论

77行,console····
多谢指正
林海寻缘
林海寻缘
77行,console····
木头
木头

引用来自“zhishaofei3”的评论

E:\nodejs\chatroom>node index.js

events.js:72
throw er; // Unhandled 'error' event
^
Error: listen EADDRINUSE
at errnoException (net.js:901:11)
at Server._listen2 (net.js:1039:14)
at listen (net.js:1061:10)
at Server.listen (net.js:1127:5)
at Object.<anonymous> (E:\nodejs\chatroom\index.js:77:8)
at Module._compile (module.js:456:26)
at Object.Module._extensions..js (module.js:474:10)
at Module.load (module.js:356:32)
at Function.Module._load (module.js:312:12)
at Function.Module.runMain (module.js:497:10)

恩,的确存在错误事件没有处理,感谢,已更新。
z
zhishaofei3
E:\nodejs\chatroom>node index.js

events.js:72
throw er; // Unhandled 'error' event
^
Error: listen EADDRINUSE
at errnoException (net.js:901:11)
at Server._listen2 (net.js:1039:14)
at listen (net.js:1061:10)
at Server.listen (net.js:1127:5)
at Object.<anonymous> (E:\nodejs\chatroom\index.js:77:8)
at Module._compile (module.js:456:26)
at Object.Module._extensions..js (module.js:474:10)
at Module.load (module.js:356:32)
at Function.Module._load (module.js:312:12)
at Function.Module.runMain (module.js:497:10)
这个男人来自地球
这个男人来自地球

引用来自“木头”的评论

引用来自“kevinLOHO”的评论

不能用啊

这个代码有测试过,运行正常。能把你的错误贴出来吗?

在浏览器那里输入什么地址
这个男人来自地球
这个男人来自地球

引用来自“木头”的评论

引用来自“kevinLOHO”的评论

不能用啊

这个代码有测试过,运行正常。能把你的错误贴出来吗?

在浏览器那里输入什么地址
这个男人来自地球
这个男人来自地球

引用来自“木头”的评论

引用来自“kevinLOHO”的评论

不能用啊

这个代码有测试过,运行正常。能把你的错误贴出来吗?

没有反应。。
木头
木头

引用来自“kevinLOHO”的评论

不能用啊

这个代码有测试过,运行正常。能把你的错误贴出来吗?
k
kevinLOHO
不能用啊
nodejs入门——搭建一个聊天室应用

个人博客 http://mvc.coding.io/ 1入门教程推荐 node入门 很早之前看的就是这个,比较浅显易懂,看一遍就明白nodejs到底是怎么一回事儿了 2开源项目 昨天在coding上看到了一个nodejs聊天室,...

蛙牛
2014/08/06
0
6
NODE.JS & HTML5 聊天室

最近学习了一下 HTML5 + node.js,一边学习一边做例子。 用 node.js 制作 Server 端,提供 http & webSocket 服务,其中 webSocket 使用的是 socket.io 前台采用的是 静态的html 页面,用 ht...

zTree
2012/08/14
0
2
【求助】谁知道 node-websocket-server 框架怎么用,麻烦帮忙看一下

本人是名在校大三学生,刚接触nodejs不到一个星期,看了node入门 然后主要是想用nodejs结合websocket和WebGL搞一个小开发,正好在本站和其他地方都有许多讲nodejs与websocket结合的文章,其中在w...

冯焰
2012/02/04
1K
2
使用node.js + socket.io + redis实现基本的聊天室场景

使用node.js + socket.io + redis实现基本的聊天室场景 在这篇文章Redis数据库及其基本操作中介绍了Redis及redis-cli的基本操作. 其中的publish-subscribe机制应用比较广泛, 那么接下来使用n...

蜗牛奔跑
2017/10/18
0
0
WebRTC基础实践 - 7. 配置信令服务

本节内容 在本节课程中, 我们将学习以下内容: 通过 安装 文件中指定的项目依赖 运行Node.js服务器, 通过 node-static 提供静态文件服务。 用Socket.IO创建消息传递服务 创建聊天室以及发送聊...

铁锚
2018/11/28
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Spring Batch @EnableBatchIntegration 注解

设置一个远程分块任务需要定义一系列的 beans: 一个连接工程来从消息中间件中获得连接,消息中间件包括有(JMS,AMQP 和其他) 一个 MessagingTemplate 来从主向从发送消息,然后再次发送回...

honeymose
31分钟前
1
0
【剑指offer纪念版】--9 斐波那契数列

题目:斐波那契数列 题目:写一个函数,输入n,求斐波那契(Fibonacci)数列的第n项。斐波那契数列的定义如下:  求解 通过求解第10项的调用过程图来分析: package aigorithm;public cla...

细节探索者
36分钟前
1
0
浏览器缓存

HTTP缓存类型 200 from cache:直接从本地缓存获取响应,可细分为from disk cache, from memory cache 304 Not Modified:协商缓存,本地未命中发送校验数据到服务端,如果服务端数据没有改变,则读...

关元
今天
3
0
正则表达式简单使用说明

在Python3里确实简单明了,测试样例如下 # 正则content = 'Hello 1234567 World_This is a Regex Demo'# 贪婪匹配 尽可能多的匹配result = re.match('^He.*(\d+).*Demo$', co......

轻轻的往前走
今天
3
0
多线程创建方式

一、基本概念 进程:就是正在运行的应用程序,进程是线程的集合。 线程:就是进程中的一条执行路径,一个独立的执行单元。 多线程:就是为了提高程序的效率,使用多线程,每个线程互不影响,...

秋至丶枫以落
今天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部