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:
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?
![[Web-Frontend] Node.js-Schnellstart](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
您可以通过使标记无效来触发订阅的查询重新查询。
请参阅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"]);