場(chǎng)景

在業(yè)務(wù)上現(xiàn)在有一個(gè)場(chǎng)景，當(dāng)發(fā)生業(yè)務(wù)行為變化時(shí)，需要對(duì)各個(gè)模塊的行為進(jìn)行數(shù)據(jù)收集，數(shù)據(jù)用途可以用作回顧，也可以是例如監(jiān)控這樣的場(chǎng)景。

核心問(wèn)題

說(shuō)白了這個(gè)需求就是需要對(duì)各個(gè)模塊狀態(tài)變更進(jìn)行記錄，然后再格式化上傳到服務(wù)端。解題思路有兩種一種是狀態(tài)監(jiān)聽(tīng)，第二主動(dòng)收集。

狀態(tài)監(jiān)聽(tīng)狀態(tài)監(jiān)聽(tīng)優(yōu)勢(shì)

快速實(shí)現(xiàn)利用狀態(tài)管理和wacth的機(jī)制很快就知道不同模塊的狀態(tài)變更，然后就可以獲取數(shù)據(jù)，再格式化數(shù)據(jù)，發(fā)送給服務(wù)端

狀態(tài)監(jiān)聽(tīng)劣勢(shì) wacth的重復(fù)監(jiān)聽(tīng)，只要使用了wacth，不管是不是你所需要的數(shù)據(jù)，只要狀態(tài)變更就會(huì)觸發(fā)改變，監(jiān)聽(tīng)行為 重復(fù)依賴，比如說(shuō)全局有個(gè)開(kāi)始結(jié)束的狀態(tài)，在使用wacth的時(shí)候就需要在不同的wacth中都去判斷這個(gè)狀態(tài)，或者有全局的時(shí)間模塊等等 重復(fù)書(shū)寫(xiě)，在不同的監(jiān)聽(tīng)中需要實(shí)踐相同的數(shù)據(jù)格式化方法 數(shù)據(jù)分布混亂，雖然控制了全局使用同一管道上傳，但是對(duì)于同一個(gè)管道內(nèi)的數(shù)據(jù)想做合并去重，或者其他自定義的操作，在不同類型數(shù)據(jù)，同一管道的這個(gè)場(chǎng)景下面支持很弱 場(chǎng)景區(qū)分困難，正常流程觸發(fā)的監(jiān)聽(tīng)是沒(méi)有問(wèn)題，如果是異常場(chǎng)景觸發(fā)恢復(fù)的監(jiān)聽(tīng)就會(huì)導(dǎo)致判斷的復(fù)雜性 描述的還是比較抽象看下代碼示例

function useA(){ wacth(new,old){ if(start){ if(new.type ==’need’) const a = { a:new.a } const aa = { aa:new.aa } upload(a) upload(aa) } }}// 多處數(shù)據(jù)散落function useB(){ // 重復(fù)監(jiān)聽(tīng) wacth(new,old){ // 全局判斷 if(start){ // 不同狀態(tài)判斷 if(new.type ==’need’) const b = { b:new.b } //重復(fù)數(shù)據(jù)格式 const aa = { b:new.aa } upload(b) upload(aa) } }}重構(gòu)實(shí)現(xiàn)思路 依賴收集（監(jiān)聽(tīng)者模式） 狀態(tài)統(tǒng)一 數(shù)據(jù)自治（策略模式） 依賴收集 核心思想:希望使用同一個(gè)采集器解決整個(gè)業(yè)務(wù)流程，數(shù)據(jù)變更在各個(gè)變更方，通過(guò)采集器提供的標(biāo)準(zhǔn)的格式化方法去處理數(shù)據(jù)，再把數(shù)據(jù)傳遞到采集器，采集器收到數(shù)據(jù)后根據(jù)不同的數(shù)據(jù)格式插入到不同的緩存通道，緩存通道緩存成功，通知業(yè)務(wù)處理的監(jiān)聽(tīng)者，根據(jù)不同的數(shù)據(jù)類型進(jìn)行不同的處理方式，最后發(fā)送到服務(wù)端。 具體代碼如下

