标签：function handle nodejs url 初入 ws var response

序言：

为了真正实现自己上线一个软件从现在开始学习后端

初入nodejs学到的内容：

首先理解的后端流程大概轮廓是

创建服务器
编写路由
编写路由拦截器（GET、POST）
连接数据库
实现数据库的增删改查

接着就是学习express.js 和 Koa.js 这两个基于nodejs的框架

我们一步一步来

创建服务器

http.createServer传入一个方法来创建服务器
该方法入参 request 和 response 即为访问服务器的请求和响应

代码中的writeHead用于写响应的头部通过改变Content-Type来改变响应体的数据类型

对数据的响应代码中也有体现出来
一种是响应非文件数据则使用 res.end()的语法，将内容以字符串形式放入进行响应
另外一个响应文件数据，代码中响应一个html文件，则使用fs来创建一个读取流，使用管道pipe将流传入response中

var http = require("http");
var fs = require("fs")
const { stringify } = require("querystring");

var service = http.createServer(function(req , res){
    console.log("request");
    
    // 传输数据
    res.writeHead(200 , {
        // "Content-Type" : 'text/plain' // 传输文本
        "Content-Type" : 'text/html' // 传输html
        // "Content-Type" : 'application/json' // 传输json
    })// 设置请求头

    var obj = {
        name : "name",
        id : "id"
    }
    // res.end(JSON.stringify(obj))

    // 可以利用读取文件进行传输
    var myReadStream = fs.createReadStream(__dirname + '/index.html' , 'utf8');
    myReadStream.pipe(res)
})  

// 监听服务器
service.listen(3000,'127.0.0.1') // 端口以及本地地址

编写路由

我对路由的理解其实就是使用接口进行请求时接口的key值
例如 localhost:8000/api/getData 这里的/getData就是路由的主体
通过编写路由来确认前端请求哪些什么接口获取什么数据
我认为也就是后端与前端的主要连接位置

在这里直接使用一个较为复杂的例子来讲解

首先启动服务器，这里将启动服务的代码封装起来 server.js

var http = require('http');

/**
 * 启动服务器
 * @param {*} router 路由表与服务器的连接函数
 * @param {*} handle 路由表 
 */
function startServer(router, handle){
    var server = http.createServer(function(request , response){
        router(handle,request.url,response)
    })

    server.listen(3000,'127.0.0.1')
    console.log("服务器运行在3000端口上")

}

module.exports = {
    startServer
}

在index.js文件中导入
封装的startServer传入两个参数分别为路由处理方法router以及路由表handle

var server = require('./server.js')
var handler = require('./handle.js')
var router = require('./router.js')

/**
 * 相当于路由表 路由对应的端口
 */
var handle = {}
handle['/'] = handler.home
handle['/home'] = handler.home
handle['/user'] = handler.user

server.startServer(router, handle)

可以理解为 handle 来指明你请求的哪个路由对应了哪个路由的响应方法
router 即为他们的操盘手将 response 和 path 和 handle 结合在一起

因此有handle.js:

var fs = require('fs')
var data = require('./user.js')

// 给予端口 封装端口状态码以及传递的内容（html\json)
function home(response){
    response.writeHead(200 , {"Content-Type" : 'text/html'})
    fs.createReadStream(__dirname + '/home.html','utf8').pipe(response)
}

function user(response){
    response.writeHead(200 , {"Content-Type" : 'application/json'})
    response.end(JSON.stringify(data))
}

module.exports = {
    home,
    user
}

router.js:

var fs = require('fs')

/**
 * 
 * @param {*} handle 路由表
 * @param {*} pathname url
 * @param {*} response 传入界面接口 将要渲染的内容放入此处
 */
function router(handle,pathname,response){
    if(typeof handle[pathname] === 'function'){
        handle[pathname](response)
    }else{
        response.writeHead(404 , {"Content-Type" : "text/html"});
		fs.createReadStream(__dirname + "/404.html","utf8").pipe(response);
    }
}

module.exports =  router

可能有点绕当时学的时候也花蛮长时间才顺通

路由拦截实现GET、post请求

上一节学习的路由编写里的请求其实都是get请求默认如此
而工作中最常见的还是POST请求

首先要认清GET和POST的区别
对于我来说最大的区别就是POST传参数是在负载中 GET传参数是在路由末尾通过？的形式添加

因此我们首先需要获取请求中的参数
GET请求获取的思路是截取后面一段url POST是使用库方法直接获取
可以通过request.method来区分POST还是GET

因此server.js:

var http = require('http');
var url = require('url')
var querystring = require('querystring')


/**
 * 启动服务器
 * @param {*} router 路由表与服务器的连接函数
 * @param {*} handle 路由表 
 */
