webpack自定义Plugin
总结
三. 自定义Plugin
3.1. 介绍tapable
3.2. Hooks的使用
- synchook
- bail
- loop
- waterfall
- parallel: 并行
- series: 串行
4.1. 自定义Plugin原理
- 回顾源码
- 插件的注册
- compiler.hooks.xxx.tapAsync
4.2. 搭建注册Plugin项目
class AutoUploadWebpackPlugin {
apply(compiler) {}
}
4.3. 自动上传的功能逻辑
- 1.获取打包后的文件夹
- 2.连接远程服务器
- 3.删除远程服务器文件中内容
- 4.上传文件夹的内容
- 5.断开ssh连接
tapable介绍
Webpack和Tapable
我们知道webpack有两个非常重要的类:Compiler和Compilation
- 他们通过注入插件的方式,来监听webpack的所有生命周期;
- 插件的注入离不开各种各样的Hook,而他们的Hook是如何得到的呢?
- 其实是创建了Tapable库中的各种Hook的实例;
所以,如果我们想要学习自定义插件,最好先了解一个库:Tapable
- Tapable是官方编写和维护的一个库;
- Tapable是管理着需要的Hook,这些Hook可以被应用到我们的插件中;
Tapable有哪些Hook呢?
Tapable的Hook分类
同步和异步的:
- 以sync开头的,是同步的Hook;
- 以async开头的,两个事件处理回调,不会等待上一次处理回调结束后再执行下一次回调;
其他的类别
- bail:当有返回值时,就不会执行后续的事件触发了;
- Loop:当返回值为true,就会反复执行该事件,当返回值为undefined或者不返回内容,就退出事件;
- Waterfall:当返回值不为undefined时,会将这次返回的结果作为下次事件的第一个参数;
- Parallel:并行,不会等到上一个事件处理回调结束,才执行下一次事件处理回调;
- Series:串行,会等待上一是异步的Hook;
Hook的使用过程
- 第一步:创建Hook对象
- 第二步:注册Hook中的事件
- 第三步:触发事件
同步hook
- sync基本使用
const { SyncHook } = require('tapable')
class HYCompiler {
constructor() {
this.hooks = {
// 1.创建hooks
syncHook: new SyncHook(["name", "age"])
}
// 2.用hooks监听事件(自定义plugin)
this.hooks.syncHook.tap("event1", (name, age) => {
console.log("event1事件监听执行了:", name, age)
})
this.hooks.syncHook.tap("event2", (name, age) => {
console.log("event1事件监听执行了:", name, age)
})
}
}
const compiler = new HYCompiler()
// 3.发出去事件
setTimeout(() => {
compiler.hooks.syncHook.call("why", 18)
}, 2000);
- sync_Bail使用
const { SyncBailHook } = require('tapable')
class HYCompiler {
constructor() {
this.hooks = {
// 1.创建hooks
// bail的特点: 如果有返回值, 那么可以阻断后续事件继续执行
bailHook: new SyncBailHook(["name", "age"])
}
// 2.用hooks监听事件(自定义plugin)
this.hooks.bailHook.tap("event1", (name, age) => {
console.log("event1事件监听执行了:", name, age)
return 123
})
this.hooks.bailHook.tap("event2", (name, age) => {
console.log("event1事件监听执行了:", name, age)
})
}
}
const compiler = new HYCompiler()
// 3.发出去事件
setTimeout(() => {
compiler.hooks.bailHook.call("why", 18)
}, 2000);
- sync_loop的使用
const { SyncLoopHook } = require('tapable')
let count = 0
class HYCompiler {
constructor() {
this.hooks = {
// 1.创建hooks
// bail的特点: 如果有返回值, 那么可以阻断后续事件继续执行
loopHook: new SyncLoopHook(["name", "age"])
}
// 2.用hooks监听事件(自定义plugin)
this.hooks.loopHook.tap("event1", (name, age) => {
if (count < 5) {
console.log("event1事件监听执行了:", name, age)
count++
return true
}
})
this.hooks.loopHook.tap("event2", (name, age) => {
console.log("event1事件监听执行了:", name, age)
})
}
}
const compiler = new HYCompiler()
// 3.发出去事件
setTimeout(() => {
compiler.hooks.loopHook.call("why", 18)
}, 2000);
- sync_waterfal的使用
const { SyncWaterfallHook } = require('tapable')
class HYCompiler {
constructor() {
this.hooks = {
// 1.创建hooks
waterfallHook: new SyncWaterfallHook(["name", "age"])
}
// 2.用hooks监听事件(自定义plugin)
this.hooks.waterfallHook.tap("event1", (name, age) => {
console.log("event1事件监听执行了:", name, age)
return {xx: "xx", yy: "yy"} //当返回值不为undefined时,会将这次返回的结果作为下次事件的第一个参数
})
this.hooks.waterfallHook.tap("event2", (name, age) => {
console.log("event1事件监听执行了:", name, age)
})
}
}
const compiler = new HYCompiler()
// 3.发出去事件
setTimeout(() => {
compiler.hooks.waterfallHook.call("why", 18)
}, 2000);
异步hook的使用
异步hook要使用tapAsync监听,callAsync触发
async_paralle的使用
const { AsyncParallelHook } = require('tapable')
class HYCompiler {
constructor() {
this.hooks = {
// 1.创建hooks
parallelHook: new AsyncParallelHook(["name", "age"])
}
// 2.用hooks监听事件(自定义plugin)
this.hooks.parallelHook.tapAsync("event1", (name, age) => {
setTimeout(() => {
console.log("event1事件监听执行了:", name, age)
}, 3000);
})
//两个并行执行
this.hooks.parallelHook.tapAsync("event2", (name, age) => {
setTimeout(() => {
console.log("event2事件监听执行了:", name, age)
}, 3000);
})
}
}
const compiler = new HYCompiler()
// 3.发出去事件
setTimeout(() => {
compiler.hooks.parallelHook.callAsync("why", 18)
}, 0);
- async_series的使用
const { AsyncSeriesHook } = require('tapable')
class HYCompiler {
constructor() {
this.hooks = {
// 1.创建hooks
// bail的特点: 如果有返回值, 那么可以阻断后续事件继续执行
seriesHook: new AsyncSeriesHook(["name", "age"])
}
// 2.用hooks监听事件(自定义plugin)
//两个串行执行,只有等到上一个async hook有结果之后,才会执行下一个。
this.hooks.seriesHook.tapAsync("event1", (name, age, callback) => {
setTimeout(() => {
console.log("event1事件监听执行了:", name, age)
callback()
}, 3000);
})
this.hooks.seriesHook.tapAsync("event2", (name, age, callback) => {
setTimeout(() => {
console.log("event2事件监听执行了:", name, age)
callback()
}, 3000);
})
}
}
const compiler = new HYCompiler()
// 3.发出去事件
setTimeout(() => {
compiler.hooks.seriesHook.callAsync("why", 18, () => {
console.log("所有任务都执行完成~")
})
}, 0);
自定义Plugin
- 在之前的学习中,我们已经使用了非常多的Plugin:
- CleanWebpackPlugin
- HTMLWebpackPlugin
- MiniCSSExtractPlugin
- CompressionPlugin
- 等等。。。
- 这些Plugin是如何被注册到webpack的生命周期中的呢?
- 第一:在webpack函数的createCompiler方法中,注册了所有的插件;
- 第二:在注册插件时,会调用插件函数或者插件对象的apply方法;
- 第三:插件方法会接收compiler对象,我们可以通过compiler对象来注册Hook的事件;
- 第四:某些插件也会传入一个compilation的对象,我们也可以监听compilation的Hook事件;
开发自己的插件
如何开发自己的插件呢?
- 目前大部分插件都可以在社区中找到,但是推荐尽量使用在维护,并且经过社区验证的;
- 这里我们开发一个自己的插件:将静态文件自动上传服务器中;
自定义插件的过程:
创建AutoUploadWebpackPlugin类;
编写apply方法:
- 通过ssh连接服务器;
- 删除服务器原来的文件夹;
- 上传文件夹中的内容;
在webpack的plugins中,使用AutoUploadWebpackPlugin类;
const { NodeSSH } = require('node-ssh')
const { PASSWORD } = require('./config')
class AutoUploadWebpackPlugin {
constructor(options) {
this.ssh = new NodeSSH()
this.options = options
}
apply(compiler) {
// console.log("AutoUploadWebpackPlugin被注册:")
// 完成的事情: 注册hooks监听事件
// 等到assets已经输出到output目录上时, 完成自动上传的功能
compiler.hooks.afterEmit.tapAsync("AutoPlugin", async (compilation, callback) => {
// 1.获取输出文件夹路径(其中资源)
const outputPath = compilation.outputOptions.path
// 2.连接远程服务器 SSH
await this.connectServer()
// 3.删除原有的文件夹中内容
const remotePath = this.options.remotePath
this.ssh.execCommand(`rm -rf ${remotePath}/*`)
// 4.将文件夹中资源上传到服务器中
await this.uploadFiles(outputPath, remotePath)
// 5.关闭ssh连接
this.ssh.dispose()
// 完成所有的操作后, 调用callback()
callback()
})
}
async connectServer() {
await this.ssh.connect({
host: this.options.host,
username: this.options.username,
password: this.options.password
})
console.log('服务器连接成功')
}
async uploadFiles(localPath, remotePath) {
const status = await this.ssh.putDirectory(localPath, remotePath, {
recursive: true,
concurrency: 10
})
if (status) {
console.log("文件上传服务器成功~")
}
}
}
module.exports = AutoUploadWebpackPlugin
module.exports.AutoUploadWebpackPlugin = AutoUploadWebpackPlugin