【Node.js】从基础到精通（三）—— HTTP 模块探索

const http = require('http');
// 创建服务器
const server = http.createServer((req, res) => {
  // 设置响应头
  res.writeHead(200, {
    'Content-Type': 'application/json'
  })
  // 向客户端发送响应数据
  res.end(JSON.stringify({
    code: 200,
    message: `Hello World!`
  }));
})
// 启动服务器 监听 3000 端口
server.listen(3000, () => {
  console.log('Server is running on port 3000...: http://localhost:3000');
});

const http = require('http');
const {parse} = require("url");
// 创建服务器
http.createServer((req, res) => {
  // 允许跨域访问
  res.setHeader("Access-Control-Allow-Origin", "*");
  // 处理不同的HTTP方法
  switch (req.method.toLowerCase()) {
    case 'get':
      handleGet(req, res);
      break;
    case 'post':
      handlePost(req, res);
      break;
    case 'delete':
      handleDelete(req, res);
      break;
    case 'put':
      handlePut(req, res);
      break;
    default:
      sendError(res, 405, "Method Not Allowed"); // 对于不支持的方法，返回错误状态码
  }
  function handleGet(req, res) {
    // 获取并解析查询参数
    const paramsObj = parse(req.url, true).query;
    respondWithSuccess(res, paramsObj);
    res.end();
  }
  function handlePost(req) {
    // POST请求通常需要读取请求体，这里假设是JSON格式
    let body = [];
    req.on('data', (chunk) => {
      body.push(chunk);
    }).on('end', () => {
      body = Buffer.concat(body).toString();
      try {
        const postData = JSON.parse(body);
        // 根据postData执行业务逻辑...
        // ...
        respondWithSuccess(res, postData);
      } catch (error) {
        sendError(res, 400, "Bad Request - Invalid JSON");
      }
    });
  }
  function handleDelete(req, res) {
    // DELETE请求可能包含URL路径中的资源标识符
    // 实际中会根据路径处理删除操作，这里仅模拟成功处理
    respondWithSuccess(res);
  }
  function handlePut(req, res) {
    // PUT请求类似POST，但通常用于更新资源
    // 同样需读取请求体并解析
    let putDataBuffer = [];
    req.on('data', (chunk) => {
      putDataBuffer.push(chunk);
    }).on('end', () => {
      // 在这里可以根据putData执行更新操作...
      // ...
      respondWithSuccess(res);
    });
  }
  function respondWithSuccess(res, data) {
    res.writeHead(200, {'Content-Type': 'application/json'});
    res.write(JSON.stringify({ code: 200, data }));
    res.end();
  }
  function sendError(res, statusCode, message) {
    res.writeHead(statusCode, {'Content-Type': 'application/json'});
    res.write(JSON.stringify({ code: statusCode, message }));
    res.end();
  }
}).listen(3000, () => {
  console.log('Server is running on port 3000...: http://localhost:3000');
});

const http = require('http');
const data = JSON.stringify({
  name: 'John',
  age: 30
})
// 创建请求对象
// GET请求
const options = {
  hostname: 'localhost',
  port: 3000,
  method: 'GET',
  path: '/?name=John&age=30',
};
// POST请求
// const options = {
//  hostname: 'localhost',
//  port: 3000,
//  // 设置请求为POST
//  method: 'POST',
//  headers: {
//    'Content-Type': 'application/json', // 设置内容类型为JSON
//    'Content-Length': Buffer.byteLength(data)
//  }
// };
// PUT请求
// const options = {
//  hostname: 'localhost',
//  port: 3000,
//  // 设置请求为PUT
//  method: 'PUT',
//  headers: {
//    'Content-Type': 'application/json', // 设置内容类型为JSON
//    'Content-Length': Buffer.byteLength(data)
//  }
// }
// DELETE请求
// const options = {
//  hostname: 'localhost',
//  port: 3000,
//  // 设置请求为DELETE
//  method: 'DELETE',
//  path: '/1',
// }
const req = http.request(options, (res) => {
  let data = '';
  // 读取响应数据并将其拼接到data变量中
  res.on('data', (chunk) => {
    data += chunk;
  });
  // 响应结束后输出响应数据
  res.on('end', () => {
    console.log(`Response received: ${data}`);
  });
});
// 处理请求错误
req.on('error', (error) => {
  console.error(`Problem with request: ${error.message}`);
});
// POST/PUT请求,写入数据到请求体
// req.write(data);
// 发送请求
req.end();