博客
关于我
socket.io
阅读量:527 次
发布时间:2019-03-08

本文共 940 字,大约阅读时间需要 3 分钟。

const Koa = require('koa');const Router = require('koa-router');const static = require('koa-static');const app = new Koa();const router = new Router();

// 配置静态文件目录app.use(static(__dirname + '/static'));

// 定义路由router.get('/text', ctx => {ctx.body = '欢迎访问我的 node.js 服务器!';});

// WebSocket配置const server = require('http').createServer(app.callback());const io = require('socket.io')(server);

io.on('connection', socket => {console.log('已连接');// 定期发送数据const userdata = {name: '测试用户',age: 18};// setInterval(() => {// io.emit('getData', userdata);// }, 1000);

socket.on('addData', data => {    console.log('收到数据:', data);    io.emit('getData', data);});

});

server.listen(8989, () => {console.log('服务器已启动,监听地址为 http://localhost:8989');});

// 功能介绍:// 1. 使用 Koa框架搭建 HTTP 服务器// 2. 配置静态文件访问目录// 3. 配置 WebSocket 服务// 4. 实现动态数据接收和发送

注:

  • 本代码基于 ES6 式语法,建议启用相应的语法支持
  • WebSocket 实现一个简单的数据发送机制
  • 可根据实际需求添加更多 WebSocket 消息处理逻辑
  • 服务器监听地址为 http://localhost:8989 模块路径
  • 转载地址:http://gawiz.baihongyu.com/

    你可能感兴趣的文章
    ReentrantReadWriteLock读写锁解析
    查看>>
    php laravel请求处理管道(装饰者模式)
    查看>>
    PHP mongoDB 操作
    查看>>
    ReentrantLock读写锁
    查看>>
    php mysql procedure获取多个结果集
    查看>>
    php mysql query 行数,PHP和MySQL:返回的行数
    查看>>
    PHP mysql_real_escape_string() 函数防SQL注入
    查看>>
    php mysql优化方法_MySQL优化常用方法
    查看>>
    PHP OAuth 2.0 Server
    查看>>
    php odbc驱动,php常用ODBC函数集(详细)
    查看>>
    php openssl aes ecb,php openssl_encrypt AES-128-ECB iOS
    查看>>
    php paypal rest api,PayPal REST API指定网络配置文件PHP
    查看>>
    php pcntl 多进程学习
    查看>>
    PHP pcntl_fork不能在web服务器中使用的变通方法
    查看>>
    php private ,public protected三者的区别
    查看>>
    php PSR规范
    查看>>
    php rand() 重复,array_rand()函数从另外一个数组中随机取得的一定数量的数组的元素是否会重复?...
    查看>>
    php redis pub/sub(Publish/Subscribe,发布/订阅的信息系统)之基本使用
    查看>>
    php redis 集群扩展类文件
    查看>>
    php redis(2)
    查看>>