function startServer(router, handle){
    var server = http.createServer(function(request , response){
        console.log(request.url) // 获取整段url
        var pathname = url.parse(request.url).pathname
        console.log(pathname) // 获取url中的pathname部分
        var data = [] // 用于存储从接口中获取的数据
        var params = {} // 用于存储请求中的数据
        request.on('error' , function(err){
            console.log(err); // 输出报错
        }).on('data' , function(chunk){
            data.push(chunk) // 存储数据
        }).on('end',function(){ // 读取结束
            console.log(request.method) // 输出请求类型
            if(request.method === 'POST'){
                data = Buffer.concat(data).toString(); // 此时被转化为字符串类型
                data = querystring.parse(data)
                params = data
            }else if(request.method === 'GET'){
                var param = url.parse(request.url,true).query // 获取url中的参数部分  url？name="xxx" true:【对象】 false:【字符串】
                params = param
            }else{}
        })


        // router(handle,request.url,response)
        // 为避免服务器连同参数部分一起读取从而无法判断正确url , 应该用pathname部分代替整段url
        router(handle,pathname,response,params)
    })

    server.listen(3000,'127.0.0.1')
    console.log("服务器运行在3000端口上")

}

module.exports = {
    startServer
}

获取到参数后用params进行装载通过router传入handle handle再根据params进行特殊处理即可

连接数据库

连接数据库很简单有个包叫mysql
第一步安装mysql包
npm install mysql --save--dev
第二步使用代码进行数据库连接：

const mysql = require('mysql2/promise');  
  
async function connectToDatabase() {  
    try {  
        const connection = await mysql.createConnection({  
            host: 'localhost',  
            user: 'yourUsername',  
            database: 'yourDatabaseName',  
            password: 'yourPassword',  
            waitForConnections: true,  
            connectionLimit: 10,  
            queueLimit: 0  
        });  
  
        await connection.connect();  
  
        console.log('成功连接到MySQL数据库');  
  
        // // 示例：插入数据（INSERT）  
        // const insertQuery = 'INSERT INTO yourTable (column1, column2) VALUES (?, ?)';  
        // const insertResult = await connection.execute(insertQuery, ['value1', 'value2']);  
        // console.log('插入数据成功', insertResult);  
  
        // // 示例：查询数据（SELECT）  
        // const selectQuery = 'SELECT * FROM yourTable WHERE column1 = ?';  
        // const [rows, fields] = await connection.execute(selectQuery, ['value1']);  
        // console.log('查询结果', rows);  
  
        // // 示例：更新数据（UPDATE）  
        // const updateQuery = 'UPDATE yourTable SET column2 = ? WHERE column1 = ?';  
        // const updateResult = await connection.execute(updateQuery, ['newValue', 'value1']);  
        // console.log('更新数据成功', updateResult.affectedRows);  
  
        // // 示例：删除数据（DELETE）  
        // const deleteQuery = 'DELETE FROM yourTable WHERE column1 = ?';  
        // const deleteResult = await connection.execute(deleteQuery, ['value1']);  
        // console.log('删除数据成功', deleteResult.affectedRows);  
  
        // 关闭连接  
        await connection.end();  
  
    } catch (error) {  
        console.error('连接到MySQL数据库时发生错误:', error);  
    }  
}  
  
connectToDatabase();

代码里还写了关于数据库的增删改查的简单方法
ps:此段代码还未运行过本人另外在express.js框架里也用过该包成功进行数据库连接

nodejs基于webSocket实现聊天功能

主要是之前看别人用go写websocket觉得好高大上当时自己搞半天都没搞通现在知道js也可以写后端就赶紧来试着实现

安装 `ws` 库

首先，你需要通过 npm 安装 ws 库。在你的 Node.js 项目目录下打开终端或命令提示符，然后运行：

npm install ws

创建 WebSocket 服务器

以下是一个简单的 WebSocket 服务器示例，使用 ws 库：

const WebSocket = require('ws');

const wss = new WebSocket.Server({ port: 8080 });

wss.on('connection', function connection(ws) {
  ws.on('message', function incoming(message) {
    console.log('received: %s', message);
  });

  ws.send('something');
});

console.log('WebSocket server is running on ws://localhost:8080');

在这个例子中，服务器监听 8080 端口，并在每个新的 WebSocket 连接上打印接收到的消息，并向客户端发送一条消息。

创建 WebSocket 客户端

客户端可以使用原生的 WebSocket API，如果你是在浏览器环境中，或者你也可以在 Node.js 中使用 ws 库来模拟客户端：

const WebSocket = require('ws');

const ws = new WebSocket('ws://localhost:8080');

ws.on('open', function open() {
  ws.send('Hello Server!');
});

ws.on('message', function incoming(data) {
  console.log(data);
});

ws.on('error', function error(err) {
  console.error(err);
});

这段代码创建了一个 WebSocket 客户端，连接到 ws://localhost:8080，发送一条消息，并打印从服务器接收到的任何消息。

标签：function,handle,nodejs,url,初入,ws,var,response
From： https://www.cnblogs.com/ZhongGL/p/18385219

初入nodejs

序言：

初入nodejs学到的内容：

创建服务器

编写路由

路由拦截实现GET、post请求

连接数据库

nodejs基于webSocket实现聊天功能

安装 `ws` 库

创建 WebSocket 服务器

创建 WebSocket 客户端

相关文章

赞助商

阅读排行

初入nodejs

序言：

初入nodejs学到的内容：

创建服务器

编写路由

路由拦截实现GET、post请求

连接数据库

nodejs基于webSocket实现聊天功能

安装 ws 库

创建 WebSocket 服务器

创建 WebSocket 客户端

相关文章

赞助商

阅读排行

安装 `ws` 库