Простая шина событий на JavaScript

2 года назад·3 мин. на чтение

Шины событий — это чрезвычайно полезный инструмент для разделения компонентов приложений.

Использование шины событий имеет свои плюсы и минусы. Поэтому она должна добавляться осторожно, иначе вы можете получить код, который будет трудно поддерживать и понимать. Но нет никаких сомнений в том, что шина событий может значительно ускорить процесс прототипирования или улучшить архитектуру малого и среднего приложения. Большому приложению могут потребоваться некоторые дополнительные инструменты и подходы. В этой статье рассмотрим как реализовать простую шину событий в JavaScript.

Что такое шина событий (event bus)?

Шина событий реализует шаблон издатель/подписчик. Его можно использовать для разъединения компонентов приложения, так что компонент может реагировать на события, инициируемые другим компонентом, без их прямых зависимостей друг от друга. Им нужно только знать шину событий. Каждый подписчик может подписаться на определенное событие. Подписчик будет уведомлен, когда событие, на которое он подписан, будет опубликовано в шине событий. Издатель может публиковать события в шине событий, когда что-то происходит.

Реализация шины событий

В этой реализации подписчик (subscriber) является простой функцией. Функция вызывается, когда интересующее событие публикуется в шине событий. Для сопоставления события с подписчиками можно использовать простой объект. Формат данных в этом объекте будет следующим: { eventType: { id: callback } }. Например:
{  
  event1: {
    1: func1,
    2: func2
  },  
  event2: {
    3: func3
  }  
}
События event1 и event2 могут быть любого типа. В большинстве случаев имеет смысл использовать простые строки. Подписчики func1, func2 и func3 являются простыми JavaScript функциями.
func1 и func2 являются подписчиками, подписанными на события типа event1. func3 является подписчиком, подписанным на события типа event2.
Идентификаторы 1, 2 и 3 будут использоваться позже для отмены подписки на подписчиков.

Как подписаться на событие?

Функция subscribe принимает в качестве аргументов интересующее событие и подписчика. Функция возвращает объект, предоставляющий функцию отмены подписки - unsubscribe. Функция unsubscribe может быть вызвана для удаления зарегистрированного подписчика. В этом примере используем генератор id для получения уникальных идентификаторов.
Идентификаторы используются для быстрой идентификации (за время O(1)) подписчика при вызове функции unsubscribe.
Вместо использования генератора id можно рассмотреть реализацию на основе ES6 символов.
const subscriptions = {}
const getNextUniqueId = getIdGenerator()
function subscribe(eventType, callback) {
  const id = getNextUniqueId()

  // создаем новый элемент для eventType
  if(!subscriptions[eventType]) {
    subscriptions[eventType] = {}
  }
 
  // регистрируем функцию обратного вызова
  subscriptions[eventType][id] = callback
  return {
    unsubscribe: () => {
      delete subscriptions[eventType][id]
      if(Object.keys(subscriptions[eventType]).length === 0) {
        delete subscriptions[eventType]
      }
    }
  }
}

Как опубликовать событие?

Функция публикации принимает в качестве аргументов событие и аргументы для подписчиков. Если подписчиков на eventType нет, то просто завершаем функцию. В противном случае перебираются идентификаторы подписчиков, зарегистрированных для eventType, и вызывается каждая функция с предоставленными аргументами.
function publish(eventType, arg) {
  if(!subscriptions[eventType]) {
    return
  }
  Object.keys(subscriptions[eventType])
    .forEach(id => subscriptions[eventType][id](arg))
}

Пример использования

В качестве простого примера предположим, что мы хотим печатать что-то в консоли каждый раз, когда появляется событие типа print. Мы можем подписаться на событие следующим образом:
const subscription = EventBus.subscribe(
  "print",
  message => console.log(`printing: ${message}`)
)
Затем мы можем выпустить событие, подобное этому:
EventBus.publish("print", "some text")
Если в какой-то момент мы захотим прекратить прослушивание события с типом print, мы можем отписаться следующим образом:
subscription.unsubscribe()

