博客
关于我
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/

    你可能感兴趣的文章
    PostgreSQL Daily Maintenance - cluster table
    查看>>
    PostgreSQL on Linux 最佳部署手册
    查看>>
    PostgreSQL Oracle 兼容性之 - pipelined
    查看>>
    PostgreSQL Point-In-Time Recovery (Incremental Backup)
    查看>>
    postgresql Streaming Replication监控与注意事项
    查看>>
    postgresql 不需要付费_使用数据传输在PostgreSQL执行 外部连接运算符
    查看>>
    postgresql 主从配置_生产环境postgresql主从环境配置
    查看>>
    postgresql 函数&存储过程 ; 递归查询
    查看>>
    PostgreSQL 分组聚合查询中 filter 子句替换 case when
    查看>>
    PostgreSQL 同步流复制锁瓶颈分析
    查看>>
    PostgreSQL 备份与还原命令 pg_dump
    查看>>
    Postgresql 外部表插件postgres_fdw的安装和使用
    查看>>
    PostgreSQL 如何从崩溃状态恢复(上)
    查看>>
    PostgreSQL 存储过程基本语法
    查看>>
    PostgreSQL 实现批量更新、删除、插入
    查看>>
    PostgreSQL 导入 .gz 备份文件
    查看>>
    PostgreSQL 批量插入&更新数据时报错(ERROR: ON CONFLICT DO UPDATE command cannot affect row a second time)
    查看>>
    PostgreSQL 新增数据返回自增ID
    查看>>
    postgresql 更新多列数据
    查看>>
    PostgreSQL 服务启动后停止
    查看>>