let http = require("http");

let fs = require("fs");

let path = require("path");

let cheerio = require("cheerio");

let iconv = require("iconv-lite");

let EventEmitter = require("events");

let targetUrl = "http://www.27270.com/ent/meinvtupian/"

//定義一個類繼承由events導出的EventEmitter

class myEmitter extends EventEmitter{

? ? init(){

? ? ? ? //注冊downHtmlSuccess，當觸發(fā)這個事件時伐憾，調(diào)用里面的方法this.parseHtml(result)

? ? ? ? this.on("downHtmlSuccess",(result)=>{

? ? ? ? ? ? this.parseHtml(result)

? ? ? ? })

? ? ? ? //parseHtmlSuccess偿乖，當觸發(fā)這個事件時，調(diào)用里面的方法this.downImages(result)

? ? ? ? this.on("parseHtmlSuccess",(result)=>{

? ? ? ? ? ? this.downImages(result)

? ? ? ? })

? ? ? ? //最開始運行的是下面這個方法

? ? ? ? this.downHtml(targetUrl)

? ? }

? ? downHtml(targetUrl) {

? ? ? ? let chunks = []

? ? ? ? http.get(targetUrl,(response)=>{

? ? ? ? ? ? response.on("data",(chunk)=>{

? ? ? ? ? ? ? ? chunks.push(chunk)

? ? ? ? ? ? })

? ? ? ? ? ? response.on("end",()=>{

? ? ? ? ? ? ? ? //重新編碼原h(huán)tml的源代碼，下面是死操作

? ? ? ? ? ? ? ? let htmlTar = iconv.decode(Buffer.concat(chunks),"gb2312");

? ? ? ? ? ? ? ? this.emit("downHtmlSuccess",htmlTar)

? ? ? ? ? ? })

? ? ? ? })

? ? }

? ? parseHtml(htmlTar){

? ? ? ? let $ = cheerio.load(htmlTar);

? ? ? ? let result = []

? ? ? ? let imgTags = $("div.MeinvTuPianBox>ul>li>a>i>img").toArray();

? ? ? ? for (let i = 0; i < imgTags.length; i++) {

? ? ? ? ? ? /*★★★尤其要注意鞠值，這里要把每個元素轉成DOM對象再取attr值矿辽，所以下面兩行是錯的*/

? ? ? ? ? ? /*let src = imgTags[i].src

? ? ? ? ? ? let imgName = imgTags[i].alt*/

? ? ? ? ? ? let src = $(imgTags[i]).attr("src")

? ? ? ? ? ? let imgName = $(imgTags[i]).attr("alt")

? ? ? ? ? ? result.push({

? ? ? ? ? ? ? ? src,

? ? ? ? ? ? ? ? imgName

? ? ? ? ? ? })

? ? ? ? }

? ? ? ? this.emit("parseHtmlSuccess",result)

? ? }

? ? downImages(result){

? ? ? ? let targetDir = "images"

? ? ? ? for (let i = 0; i < result.length; i++) {

? ? ? ? ? ? let src = result[i].src

? ? ? ? ? ? let imgName = result[i].imgName

? ? ? ? ? ? http.get(src,(response)=>{

? ? ? ? ? ? ? ? let filePath = path.join(targetDir,imgName+path.extname(src));

? ? ? ? ? ? ? ? let writeStream = fs.createWriteStream(filePath);

? ? ? ? ? ? ? ? response.pipe(writeStream)

? ? ? ? ? ? })

? ? ? ? }

? ? }

}

//創(chuàng)建一個類并調(diào)用其init()方法

let emitter = new myEmitter();

emitter.init()