nodejs/requestHandlers.js at master · Cathrine0813/nodejs · GitHub

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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
// // 作为路由目标的函数称为请求处理程序

// var exec = require("child_process").exec;//新的Node.js模块，child_process。之所以用它，是为了实现一个既简单又实用的非阻塞操作：exec()。
// var querystring = require("querystring");
// var fs = require("fs");//将该文件读取到我们的服务器中
// var formidable = require("formidable");

// //仔细想想，有一大堆东西，每个都要映射到一个字符串（就是请求的URL）上？似乎关联数组（associative array）能完美胜任。
// //不过结果有点令人失望，JavaScript没提供关联数组 -- 也可以说它提供了？事实上，在JavaScript中，真正能提供此类功能的是它的对象。
// //确定将一系列请求处理程序通过一个对象来传递，并且需要使用松耦合的方式将这个对象注入到route()函数中。
// function start(response, postData) {
//     console.log("Request handler 'start' was called")

//     // var content = "Hello Start1"
//     // function sleep(milliSeconds) {
//     //     var startTime = new Date().getTime();
//     //     while (new Date().getTime() < startTime + milliSeconds);
//     //     content = "Hello Start2"
//     // }

//     // sleep(10000)//模拟休眠10秒,阻塞操作
//     /**
//      * Node.js可以在不新增额外线程的情况下，依然可以对任务进行并行处理 —— Node.js是单线程的。
//      * 它通过事件轮询（event loop）来实现并行操作，对此，我们应该要充分利用这一点 —— 尽可能的避免阻塞操作，取而代之，多使用非阻塞操作。
//      * 然而，要用非阻塞操作，我们需要使用回调，通过将函数作为参数传递给其他需要花时间做处理的函数（比方说，休眠10秒，或者查询数据库，又或者是进行大量的计算）。
//      * 对于Node.js来说，它是这样处理的：“嘿，probablyExpensiveFunction()（译者注：这里指的就是需要花时间处理的函数），你继续处理你的事情，我（Node.js线程）先不等你了，我继续去处理你后面的代码，请你提供一个callbackFunction()，等你处理完之后我会去调用该回调函数的，谢谢！”
//      */

//     // var content = "empty"

//     //------------错误的非阻塞【我们的代码是同步执行的，这就意味着在调用exec()之后，Node.js会立即执行 return content ；在这个时候，content仍然是“empty”，因为传递给exec()的回调函数还未执行到——因为exec()的操作是异步的。
//     //exec() 它从Node.js来执行一个shell命令。
//     //在上述例子中，我们用它来获取当前目录下所有的文件（“ls-lah”）,然后，当 /start URL请求的时候将文件信息输出到浏览器中。
//     // exec("ls-lah", function (error, stdout, stderr) {
//     //     content = stdout
//     // })
//     // return content


//     //------------
//     exec("find /",
//     { timeout: 10000, maxBuffer: 20000*1024 },
//     function (error, stdout, stderr) {
//       response.writeHead(200, {"Content-Type": "text/plain"});
//       console.log(111,stdout)
//       response.write('111');
//       response.end();
//     });
// }

// function upload(response, postData) {
//     console.log("Request handler 'upload' was called")

//     //node-formidable会处理将上传的文件保存到本地/tmp目录中
//     var form = new formidable.IncomingForm();
//     console.log("about to parse");
//     form.parse(request, function (error, fields, files) {
//         console.log("parsing done");
//         //确保该文件保存成/tmp/test.png。 采用fs.renameSync(path1,path2)重命名 来实现
//         //同步执行
//         fs.renameSync(files.upload.path, "/tmp/test.png");
//         response.writeHead(200, { "Content-Type": "text/html" });
//         response.write("recived image:<br/>");
//         response.wrire("<img src='/show'/>");
//         response.end();
//     })


//     // response.writeHead(200, {"Content-Type": "text/plain"});
//     // response.write("Hello Upload");
//     // response.write("You've sent the text:"+querystring.parse(postData));
//     // response.end();
//     // return "Hello Upload"
// }


// function imports(response, postData){
//     console.log("Request handler 'imports' was called")
//     /**
//      * 1、在/start表单中添加一个文件上传元素
//      *      在HTML表单中，添加一个multipart/form-data的编码类型，
//      *      移除此前的文本区，添加一个文件上传组件，
//      *      并将提交按钮的文案改为“Upload file”即可
//      * 2、将node-formidable整合到我们的upload请求处理程序中，用于将上传的图片保存到/tmp/test.png
//      *
//      * 3、将上传的图片内嵌到/uploadURL输出的HTML中
//      *
//      */
//     // var body = '<html><head><meta http-equiv="Content-Type" content="text/html;charset=UTF-8"/></head>' +
//     // '<body><form action="/upload" method="post"><textarea name="text" rows="20" cols="60"></textarea><input type="submit" value="Submit text"/></form></body></html>'
//     var body = '<html><head><meta http-equiv="Content-Type" content="text/html;charset=UTF-8"/></head>' +
//     '<body><form action="/upload" enctype="multipart/form-data" method="post"><input type="file" name="upload"/><input type="submit" value="Upload file"/></form></body></html>'

//     response.writeHead(200, { "Content-Type": "text/html" });
//     response.write(body);
//     response.end();
// }


// function show(response, postData) {
//     console.log("Request handler 'show' was called.")

//     fs.readFile("/tmp/test.png", "binary", function (error, file) {
//         if (error) {
//             response.writeHead(500, { "Content-Type": "text/plain" });
//             response.write(error + "\n");
//             response.end();
//         } else {
//             response.writeHead(200, { "Content-Type": "image/png" });
//             response.write(file, "binary");
//             response.end()
//         }
//     })
// }


// exports.start = start
// exports.upload = upload
// exports.imports = imports
// exports.show = show


var querystring = require("querystring"),
    fs = require("fs"),
    formidable = require("formidable");

function start(response) {
  console.log("Request handler 'start' was called.");

  var body = '<html>'+
    '<head>'+
    '<meta http-equiv="Content-Type" '+
    'content="text/html; charset=UTF-8" />'+
    '</head>'+
    '<body>'+
    '<form action="/upload" enctype="multipart/form-data" '+
    'method="post">'+
    '<input type="file" name="upload" multiple="multiple">'+
    '<input type="submit" value="Upload file" />'+
    '</form>'+
    '</body>'+
    '</html>';

    response.writeHead(200, {"Content-Type": "text/html"});
    response.write(body);
    response.end();
}

function upload(response, request) {
  console.log("Request handler 'upload' was called.");

  var form = new formidable.IncomingForm();
  console.log("about to parse");
  form.parse(request, function(error, fields, files) {
    console.log("parsing done");

    /* Possible error on Windows systems:
       tried to rename to an already existing file */
    fs.rename(files.upload.path, "/tmp/test.png", function(err) {
      if (err) {
        fs.unlink("/tmp/test.png");
        fs.rename(files.upload.path, "/tmp/test.png");
      }
    });
    response.writeHead(200, {"Content-Type": "text/html"});
    response.write("received image:<br/>");
    response.write("<img src='/show' />");
    response.end();
  });
}

function show(response) {
  console.log("Request handler 'show' was called.");
  response.writeHead(200, {"Content-Type": "image/png"});
  fs.createReadStream("/tmp/test.png").pipe(response);
}

exports.start = start;
exports.upload = upload;
exports.show = show;