【node】node的核心模块---http模块，http的服务器和客户端

http服务器和客户端

node.js标准库提供了http模块，其中封装了一个高效的http服务器和一个简易的http客户端，http.Server是一个基于事件的HTTP服务器，他的核心由Node.js下层的C++部分实现，而接口由JavaScript封装，兼顾了性能和简易性，http.request则是一个http客户端工具，用于向http服务发起请求；

创建HTTP服务器

1. http.createServer()

//服务器实例
var httpServer = require("http")
httpServer.createServer(function(req,res){
        res.writeHead(200,{"Content-Type":"text/html"});
         res.write("<h2>hello world</h2>");
        res.end("<h3>你好</h3>");
}).listen(2333);
console.log("http server is listening at port 2333，localhost:2333");

http.createServer创建了一个http.server实例，将一个函数作为HTTP请求处理函数，这个函数接受两个参数，分别是请求对象(req)和响应对象(res)，在函数体内，res显式的写回了响应代码200(表示请求成功)，指定响应头为"Content-Type":"text/html"，然后写入响应体通过res.end()结束并发送，最后调用listen函数，启动服务器并且监听2333端口

2. http.Server类

http.server是一个基于事件的http服务器，所有的请求都被封装为独立的事件，开发者只需要对他的事件编写响应函数即可实现HTTP服务器的所有功能，它继承自EventEmitter

  • connection: 当TCP链接建立时，该事件被触发，提供一个参数socket，为net.Socket的实例，connection事件的粒度要大于request,因为客户端在keep-Alive模式下可能在同一个链接内发送多次请求
wsServer.on(‘connection‘,function(sock){
 sock.on(‘a‘,function(num1,num2){
   console.log(`接到了浏览器发送的数据:${num1}`)
 })
 setInterval(function(){
   sock.emit(‘ttt‘,Math.random())
 },500)

})
  • close: 当服务器关闭时，该事件被触发，注意不是在用户连接断开时，等等事件
  • request:　每次接收到一个请求时触发。

var server = new http.Server();
server.on("request", function (req, res) {
   res.writeHead(200, { "Content-Type": "text/html" });
   res.write("<h2>node.js</h2>");
   res.end("<h3>test</h3>");
}).listen(2333);
console.log("http server is listening at port 2333:2333");

3. http.ServerResponse

http.ServerResponse是返回给客户端的信息，决定了用户最终能看到的结果，它也是由http.Server的request事件发送的，作为第二个参数传递，一般简称response或者res。

http.ServerResponse有三个重要的成员函数，用于返回响应头，响应内容以及结束请求：

（1）response.writeHead(statsCode,[headers])：向请求的客户端发送响应头，statusCode是HTTP状态码如200（请求成功），404（未找到）等，headers是一个类似关联数组的对象，表示响应头的每个属性，该函数在请求内最多只能调用一次，如果不调用，则会自动生成一个响应头。

（2）response.write(data,[encoding])：向请求的客户端发送响应内容，data是一个buffer或者字符串，表示要发送的内容，如果data是字符串，那么需要指定encoding编码方式，默认是utf-8，在response.end之前调用，response.write可以被调用多次；

（3）response.end([data],[encoding])：结束响应，告知客户端所有发送已经完成，当所有要返回的内容发送完毕的时候，该函数必须调用一次，他可接受两个参数，意义和response.write相同，如果不调用该函数，客户端将永远处于等待状态；

创建HTTP客户端

http提供了两个函数==http.request==和==http.get==，作为客户端向HTTP服务器发起请求；

1. http.request(options[, callback])

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(`状态码: ${res.statusCode}`);
  console.log(`响应头: ${JSON.stringify(res.headers)}`);
  res.setEncoding(‘utf8‘);
  res.on(‘data‘, (chunk) => {
    console.log(`响应主体: ${chunk}`);
  });
  res.on(‘end‘, () => {
    console.log(‘响应中已无数据。‘);
  });
});

req.on(‘error‘, (e) => {
  console.error(`请求遇到问题: ${e.message}`);
});

// 写入数据到请求主体
req.write(postData);
req.end();

注意，在例子中调用了 req.end()。 使用 http.request() 必须总是调用 req.end() 来表明请求的结束，即使没有数据被写入请求主体。

如果请求过程中遇到任何错误（DNS 解析错误、TCP 级的错误、或实际的 HTTP 解析错误），则在返回的请求对象中会触发 ‘error‘ 事件。 对于所有的 ‘error‘ 事件，如果没有注册监听器，则抛出错误。