/* * @Description: 采集公共類 * @version: 1.0.0 * @Author: 吳文周 * @Date: 2021-04-20 19:44:35 * @LastEditors: 吳文周 * @LastEditTime: 2021-04-22 15:20:50 *//** * @name: Dep * @msg: 依賴收集對(duì)象 */class Dep { private subs: any = [] // 添加觀察者 public addSub(sub: any) { if (sub && sub.update) { this.subs.push(sub) } } // 發(fā)送通知 public notify(content: any) { this.subs.forEach((sub: any) => { sub.update(content) }) }}/** * @name: Watcher * @msg: 觀察者對(duì)象 */class Watcher { private cb!: (arg: any) => void constructor(cb: (arg: any) => void) { // 回調(diào)函數(shù)負(fù)責(zé)更新 this.cb = cb } // 當(dāng)數(shù)據(jù)發(fā)生變化的時(shí)候更新 update(content: any) { this.cb(content) }}/** * @name: Channel * @msg: 緩存消息管道 */class Channel { // 管道存儲(chǔ)數(shù)組 private queue: any = [] // 管道大小 private limitSize = 1 // 管道名稱 public name: string constructor(name: string, limitSize = 1) { this.name = name // 最小尺寸是1 limitSize = limitSize >= 1 ? limitSize : 1 this.limitSize = limitSize } /** * @name: push * @msg: 添加的數(shù)據(jù) */ push(item: any) { // 如果超出限制尺寸移除第一個(gè) if (this.limitSize == this.queue.length) { this.queue.shift() } this.queue.push(item) } /** * @name: getLast * @msg: 獲取最后添加的數(shù)據(jù) */ getLast() { if (this.queue.length > 0) { return this.queue[this.queue.length - 1] } else { throw new Error(’no item return’) } } /** * @name: getLastIndex * @msg: 獲取最后倒數(shù)的數(shù)據(jù) */ getLastIndex(index: number) { try { return this.queue[this.queue.length - index - 1] } catch (error) { throw new Error(’no item return’) } } /** * @name: isEmpty * @msg: 管道是否為空 */ isEmpty() { return this.queue.length == 0 }}export class Collection { // 依賴收集對(duì)象 private dep = new Dep() // 各個(gè)數(shù)據(jù)頻道分類 private dataQueue = [’A’, ’B’, ’C’] // 頻道集合 private channelMap = new Map() // 上傳隊(duì)列 private MQ!: LiveCollectionMQ // 策略模式：數(shù)據(jù)類型不同對(duì)應(yīng)不同的處理機(jī)制 private strategies = { A: () => { // 可以在不同的管道中獲取相對(duì)應(yīng)的數(shù)據(jù)進(jìn)行不同邏輯的處理 }, B: () => { }, C: () => { }, } as Record<NotifyType, any> constructor() { this.init() } private init() { // 初始化watcher this.intWatcher() // 初始化頻道 this.initChannel() // 初始化數(shù)據(jù) this.initData() // 初始化隊(duì)列 this.initMQ() } /** * @name:intWatcher * @msg:初始化監(jiān)聽(tīng)器 */ private intWatcher() { this.dep.addSub( new Watcher((type: NotifyType) => {const handlerBack = this.getHandler(type)handlerBack() }), ) } /** * @name: initChannel * @msg: 初始化頻道 */ private initChannel() { this.dataQueue.forEach(item => { this.channelMap.set(item, new Channel(item, 3)) }) } /** * @name: initData * @msg: 初始化頻道數(shù)據(jù) * @param {*} */ private initData() { } /** * @name: initMQ * @msg: 初始化上傳隊(duì)列 */ private initMQ() { } /** * @name: getMQ * @msg:獲取消息隊(duì)列 */ public getMQ() { return this.MQ } /** * @name:getChannel * @msg:根據(jù)頻道名稱獲取頻道實(shí)例 * @param {name}頻道名稱 */ private getChannel(name: NotifyType) { if (this.channelMap.get(name)) { return this.channelMap.get(name) } else { throw new Error(’no channel’) } } /** * @name:notify * @msg:依賴通知方法 * @param {NotifyType} type * @param {any} mes */ public notify(type: NotifyType, mes: any) { // 設(shè)置管道緩存 this.setChannel(type, mes) // 全局統(tǒng)一判斷狀態(tài)判斷是否要分發(fā)數(shù)據(jù) if (state.value.type) { this.dep.notify(type) } } /** * @name: setChannel * @msg: 設(shè)置頻道緩存 * @param {NotifyType} name * @param {any} mes */ private setChannel(name: NotifyType, mes: any) { const channel = this.getChannel(name) channel.push(mes) } /** * @name:getHandler * @msg: 獲取 * @param {NotifyType} name */ private getHandler(name: NotifyType) { return this.strategies[name] } /** * @name: getChannelLast * @msg: 獲取指定管道中的最新的數(shù)據(jù) * @param {NotifyType} name * @return {*} */ public getChannelLast(name: NotifyType) { try { const channel = this.getChannel(name) return channel.getLast() } catch (error) { throw new Error(error) } } /** * @name: getChannelLast * @msg: 獲取指定管道中的倒序數(shù)據(jù) * @param {NotifyType} name * @param {number} index */ public getChannelItemByLastIndex(name: NotifyType, index: number) { try { const channel = this.getChannel(name) return channel.getLastIndex(index) } catch (error) { throw new Error(error) } } /** * @name: generateA * @msg: 生成A數(shù)據(jù)方法 */ public generateA() { } /** * @name: generateB * @msg: 生成B數(shù)據(jù)方法 */ public generateB() { } /** * @name: generateC * @msg: 生成C數(shù)據(jù)方法 */ public generateC() { }}export const CollectionHelper = new Collection()總結(jié) 我覺(jué)得去了解一個(gè)框架的一個(gè)好的思路就是在運(yùn)用它的核心原理去解決一個(gè)原理，正如之前使用webpack的插件機(jī)制一樣，這次使用的是vue的依賴收集 狀態(tài)自治，職責(zé)統(tǒng)一是個(gè)代碼封裝的好習(xí)慣

以上就是用vue設(shè)計(jì)一個(gè)數(shù)據(jù)采集器的詳細(xì)內(nèi)容，更多關(guān)于vue 設(shè)計(jì)數(shù)據(jù)采集器的資料請(qǐng)關(guān)注好吧啦網(wǎng)其它相關(guān)文章！