const WebSocket = require('ws')
const WebSocketServer = WebSocket.Server;
//在4000端口上打开了一个WebSocket Server，该实例由变量wss引用。
const wss =new WebSocketServer({
port:4000
})
//如果有WebSocket请求接入，wss对象可以响应connection事件来处理这个WebSocket：
wss.on('connection',function(ws){ //在connection事件中，回调函数会传入一个WebSocket的实例，表示这个WebSocket连接。
console.log(`[SERVER] connection()`);
candleMsg()
ws.on('message',function(message){ //我们通过响应message事件，在收到消息后再返回一个ECHO: xxx的消息给客户端。
console.log(`[SERVER] Received:${message}`);
setInterval(()=>{
// ws.send(`ECHO:${message}` ,(err)=>{
// if(err){
// console.log(`[SERVER] error:${err}`);
// }
// })
ws.send(candleMsg(), (err)=>console.log(err))
} , 2000)
})
})
const candleJson = require("./data/candle_stick.json");
const Low = 600
const High = 2000
const candleMsg = () => {
let data = candleJson.data
data.high = getRandom()
let low = getRandom()
data.low = low > data.high ? data.high : low
return JSON.stringify(candleJson)
}
const getRandom = ()=> Math.random() * (High - Low) + Low
/// 首先执行 npm install ws --save
/// 然后执行 node index.js 启动服务器,服务器启动后控制台没有任何输出
/// 连接成功后要先向服务器 发送一个消息后才会推送数据
基于 nodejs 的 websocket 服务器
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
- 文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
推荐阅读更多精彩内容
- https://objc.com/article/53 websocket server 基于django-pri...
- 使用 WebSocket 客户端连接 MQTT 服务器 [TOC] 简介 近年来随着 Web 前端的快速发展，浏览...
- 嗨，大家好! 我的名字是Sergey Kamardin，我是Mail.Ru的工程师。 介绍 首先介绍我们的故事的上...
- 问题 直到我写这篇文章时（2017年11月），阿里云的负载均衡（下面简称：SLB）还不支持websocket。但是...
