当前位置：首页 > 软件库 > Web应用开发 > Node.js 扩展 >

ws.io

Node.js 的 WebSocket 模块

授权协议 MIT

开发语言 JavaScript

所属分类 Web应用开发、 Node.js 扩展

软件类型开源软件

地区不详

投递者戚明朗

操作系统跨平台

开源组织无

适用人群未知

软件官网

软件概览

A simple wrap to node.js ws module and then we can use it in a manner like socket.io. It's really easy to use socket.io but it doesn't support Blob yet. So I write a simple wrap to ws module for this purpose. This is also a part of works from a contest by ithelp.ithome.com.tw.

Features:

trnasfer Blob/ArrayBuffer by put it in an object and emit it just as socket.io
broadcast to all but not me
emit to specified peer by socket.to(socket.id).emit('event', data)
join/leave/in room
in-memory store

Limits:

can only send one Blob/ArrayBuffer within one emit
the Blob/ArrayBuffer object must be a property of the emitting object in the first level, no deeper
no configuration support
no 3rd party data store support
cannot scale (due to current sockets management and store design)
client support is now through a static url: /ws.io/ws.io.js

install

npm install ws.io

usage

a simple echo server. (echo.js)

var app = require('http').createServer(handler),
io = require('./ws.io').listen(app);
app.listen(8443);

function handler (req, res) {
    res.setHeader('Content-Type', 'text/html');
    res.writeHead(200);
    res.end(
        "<!DOCTYPE html>"+
        "<html>"+
        "<head>"+
        "<script src='/ws.io/ws.io.js'></script>"+
        "<script>"+
        "var socket = io.connect('ws://localhost:8443');"+
        "socket.on('echo', function(data) {"+
        "    alert(data);"+
        "});"+
        "</script>"+
        "<body>"+
        "<button id='echo'>echo</button>"+
        "</body>"+
        "</html>"+
        "<script>"+
        "var button = document.getElementById('echo');"+
        "button.onclick = function() {"+
        "    socket.emit('echo', 'hello echo server.');"+
        "}"+
        "</script>"
    );
}

io.sockets.on('connection', function (socket) {
    socket.on('echo', function(data) {
        socket.emit('echo', data);
    });
});

a simple blob sharing through file api. (blob.js)

var fs = require('fs'),
url = require('url'),
app = require('http').createServer(function(req, res) {
    res.setHeader('Content-Type', 'text/html');
    res.writeHead(200);
    res.end(
        "<!DOCTYPE html>"+
        "<html>"+
        "<meta charset='utf-8'>"+
        "<head>"+
        "<style>"+
        "#panel {"+
        "    border: solid 1px #336699;"+
        "    line-height: 20px;"+
        "    vertical-align: middle;"+
        "    padding: 5px;"+
        "    border-radius: 5px;"+
        "}"+
        "</style>"+
        "<script src='/ws.io/ws.io.js'></script>"+
        "</head>"+
        "<body>"+
        "<input type='file' id='files'><br>"+
        "<div id='panel'><ul id='list'></ul></div>"+
        "</body>"+
        "</html>"+
        "<script>"+
        "var files = document.getElementById('files');"+
        "var socket = io.connect('ws://localhost:8443');"+
        "function getUrl() {"+
        "    if(!!window.URL) {"+
        "        return window.URL;"+
        "    }"+
        "    if(!!window.webkitURL) {"+
        "        return window.webkitURL;"+
        "    }"+
        "}"+
        ""+
        "files.addEventListener('change', function(e) {"+
        "    var URL = getUrl();"+
        "    if(files.files.length>0) {"+
        "        var file = files.files[0];"+
        "        if(file.type==='') {"+
        "            alert('File type unknown. Process stopped.');"+
        "            return false;"+
        "        }"+
        "        var src = URL.createObjectURL(file);"+
        "        var a = document.createElement('a');"+
        "        a.href = src;"+
        "        a.innerHTML = file.name;"+
        "        a.target = '_blank';"+
        "        var li = document.createElement('li');"+
        "        li.appendChild(a);"+
        "        document.getElementById('list').appendChild(li);"+
        "        socket.emit('share', {filename: file.name, type: file.type, file:file});"+
        "    }"+
        "});"+
        "var fileinfo;"+
        "socket.on('share', function(data) {"+
        "    var URL = getUrl();"+
        "    var a = document.createElement('a');"+
        "    var file = new Blob([data.file], {type:data.type});"+
        "    a.href = URL.createObjectURL(file);"+
        "    a.innerHTML = data.filename;"+
        "    a.target = '_blank';"+
        "    var li = document.createElement('li');"+
        "    li.appendChild(a);"+
        "    document.getElementById('list').appendChild(li);"+
        "});"+
        "</script>"
    );
}),
io = require('ws.io').listen(app);

io.sockets.on('connection', function(socket) {
    socket.on('share', function(data) {
        socket.broadcast.emit('share', data);
    });
});

app.listen(8443);

使用案例

(精华)2020年7月8日 Node.js ws和websocket.io的使用

WS 客户端1 <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <meta http-equiv="X-UA-Compatible" content="ie
websocket链接断开服务器报错java.io.EOFException解决办法

首先说一下报错原因，由于默认60s无消息交互就会关闭长连接，所以导致这个报错解决方案其实也很简单，既然是长时间没有通信导致断开，其实保持通信就好，可以设置心跳时间来解决。可以前端也可以后端，附上前端代码吧 //心跳检测 var heartCheck = { timeout: 60000,//60秒 timeoutObj: null, serverTimeoutObj:
socket.io的使用

安装 npm install socket.io # 写这篇文档时: "socket.io": "^4.5.4" 快捷使用备注：通过快捷使用的例子，就可以走通websocket的流程了。 node服务器端： import * as express from "express"; import { createServer } from "http"; import { Server } f
socket.io实现聊天功能

一、环境说明文档地址：socket.io 服务端使用express+ts 客户端使用vue3+ts 二、基本使用 1.服务端安装socket.io npm i socket.io -S 参考代码 import express from 'express'; import { Server } from 'socket.io'; import http from 'http'; const a

ws.io

Features:

Limits:

install

usage

同类工具

相关阅读

相关文章

相关问答

相关文档