最近有空闲的时间就看看Node相关的，我觉得要真正掌握node得对node的一些核心模块比较熟悉才行。然后在去看其他的一些基于核心模块封装的框架(如 express/koa/egg等)或模块，这样也很好的理解框架中的内容。
Node中如何创建 web server
创建服务的步骤其实很简单，下面是Node官网中的一段代码。通过原生的方式创建了一个web server，这样就直接可以使用 http://127.0.0.1:3000 访问了。
- 使用http模块
createServer方法创建一个服务; -
createServer方法接收一个function作为参数，并进行请求处理，res.end('Hello World\n');处理请求，返回一个 Hello World 文本； - server监听 3000 端口。
const http = require('http');
const hostname = '127.0.0.1';
const port = 3000;
const server = http.createServer((req, res) => {
res.statusCode = 200;
res.setHeader('Content-Type', 'text/plain');
res.end('Hello World\n');
});
server.listen(port, hostname, () => {
console.log(`Server running at http://${hostname}:${port}/`);
});
以上是通过最原始的方式，当然也可以通过一些框架(如 express / koa / egg等)简化这些操作。
// express 创建 web server
var express = require('express');
var app = express();
app.get('/', function (req, res) {
res.send('Hello World!');
});
app.listen(3000, function () {
console.log('Example app listening on port 3000!');
});
// Koa创建web server
const Koa = require('koa');
const app = new Koa();
app.use(async ctx => {
ctx.body = 'Hello World';
});
app.listen(3000);
Node创建HTTPS服务
const https = require('https');
const fs = require('fs');
const hostname = '127.0.0.1';
const port = 443;
const options = {
key: fs.readFileSync('./ssh/private.pem'), // 秘钥
cert: fs.readFileSync('./ssh/full_chain.pem') // 证书
};
const server = https.createServer(options, (req, res) => {
res.writeHead(200);
res.end('hello world !!');
});
server.listen(port, () => {
console.log(`The server is running at http://${hostname}:${port}/`);
});
Node中的请求
通过上面创建 web server 过程可以看出，创建server的时候都对请求进行处理，否则创建web server也就意义不大了，所以创建了 server 就得使用。response 返回的内容总是会来自很多的地方，有些是直接返回一个固定的值，类似上面直接返回 Hello World 文本；有些返回的数据则是需要通过查询数据库存储的数据； 还有可能通过第三方的API对接， 下面就来看下如何请求第三方的API。
老样子，先看看Node中原生的如何来实现：
GET请求
var http = require("http");
var options = {
"method": "GET",
"hostname": "localhost",
"port": "3000",
"headers": {
"Cache-Control": "no-cache"
}
};
var req = http.request(options, function (res) {
var chunks = [];
res.on("data", function (chunk) {
chunks.push(chunk);
});
res.on("end", function () {
var body = Buffer.concat(chunks);
console.log(body.toString());
});
});
req.end();
POST请求
const postData = querystring.stringify({
'msg': 'Hello World!'
});
const options = {
hostname: 'www.google.com',
port: 80,
path: '/upload',
method: 'POST',
headers: {
'Content-Type': 'application/x-www-form-urlencoded',
'Content-Length': Buffer.byteLength(postData)
}
};
const req = http.request(options, (res) => {
console.log(`STATUS: ${res.statusCode}`);
console.log(`HEADERS: ${JSON.stringify(res.headers)}`);
res.setEncoding('utf8');
res.on('data', (chunk) => {
console.log(`BODY: ${chunk}`);
});
res.on('end', () => {
console.log('No more data in response.');
});
});
req.on('error', (e) => {
console.error(`problem with request: ${e.message}`);
});
// write data to request body
req.write(postData);
req.end();
原生的方式实现请求主要是通过 http.request 方法向第三方API发出请求。关于请求可以使用 request 模块 来简化请求的过程
var request = require("request");
var options = { method: 'GET',
url: 'http://127.0.0.1:3000',
headers:
{ 'Postman-Token': 'd11b0b66-4ef1-4f2a-b83f-dd5bab3f6fe1',
'Cache-Control': 'no-cache' } };
request(options, function (error, response, body) {
if (error) throw new Error(error);
console.log(body);
});
下面的一个小 demo 就是通过 request 和 koa 相结合的。
