ws 服务端 nodejs 代码

var ws = require("ws");
var fs = require("fs");
// 启动基于websocket的服务器,监听我们的客户端接入进来。
var server = new ws.Server({
	host: "",
	port: 3000,
});
server.on('connection', function (ws) {
	    console.log("ok");
    ws.on('message', function (message) {
        //sqlr.getlook(ws,message);
		console.log(message);
		var ma = JSON.parse(message);
		fs.exists("./api/"+ma.function+".js", function(exists){
	 console.log(exists);
	 if(exists){
			var api = require('./api/'+ma.function);
			api.get(ws,message);
	
		}else{
	
	var g = {data:"数据不存在"}

	ws.send(JSON.stringify(g));
		}
        })
    })




})

console.log('服务开启');

评论

刷新

友情链接