热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

转nodejssocket.io初探

1、安装socket.ionpminstallsocket.io2、创建服务端代码server.jsvarapprequire(http).createServer(handler

1、安装socket.io

npm install socket.io

2、创建服务端代码server.js

转  nodejs socket.io初探
var app = require('http').createServer(handler), 
    io = require('socket.io').listen(app), 
    fs = require('fs')

app.listen(8080);
io.set('log level', 1);//将socket.io中的debug信息关闭

function handler (req, res) {
  fs.readFile(__dirname + '/index.html',function (err, data) {  
    if (err) {
      res.writeHead(500);
      return res.end('Error loading index.html');
    }    
    res.writeHead(200, {'Content-Type': 'text/html'});    
    res.end(data);
  });
}

io.sockets.on('connection', function (socket) {
    socket.emit('news', { hello: 'world' });
    socket.on('my other event', function (data) {
      console.log(data);
    });
});
转  nodejs socket.io初探

3、创建客户端代码 index.html

转  nodejs socket.io初探


    
    
         



    
    

转  nodejs socket.io初探

4、执行结果

启动服务端:

node  server.js

在浏览器输入 http://localhost:8080/index.html

浏览器打印出: world

命令行打印出:{ my: 'data' }

 

5、更多资料参见官方网站 http://socket.io/#how-to-use

6、服务端向指定客户端发送消息

思路是客户端与服务端建立连接的时候,服务端保存客户端的信息,做一个socketMap, 在socketMap中取出需要发送消息的客户端,向该客户端发送消息

做一个模拟的简单例子,这里用的是数组:

转  nodejs socket.io初探
var sockets = [];
var i = 1;
io.sockets.on('connection', function (socket) {
    sockets[i] = socket;
    i++;
    socket = sockets[1];  //这里指定向第一个客户发送消息
    console.log(i);
    
    socket.emit('news', { hello: 'world' });
    socket.on('my other event', function (data) {
      console.log(data);
    });
});
转  nodejs socket.io初探

推荐阅读
author-avatar
手机用户2502936117
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有