Фронтенд-менеджеры состояния, которые вы должны знать

государственный менеджер

вместе сReactа такжеVueС широким использованием асинхронных фреймворков интерфейсные менеджеры состояний постепенно стали незаменимой темой во фронтенд-разработке. В формеReactочень популярныйRedux, как вVueСтандартный менеджер статусаVuex, являются относительно зрелыми менеджерами состояний в отрасли, тогда мы будем использовать собственный javascript для реализации менеджера состояний.

В основном включает в себя два аспекта: первый –опубликовать подписаться, второйгосударственное управление.

опубликовать подписатьсяPubSub

создать класс

Сначала мы создаемPubSubФункция класса:

class PubSub {
  constructor() {
  	// 收集事件
    this.events = {};
  }
}

Реализовать Опубликовать

Далее давайте реализуем функцию публикации:

class PubSub {
  ...
  // 发布
  publish(event, data = {}) {
    const self = this;
	
    /*
     * 校验是否存在事件
     * 默认返回一个空数组
     */
    if (!self.events.hasOwnProperty(event)) {
      return [];
    }
	
    // 遍历执行事件队列里的回调函数
    return self.events[event].map((callback) => callback(data));
  }
  ...
}

Реализовать подписку

Реализовать функцию публикацииpublish, а затем реализуем функцию подписки:

class PubSub {
	...
    // 订阅
    subscribe(event, callback) {
      const self = this;
      
      /*
       * 校验是否存在事件
       * 默认给一个空数组
       */
      if (!self.events.hasOwnProperty(event)) {
        self.events[event] = [];
      }
	  
      // 将事件推入回调队列
      return self.events[event].push(callback);
    }
    ...
}

полный код

class PubSub {
  constructor() {
    // 收集事件
    this.events = {};
  }

  // 订阅
  subscribe(event, callback) {
    const self = this;

    /*
     * 校验是否存在事件
     * 默认给一个空数组
     */
    if (!self.events.hasOwnProperty(event)) {
      self.events[event] = [];
    }

    // 将事件推入回调队列
    return self.events[event].push(callback);
  }

  // 发布
  publish(event, data = {}) {
    const self = this;
	
    /*
     * 校验是否存在事件
     * 默认返回一个空数组
     */
    if (!self.events.hasOwnProperty(event)) {
      return [];
    }
	
    // 遍历执行事件队列里的回调函数
    return self.events[event].map((callback) => callback(data));
  }
}

государственное управлениеStore

создать класс

Сначала мы создаемStoreФункция класса:

class Store {
	// 传入params对象
	constructor(params) {
    	const self = this;

        self.actions = {}; // 异步任务对象
        self.mutations = {}; // 同步任务对象
        self.state = {}; // 全局状态对象
        self.plugins = []; // 插件
        self.status = "resting"; // 初始状态
		
        /*
         * 初始化设置actions对象
         * 该对象主要处理异步事件
         */
        if (params.hasOwnProperty("actions")) {
          self.actions = params.actions;
        }
		
        /*
         * 初始化设置mutations对象
         * 该对象主要处理同步事件
         */
        if (params.hasOwnProperty("mutations")) {
          self.mutations = params.mutations;
        }

        // 插件
        if (params.hasOwnProperty("plugins")) {
          self.plugins = params.plugins;
        }

        /* 
         * 代理监听state
         */
        self.state = new Proxy(params.state || {}, {
          set(state, key, value) {
          	// 代理设置state对象并赋值
            state[key] = value;
			
            // 更改状态
            self.status = "resting";

            return true;
          },
        });
    }
}

реализовать фиксацию

Затем давайте реализуем основную функциюcommit, эта функция в основном обрабатывает изменения объекта, вызываяmutationsФункция внутри объекта:

class Store {
	...
    commit = (mutationKey, payload) => {
      const self = this;
      // 校验是否存在函数
      if (typeof self.mutations[mutationKey] !== "function") {
        console.warn(`Mutation ${mutationKey} dose not exist`);
        return false;
      }
	  
      // 变更状态
      self.status = "mutation";
      
      // 执行对应函数
      self.mutations[mutationKey](self.state, payload);

      return true;
    };
    ...
}

