浅析node.js

const http = require("http")const server = http.createServer(req,res()=>{ ??res.end("hello world") })res.listen("9000")

//首先在cmd中进去我们的项目文件夹c/d/e/://进入什么盘（c还是d还是e）cd ?file//进去你的模块文件夹npm ?init//执行完这行命令后，会生成一个package.json的文件夹，文件夹中的name名要唯一，当这个文件夹存在时node就是一个包了npm ?adduser 输入账号密码npm ?publish ?上传模块然后别人就可以通过npm ?install 模块名来下载你的模块了！

npm install ?nrm ?-g//全局安装nrm ?ls ?//查看可以使用的源nrm test ?源名 ?//测试单个源的速度nrm ?use ?源名 ?//切换到你要使用的源//这样我们就可以把源切换到下载速度较快的源，就会加快好多了

const url=require("url");//url.parse()解析url,返回值是URLobject;Const ???result=url.parse("https://www.baidu.com/s?ie=utf-8&f=8&rsv_bp=1&rsv_idx=1&tn=baidu&wd=node&oq=node&rsv_pq=aea4b4650005e274&rsv_t=b6efVwyWo9RLoHnJougYq4rPh%2B83TZcEX%2BdoFLqN8zcpvB2fgErBjdboWPo&rqlang=cn&rsv_enter=0",true);//urlformat.根据URLobject生成URLconst rs=url.format(result); console.log(rs);//生成相对路径或绝对路径的一种方法console.log(url.resolve("http://www.baidu.com/a/b/c","d"));//网址是/a/b/c//<a href="/d">跳转到d</a>// ?结果是http://www.baidu.com/a/b/dconsole.log(url.resolve("http://www.baudu.com/a/b/c","/d"));//网页地址是/a/b/c// <a href="/d">跳转到d</a>//结果是http://www.baidu.com/d

const querystring = require("querystring");const str = "name%dell!age%28!gender%male";//querystring.parse 对querys字符串进行解析,seprator=&,equal=const result = querystring.parse(str,"!","%");//querystring.stringify 把对象转化成query字符串console.log(querystring.stringify(result, "!", "%"));const newStr = "a=1=2=3";console.log(querystring.unescape(querystring.escape(newStr)));

const http = require("http");//引入http核心模块const cheerio = require(‘cheerio‘);//引入cheerioconst fs = require("fs"); ////因为大多数请求都是get请求且不带请求主体，所以node.js提供了更便捷方法，该方法与http.requirest()唯一区别就是它设置请求方式为get自定调用req.end();http.get("http://www.easyvoa.com", (res) => {//http发送一个get请求 ???if(res.statusCode == 200) {//200页面加载成功 ???????let str = ""; ???????res.setEncoding(‘utf8‘);//编码避免出现乱码 ???????res.on("data", (data) => {//监听data ???????????str += data; ???????}) ???????res.on("end", () => {//触发end时间 ???????????const $ = cheerio.load(str);//用了一个第三方模块，它的感觉像是jQuery实际上不是。只是帮助我们从一个字符串里找出我们想要的字符串。 ???????????const titles = $(".title_a");把.title标签里面的内容存在titles ???????????let result = ""; ???????????for (var i = 0; i < titles.length; i++) { ???????????????result += titles.eq(i).text() + ‘\n‘; ???????????} ???????????fs.writeFileSync("list.text", result); ???????}) ???}})

const EventEmitter=require("events");//EventEmitter它大写是因为events导出来的 是一个类，而类的首字母是大写 ?class Wang extends EventEmitter{}// 自己定义了一个类继承了EvenEtmitter{} ?const wang=new Wang();//创建一个wang实例对象 ?wang.on("change",()=>{//对象有一个on方法 ?????console.log("change"); ?}) ?//wang.once("change",()=>{//once只执行一次 ?//console.log("haha"); ?//}) ?//wang.prependListener("change"); ?//wang.removeAlListener("change");wang.emit("change");//emit触发事件