以下是需要注意的几个特殊的请求头。

  • 发送 ‘Connection: keep-alive‘ 会通知 Node.js，服务器的连接应一直持续到下一个请求。
  • 发送 ‘Content-Length‘ 请求头会禁用默认的块编码。
  • 发送 ‘Expect‘ 请求头会立即发送请求头。 通常情况下，当发送 ‘Expect: 100-continue‘ 时，超时时间与 continue 事件的监听器都需要被设置。 详见 RFC2616 章节 8.2.3。
  • 发送 Authorization 请求头会替代 auth 选项计算基本身份验证。

    2. http.get(options[, callback])

    该对象在HTTP服务器内部被创建。作为第二个参数呗传入‘request‘事件

  • 接收与http.request()相同的设置。 method一直设置为GET，忽略继承自原型的属性

  • 返回: <http.ClientRequest>
http.get(‘http://nodejs.org/dist/index.json‘, (res) => {
  const { statusCode } = res;
  const contentType = res.headers[‘content-type‘];

  let error;
  if (statusCode !== 200) {
    error = new Error(‘请求失败。\n‘ +
                      `状态码: ${statusCode}`);
  } else if (!/^application\/json/.test(contentType)) {
    error = new Error(‘无效的 content-type.\n‘ +
                      `期望 application/json 但获取的是 ${contentType}`);
  }
  if (error) {
    console.error(error.message);
    // 消耗响应数据以释放内存
    res.resume();
    return;
  }

  res.setEncoding(‘utf8‘);
  let rawData = ‘‘;
  res.on(‘data‘, (chunk) => { rawData += chunk; });
  res.on(‘end‘, () => {
    try {
      const parsedData = JSON.parse(rawData);
      console.log(parsedData);
    } catch (e) {
      console.error(e.message);
    }
  });
}).on(‘error‘, (e) => {
  console.error(`错误: ${e.message}`);
});

3. http.ClientRequest

该对象在http.request()内部被创建并返回。它表示着一个正则处理的请求，其请求头已进入队列。请求头仍可使用 setHeader(name, value)、getHeader(name) 和 removeHeader(name) 进行修改。实际的请求头会与第一个数据块一起发送或当调用request.end()时发送。

  • connect事件
const http = require(‘http‘);
const net = require(‘net‘);
const url = require(‘url‘);

// 创建一个 HTTP 代理服务器
const proxy = http.createServer((req, res) => {
  res.writeHead(200, { ‘Content-Type‘: ‘text/plain‘ });
  res.end(‘okay‘);
});
proxy.on(‘connect‘, (req, cltSocket, head) => {
  // 连接到一个服务器
  const srvUrl = url.parse(`http://${req.url}`);
  const srvSocket = net.connect(srvUrl.port, srvUrl.hostname, () => {
    cltSocket.write(‘HTTP/1.1 200 Connection Established\r\n‘ +
                    ‘Proxy-agent: Node.js-Proxy\r\n‘ +
                    ‘\r\n‘);
    srvSocket.write(head);
    srvSocket.pipe(cltSocket);
    cltSocket.pipe(srvSocket);
  });
});

// 代理服务器正在运行
proxy.listen(1337, ‘127.0.0.1‘, () => {

  // 发送一个请求到代理服务器
  const options = {
    port: 1337,
    hostname: ‘127.0.0.1‘,
    method: ‘CONNECT‘,
    path: ‘www.google.com:80‘
  };

  const req = http.request(options);
  req.end();

  req.on(‘connect‘, (res, socket, head) => {
    console.log(‘已连接！‘);

    // 通过代理服务器发送一个请求
    socket.write(‘GET / HTTP/1.1\r\n‘ +
                 ‘Host: www.google.com:80\r\n‘ +
                 ‘Connection: close\r\n‘ +
                 ‘\r\n‘);
    socket.on(‘data‘, (chunk) => {
      console.log(chunk.toString());
    });
    socket.on(‘end‘, () => {
      proxy.close();
    });
  });
});

4. http.Agent

负责为HTTP客户端管理连接的持续与复用。它为一个给定的主机和端口维护着一个等待请求的队列，且为每个请求重复使用一个单一的socket连接直到队列为空，此时socket会呗销毁到一个连接池中等待被有着相同主机与端口的请求再次使用。 是否被销毁或被放入连接池取决于 keepAlive 选项。

http.get(options, (res) => {
  // 处理事情
}).on(‘socket‘, (socket) => {
  socket.emit(‘agentRemove‘);
});

当 socket 触发 ‘close‘ 事件或 ‘agentRemove‘ 事件时，它会被移出代理。 当打算长时间保持打开一个 HTTP 请求且不想它留在代理中，则可以如上处理

原文地址：https://www.cnblogs.com/teemor/p/9597573.html

时间： 2024-10-08 01:47:44

【node】node的核心模块---http模块，http的服务器和客户端的相关文章

Python 使用Socket模块编写一个简单的服务器和客户端