Полная реализация

Вот полная реализация этой шины событий. Он может быть легко преобразован в простую функцию Javascript.
// eventBus.js

const subscriptions = {}
const getNextUniqueId = getIdGenerator()

function subscribe(eventType, callback) {
  const id = getNextUniqueId()

  if(!subscriptions[eventType]) {
    subscriptions[eventType] = {}
  }

  subscriptions[eventType][id] = callback

  return { 
    unsubscribe: () => {
      delete subscriptions[eventType][id]
      if(Object.keys(subscriptions[eventType]).length === 0) {
        delete subscriptions[eventType]
      }
    }
  }
}

function publish(eventType, arg) {
  if(!subscriptions[eventType]) {
    return
  }
  
  Object.keys(subscriptions[eventType]).forEach(key => subscriptions[eventType][key](arg))
}

function getIdGenerator() {
  let lastId = 0
  
  return function getNextUniqueId() {
    lastId += 1
    return lastId
  }
}

module.exports = { publish, subscribe }

Продвинутое использование функций обратного вызова в React

2 года назад·4 мин. на чтение

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

Продвинутое использование функций обратного вызова являются неотъемлемой частью создания производительных и масштабируемых приложений, и это особенно актуально в разработке React приложений. Senior React разработчику важно иметь глубокое понимание продвинутых практик и того, как эффективно применять их в приложениях React. К концу этой статьи вы будете иметь четкое представление об этих передовых методах обратного вызова и сможете использовать их в своих собственных приложениях React для повышения производительности и пользовательского опыта.

Что такое функции обратного вызова (callback, колбэк)?

Функция обратного вызова — это функция, которая передается в качестве аргумента другой функции и выполняется позже. Обратные вызовы используются для обработки асинхронного кода, например ожидания извлечения данных с сервера или обработки событий пользовательского ввода. В React обратные вызовы широко используются для обработки взаимодействия с пользователем и обновления состояния приложения. Например, когда пользователь нажимает кнопку, запускается функция обратного вызова для обработки события клика и соответствующего обновления состояния приложения.

Пример простой функции обратного вызова

Вот базовый пример использования обратного вызова в React:
import React from 'react';

class MyComponent extends React.Component {
  handleClick() {
    console.log('Button clicked');
  }
  render() {
    return (
      <button onClick={this.handleClick}>Click me</button>
    );
  }
}
В этом примере мы создадим класс MyComponent, который расширяет класс React.Component. Мы определяем метод handleClick, который пишет сообщение в консоли при нажатии кнопки. Затем мы рендерим элемент button с атрибутом onClick, который задается методом handleClick. Этот пример представляет собой простую демонстрацию того, как обратные вызовы могут использоваться в React для обработки взаимодействий с пользователем.

Продвинутые функции обратного вызова

Теперь, когда мы рассмотрели основы обратных вызовов в React, давайте рассмотрим некоторые продвинутые функции обратного вызова, которые могут помочь senior инженерам создавать более эффективные и масштабируемые приложения.

Мемоизация (memoization)

Мемоизация — это метод, используемый для оптимизации производительности функции путем кэширования ее результатов на основе входных параметров. Это может помочь уменьшить количество вызовов функции и повысить производительность приложения. В React запоминание можно использовать для оптимизации производительности компонентов, которые часто повторно рендерятся. Кэшируя результаты функции, мы можем избежать дорогостоящих вычислений, которые повторяются каждый раз при повторном рендеринге компонента. Вот пример того, как использовать мемоизацию в React:
import React, { useMemo } from 'react';

function MyComponent(props) {
  const result = useMemo(() => {
    // Дорогостоящее вычисление
    return props.data.map(item => item * 2);
  }, [props.data]);
  return (
    <div>{result}</div>
  );
}
В этом примере мы используем хук useMemo для запоминания результата дорогостоящих вычислений. Хук принимает два аргумента: функцию, которая выполняет дорогостоящие вычисления, и массив зависимостей, которые запускают вычисления при их изменении. Используя хук useMemo, мы можем избежать дорогостоящих вычислений, когда массив props.data не изменяется.