const fs=require("fs"); ???//得到文件与目录的信息// fs.stat("list.text",(err,stats)=>{// ????console.log(stats.isDirectory());// }) ?????//创建一个目录// fs.mkdir("wang",(err)=>{// ????if(err){// ????????console.log(error);// ????}// }) ???????//创建文件并写入内容// fs.writeFile("lee.txt","content",(err)=>{// ????console.log(err);// } ?????fs.writeFileSync("lee1.txt","1111") ?fs.appendFileSync("lee1.txt","2222") console.log(123);// fs.readFile("lee1.txt",(err,data)=>{// ???console.log(data);//})//fs.readdir("./",())//fs.readFile("lee1.txt",(err,data)=>{// ???console.log(data);//<Buffer 31 31 31 31 32 32 32 32>//}) ???//列出目录中的东西返回一个数组//fs.readdir("./",(err,list)=>{// ???console.log(list);//返回一个数组//})// fs.rename("lee.txt","llelele.txt",()=>{})//重命名目录或文件[‘ const read=fs.createReadStream("lee1.txt"); const write=fs.createWriteStream("leecopy.txt"); read.pipe(zlib.createGzip()).pipe(write);Server.js ??const server http.createServer((req,res)={ ????If(req.url!==”/favicon.ico”){ ???????//Es6的解构赋值： ??????const {pathname,query}=url.parse(req.url,true); ??????(相当于：Pathname=url.parse(req.url,true).pathname;Query=url.parse(req.url,true).query;) ???????If(req.url==”/”){//如果访问的是根目录则返回index ??????????res.end(“index”);}if(req.url==”/list”){//如果访问的是list则返回list ??????????res.end(“list”);}else{//否则返回404 ??res.end(“404”);}}console.log(req.url);Res.end(“hello world”);}) Server.listen(“3000”);

(1)服务器端：server.js//引入net模板，net中有socketconst net=require("net");/*每个用户的连接，即保存所有用户*/const clients=[];//创建服务const server=net.createServer();//监听，当服务器被连接的时候，将连接用户保存在clients数组中server.on("connection",(client)=>{ ?????//当一个用户连接进来时，我给用户一个id ???//将用户存入所有用户这个数组中 ???client.id=clients.length; ???clients.push(client); ???//设置编码集合 ???client.setEncoding("utf8"); ???//监听用户是否给服务器发了这个数据 ???//如果发送了数据，服务器要把数据转发给其他所有用户--->群聊，聊天室 ???client.on("data",(data)=>{ ???????//将数据发送给其他所有用户 ???????for(var i=0;i<clients.length;i++){ ???????????//如果存在，发送数据 ???????????if(clients[i]){ ???????????????//转发其他用户 ???????????????clients[i].write(data); ???????????} ???????} ???}) ???//监听用户是否退出群聊 ???client.on("close",(data)=>{ ???????//如果退出，将对应id用户移除 ???????clients[client.id]=null; ???}) ???//监听用户连接是否失败 ???client.on("error",(data)=>{ ???????//如果失败，将对应id用户移除 ???????clients[client.id]=null; ???}) ???????})server.listen("9000","127.0.0.1");(2)客户端：client.js//net中有socketconst net=require("net");const readline=require("readline");//创建一个客户端const client=new net.Socket();//创建一个和命令行连接的接口（读和写）const rl = readline.createInterface({ ?input: process.stdin, ?output: process.stdout});//连接服务器client.connect("9000","127.0.0.1");//设置编码集合（buffer数据）client.setEncoding("utf8");//服务器传来数据，这里做监听client.on("data",(data)=>{ ???????console.log(data); ???})//写一个数据，往服务器发送数据client.write("w_juan");//对命令行数的监听//监听控制台输入的内容发送给服务器rl.on("line",(input)=>{ ???if(input==="quit"){ ???????//销毁 ???????rl.close(); ???????client.destory(); ???}else{ ???????client.write(input); ???}})

（1） 服务器端：const WebSocket = require(‘ws‘);const server = new WebSocket.Server({ port: 9000 });const clients = [];server.on(‘connection‘, (client) => { ???//存储用户 ???client.id = clients.length; ???clients.push(client); ???client.on(‘message‘, (message) => { ???????//一旦发送信息，将message传过去 ???????for (var i = 0; i < clients.length; i++) { ???????????clients[i] && clients[i].send(message); ???????????/*if(clients[i]){ ???????????????//转发其他用户 ???????????????clients[i].send(message); ???????????}*/ ???????} ???}); ???client.on(‘error‘, () => { ???????clients[client.id] = null; ???}); ???client.on(‘close‘, () => { ???????clients[client.id] = null; ???});});（2）客户端：<!DOCTYPE html><html> ???<head> ???????<meta charset="UTF-8"> ???????<title>聊天室</title> ???</head> ???<body> ???????<input type="text" id="input" /> ???????<button id="button" onclick="handleClick()">提交</button> ???????<div id="div1"></div> ???????<script type="text/javascript"> ???????????var client = new WebSocket("ws://127.0.0.1:9000"); ???????????input = document.getElementById("input"); ???????????div1 = document.getElementById("div1"); ???????????function handleClick() { ???????????????client.send(input.value); ???????????} ???????????client.onmessage = function(e) { ???????????????div1.innerHTML=e.data; ???????????} ???????</script> ???</body></html>