# 简单搭建一个NodeJs Http服务

//引入http模块
var http = require("http");
var url = require('url');
var hostName = '127.0.0.1';
var port = 8080;
//创建服务
var server = http.createServer(function(req,res){
    res.setHeader('Content-Type','text/plain');
    res.setHeader('Access-Control-Allow-Origin',"*");
    res.setHeader("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept"); 

    var isUrl = url.parse(req.url).pathname  //请求路径
    console.log(isUrl);
    if(isUrl === '/test'){
        res.end("访问到路径为test的Controller");//返回参数
        var rdata  =  url.parse(req.url,true).query;   //获取参数
        console.log(rdata); 
    }else{
        res.writeHead(404);
        res.end('404 Not Found');
    }
});

server.listen(port,hostName,function(){
    console.log(`服务器运行在http://${hostName}:${port}`);
});
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

# 搭建websocket服务

var ws = require("nodejs-websocket");
ws.createServer(function(conn){
    conn.on("text", function (str) {
        console.log("收到的信息为:"+str)
        conn.sendText("success");
    })
    conn.on("close", function (code, reason) {
        console.log("关闭连接")
    });
    conn.on("error", function (code, reason) {
        console.log("异常关闭")
    });
}).listen(8001)
console.log("WebSocket建立完毕")
1
2
3
4
5
6
7
8
9
10
11
12
13
14

# 客户端访问websocket

const socket = new WebSocket('ws://127.0.0.1:8001');
socket.onopen = function(event){
    // 发送一个初始化消息
    socket.send('hello server!');
    // 监听消息
    socket.onmessage = function(event){
        console.log('收到服务器的推送',event);
    };
    // 监听Socket的关闭
    socket.onclose = function(event){
        console.log('Client notified socket has closed',event);
    };
    // 关闭Socket.... 
    //socket.close()
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
Last Updated: 3/4/2019, 4:34:52 PM