Wie kann ich alle Redux-RTK-Abfragen ungültig machen, wenn ich spezielle Ereignisse (Socket-IO-Nachrichten) sende?

Question

Ich möchte eine SPA React-Anwendung für alle Benutzer synchronisieren (mehrere Registerkarten, mehrere Benutzer). Ich habe einen einfachen reaktiven Hook geschrieben, der auf bestimmte Socket-IO-Nachrichten lauscht und eine Statusvariable basierend auf der Nachricht mit dem Namen useGetAllEmployeesQuery:

aktualisiert

import { useEffect, useState } from 'react'

export function useRefetchOnMessage (messageType) {
  const [needRefetch, setNeedRefetch] = useState()

  if (!window.io.socket) {
    return
  }

  function handleMessage (e) {
    setNeedRefetch(Date.now())
  }

  useEffect(() => {
    window.io.socket.on(messageType, handleMessage)

    return () => {
      window.io.socket.off(messageType, handleMessage)
    }
  }, [])

  return needRefetch
}

Wenn dieses Ereignis ausgelöst wird, rufe ich einfach die RTK-Methode refetch() auf.

const employees = useGetAllEmployeesQuery(officeId)

const needRefreshEmployees = useRefetchOnMessage('employees changed')

useEffect(() => {
  if (!needRefreshEmployees) return

  employees.refetch()
}, [needRefreshEmployees])

Wir müssen es also überall in der Anwendung aufrufen. Nehmen wir an, wir haben 5 Komponenten, die Mitarbeiterabfragen verwenden. Wir müssen refetch in allen Komponenten aufrufen. Viele Abfragen müssen zur Ausführung nur einmal ausgeführt werden. (Einmal ungültig)

Ist es möglich, solche Ereignisse in der Redux RTK-Abfragekonfiguration zu abonnieren?

Answer 1

您可以通过使标记无效来触发订阅的查询重新查询。

请参阅invalidateTags：Redux 操作创建器，可用于手动使 的缓存标签失效自动重新获取。

假设 getAllEmployees 端点提供了一个标签，例如“employees”，您可以调度一个操作来使该标记无效并触发 useGetAllEmployeesQuery 挂钩来重新获取数据。

const api = createApi({
  ...
  endpoints: builder => ({
    ...
    getAllEmployees: builder.query({
      query: ......,
      ...
      providesTags: ["employees"],
    }),
    ...
  }),
});

import { useEffect } from 'react';
import { useDispatch } from 'react-redux';
import api from '../path/to/apiSlice';

export function useRefetchOnMessage (messageType = "", tags = []) {
  const dispatch = useDispatch();

  useEffect(() => {
    const handleMessage = () => {
      dispatch(api.util.invalidateTags(tags));
    };

    window.io?.socket?.on(messageType, handleMessage);

    return () => {
      window.io?.socket?.off(messageType, handleMessage);
    }
  }, [messageType, tags]);
}

UI 代码只需调用挂钩，将 "employees" 标记传递给 useRefetchOnMessage 挂钩。

const employees = useGetAllEmployeesQuery(officeId);
useRefetchOnMessage('employees changed', ["employees"]);