осуществить отправку

осуществленныйcommit, давайте реализуемdispatch, эта функция в основном имеет дело с асинхронными проблемами, передаваяcommitметод:

class Store {
	...
    dispatch = (actionKey, payload) => {
      const self = this;
      
      // 校验是否存在函数
      if (typeof self.actions[actionKey] !== "function") {
        console.warn(`Action ${actionKey} dose not exist`);
        return false;
      }
	  
      // 变更状态
      self.status = "action";
      
      // 执行对应函数，并传入commit
      self.actions[actionKey]({ commit: self.commit }, payload);

      return true;
    };
    ...
}

полный код

class Store {
	// 传入params对象
	constructor(params) {
    	const self = this;

        self.actions = {}; // 异步任务对象
        self.mutations = {}; // 同步任务对象
        self.state = {}; // 全局状态对象
        self.plugins = []; // 插件
        self.status = "resting"; // 初始状态
		
        /*
         * 初始化设置actions对象
         * 该对象主要处理异步事件
         */
        if (params.hasOwnProperty("actions")) {
          self.actions = params.actions;
        }
		
        /*
         * 初始化设置mutations对象
         * 该对象主要处理同步事件
         */
        if (params.hasOwnProperty("mutations")) {
          self.mutations = params.mutations;
        }

        // 插件
        if (params.hasOwnProperty("plugins")) {
          self.plugins = params.plugins;
        }

        /* 
         * 代理监听state
         */
        self.state = new Proxy(params.state || {}, {
          set(state, key, value) {
          	// 代理设置state对象并赋值
            state[key] = value;
			
            // 更改状态
            self.status = "resting";

            return true;
          },
        });
   }

  dispatch = (actionKey, payload) => {
      const self = this;
      
      // 校验是否存在函数
      if (typeof self.actions[actionKey] !== "function") {
        console.warn(`Action ${actionKey} dose not exist`);
        return false;
      }
	  
      // 变更状态
      self.status = "action";
      
      // 执行对应函数，并传入commit
      self.actions[actionKey]({ commit: self.commit }, payload);

      return true;
  }

  commit = (mutationKey, payload) => {
      const self = this;
      // 校验是否存在函数
      if (typeof self.mutations[mutationKey] !== "function") {
        console.warn(`Mutation ${mutationKey} dose not exist`);
        return false;
      }
	  
      // 变更状态
      self.status = "mutation";
      
      // 执行对应函数
      self.mutations[mutationKey](self.state, payload);

      return true;
   }
}

PubSub и магазин вместе взятые

Импорт библиотеки PubSub

	const SubPub = require("../lib/pubsub");
    
    // 在state的代理中监测到数据改变，发布相对应事件
    class Store {
    	constructor(params) {
        	// 实例化发布订阅
        	self.events = new SubPub()
        
        	...
            /* 
             * 代理监听state
             */
            self.state = new Proxy(params.state || {}, {
              set(state, key, value) {
                // 代理设置state对象并赋值
                state[key] = value;
                
                // 添加发布事件
                self.events.publish("stateChange", self.state);

                // 更改状态
                self.status = "resting";

                return true;
              },
            });
            ...
        }
    }

Пример сцены

const Store = new Store({
	state: {
    	text: ''
    },
	mutations: {
    	init: (state, payload) => {
        	state.text = payload
        },
    },
    actions: {
    	init: ({commit},payload) => {
        	setTimeout(() => {
            	commit('init', payload)
            },200)
        }
    },
    plugins: [
    	function() {
        	console.log('plugins')
        }
    ]
})

// 执行同步事件
Store.commit('init', 'hello init')

// 执行异步事件
Store.dispatch('init', 'hello async init')

Суммировать

Выше приведена базовая версия глобального диспетчера состояний, включая базовую синхронную и асинхронную обработку, плагины, функции публикации и подписки, и, конечно, некоторые детали нуждаются в улучшении. Если у вас есть какие-либо вопросы, пожалуйста, укажите их в комментариях, спасибо.