任务 Socket套接字开始监听后,使用accept函数来等待客户连接.这个过程在循环中无限循环,服务器处理完和客户端的连接后会再次调用accpet函数,等待下一个连接. 客户端代码 1 import socket 2 s1=socket.socket() 3 s1.bind(("127.0.0.1",2345)) 4 s1.listen(5) 5 while 1: 6 conn,address = s1.accept() 7 print("a new connect fro

Node.js进程管理之Process模块

在前面Node.js事件运行机制也有提到,Node.js应用在单个线程运行,但是现在大部分服务器都是多处理器,为了方便使用多个进程,Node.js提供了3个模块.Process模块提供了访问正在运行的进程.child_process模块可以创建子进程,并与他们通信.cluster模块提供了实现共享相同端口的集群服务能力,允许多个请求同时处理. 一.Process模块是一个无须使用require()就可以从node.js应用程序进行访问的全局对象. 二.进程I/O管道 Process为进程stdi

Node学习HTTP模块(HTTP 服务器与客户端)

Node学习HTTP模块(HTTP 服务器与客户端) Node.js 标准库提供了 http 模块,其中封装了一个高效的 HTTP 服务器和一个简易的HTTP 客户端.http.Server 是一个基于事件的 HTTP 服务器,它的核心由 Node.js 下层 C++部分实现,而接口由JavaScript封装,兼顾了高性能与简易性.http.request 则是一个HTTP 客户端工具,用于向 HTTP 服务器发起请求. 'http'模块提供两种使用方式: 作为服务端使用时,创建一个HTTP服务

Node.js入门：前后端模块的异同

通常有一些模块可以同时适用于前后端,但是在浏览器端通过script标签的载入JavaScript文件的方式与Node.js不同.Node.js在载入到最终的执行中,进行了包装,使得每个文件中的变量天然的形成在一个闭包之中,不会污染全局变量.而浏览器端则通常是裸露的JavaScript代码片段.所以为了解决前后端一致性的问题,类库开发者需要将类库代码包装在一个闭包内.以下代码片段抽取自著名类库underscore的定义方式. 1 (function () { 2 // Establish the

log4js－Node.js中的日志管理模块使用与封装

开发过程中,日志记录是必不可少的事情,尤其是生产系统中经常无法调试,因此日志就成了重要的调试信息来源. Node.js,已经有现成的开源日志模块,就是log4js,源码地址:点击打开链接 项目引用方法: npm install log4js 1.配置说明(仅以常用的dateFile日志类型举例,更多说明参考log4js-wiki): { "appenders": [ // 下面一行应该是用于跟express配合输出web请求url日志的 {"type": "

Node.js学习笔记【1】入门（服务器JS、函数式编程、阻塞与非阻塞、回调、事件、内部和外部模块）

笔记来自<Node入门>@2011 Manuel Kiessling JavaScript与Node.js Node.js事实上既是一个运行时环境,同时又是一个库. 使用Node.js时,我们不仅仅在实现一个应用,同时还实现了整个HTTP服务器. 一个基础的HTTP服务器 server.js:一个可以工作的HTTP服务器 var http = require("http"); http.createServer(function(request, response) { r

Node.js（二）【模块与url】

Nodejs模块创建模块 teacher.js导出模块 exports.add = function () {}加载模块 var teacher = require('./teacher.js');使用模块 teacher.add('Scott'); 入口文件:index.js 1 var grade = require('./grade.js'); 2 3 grade.add('John', ['小红','小明','熊大']); 模块文件:student.js 1 function add(s

深入浅出Node.js--数据通讯，NET模块运行机制

互联网的运作,最根本的驱动就是信息的交互,NodeJS 在数据交互这一块做的很带感,异步编程让人很惬意,关于 NodeJS 的数据通信,最基础的两个模块是 NET 和 HTTP,前者是基于 TCP 的封装,后者本质还是 TCP 层,只不过做了比较多的数据封装,我们视之为更高层. 本文先述说 NodeJS 的 NET 模块工作机制,下次再谈一谈 HTTP 模块. 一.服务器和客户端之间的交互 NodeJS 底层支撑是 v8,v8 是用 C++ 编写的一个编译和运行 JavaScript 代码的库,

node.js中通过dgram数据报模块创建UDP服务器和客户端

node.js中 dgram 模块提供了udp数据包的socket实现,可以方便的创建udp服务器和客户端. 一.创建UDP服务器和客户端 服务端: const dgram = require('dgram'); //创建upd套接字 //参数一表示套接字类型,'udp4' 或 'udp6' //参数二表示事件监听函数,'message' 事件监听器 let server = dgram.createSocket('udp4'); //绑定端口和主机地址 server.bind(8888, '1