Debounce

Debounce — это метод, используемый для предотвращения вызова функции несколько раз за короткий период времени. Это может помочь повысить производительность приложения и уменьшить количество ненужных вызовов функции. В React debounce можно использовать для обработки событий пользовательского ввода, таких как ввод в поле поиска. Применяя debounce для функции, которая обрабатывает событие ввода, мы можем избежать ненужных вызовов функции и повысить производительность приложения. Вот пример того, как использовать отмену в React:
import React, { useState, useEffect } from 'react';
import debounce from 'lodash.debounce';

function MyComponent() {
  const [searchQuery, setSearchQuery] = useState('');
  useEffect(() => {
    const debouncedSearch = debounce(handleSearch, 500);
    document.addEventListener('keyup', debouncedSearch);
    return () => {
      document.removeEventListener('keyup', debouncedSearch);
    };
  }, []);

function handleSearch() { // Имитация вызова API
  console.log('Searching for:', searchQuery);
}

function handleChange(event) {
  setSearchQuery(event.target.value);
}

  return (
    <div>
      <input
        type="text"
        onChange={handleChange}
      />
    </div>
  );
}
В этом примере мы используем библиотеку lodash.debounce для отмены debounce’а функции handleSearch. Мы добавляем прослушиватель событий к объекту документа для события keyup, которое запускает функцию с debounce’ом. Мы также удаляем прослушиватель событий при размонтировании компонента, чтобы избежать утечек памяти. Применив debounce к функции handleSearch, мы можем предотвратить ее многократный вызов за короткий промежуток времени, что может помочь повысить производительность приложения.

Throttle

Throttle — это метод, используемый для ограничения количества вызовов функции за заданный период времени. Это может помочь повысить производительность приложения и уменьшить количество ненужных вызовов функции. В React throttle можно использовать для обработки событий пользовательского ввода, таких как прокрутка или изменение размера окна. Регулируя функцию, обрабатывающую входное событие, мы можем избежать ненужных вызовов функции и повысить производительность приложения. Вот пример использования throttle в React:
import React, { useState, useEffect } from 'react';
import throttle from 'lodash.throttle';

function MyComponent() {
  const [scrollPosition, setScrollPosition] = useState(0);
  useEffect(() => {
    const throttledScroll = throttle(handleScroll, 500);
    window.addEventListener('scroll', throttledScroll);
    return () => {
      window.removeEventListener('scroll', throttledScroll);
    };
  }, []);

  function handleScroll() {
    const position = window.pageYOffset;
    setScrollPosition(position);
  }

  return (
    <div>
      <p>Scroll position: {scrollPosition}</p>
      <div style={{ height: '2000px' }}>
        Content here
      </div>
    </div>
  );
};
В этом примере мы используем библиотеку lodash.throttle для throttle'а функции handleScroll. Мы добавляем прослушиватель событий к объекту окна для события scroll, которое запускает функцию регулирования. Мы также удаляем прослушиватель событий при размонтировании компонента, чтобы избежать утечек памяти. Применив throttle на функцию handleScroll, мы можем ограничить количество вызовов за заданный период времени, что может помочь повысить производительность приложения.

Итоги

React предоставляет мощный набор инструментов для обработки обратных вызовов и оптимизации производительности приложений. Используя продвинутые способы использования обратных вызовов, такие как мемоизация, debounce и throttle, инженеры могут создавать эффективные и масштабируемые приложения, которые просты в поддержке и тестировании. Это лишь некоторые из многих реальных примеров того, как использовать эти способы обратных вызовов в React, чтобы проиллюстрировать, как они работают. Осваивая эти методы, старшие инженеры могут вывести свои навыки React на новый уровень и создавать удивительные приложения, которые впечатляют своих пользователей.