I need to connect to WebSockets server and log it's messages. With React class component I'd put this logic in componentDidMount
lifecycle hook and move on happily, but I'm not sure how to properly implement it with hooks.
Here's my first attempt.
import React, {useEffect} from 'react'; export default function AppWs() { useEffect(() => { let ws = new WebSocket('wss://ws.kraken.com/'); ws.onopen = () => console.log('ws opened'); ws.onclose = () => console.log('ws closed'); ws.onmessage = e => { const message = JSON.parse(e.data); console.log('e', message); }; return () => { ws.close(); } }, []); return ( <div>hooks + ws</div> ) }
I added connection and log logic to useEffect
, provided empty array with dependencies, and everything worked great. Until I needed to add pause
state to pause logging.
export default function AppWs() { const [isPaused, setPause] = useState(false); useEffect(() => { let ws = new WebSocket('wss://ws.kraken.com/'); ws.onopen = () => console.log('ws opened'); ws.onclose = () => console.log('ws closed'); ws.onmessage = e => { if (isPaused) return; const message = JSON.parse(e.data); console.log('e', message); }; return () => { ws.close(); } }, []); return ( <div> <button onClick={() => setPause(!isPaused)}>{isPaused ? 'Resume' : 'Pause'}</button> </div> ) }
ESLint started to yell at me that I should add isPaused
state as a dependency to useEffect
.
Well, ok, done.
But I noticed re-connection to WS server after every time I click the button. This is clearly not what I want.
My next iteration was to use two useEffect
s: one for connection and one for message processing.
export default function AppWs() { const [isPaused, setPause] = useState(false); const [ws, setWs] = useState(null); useEffect(() => { const wsClient = new WebSocket('wss://ws.kraken.com/'); wsClient.onopen = () => { console.log('ws opened'); setWs(wsClient); }; wsClient.onclose = () => console.log('ws closed'); return () => { wsClient.close(); } }, []); useEffect(() => { if (!ws) return; ws.onmessage = e => { if (isPaused) return; const message = JSON.parse(e.data); console.log('e', message); }; }, [isPaused, ws]); return ( <div> <button onClick={() => setPause(!isPaused)}>{isPaused ? 'Resume' : 'Pause'}</button> </div> ) }
This works as expected, but I have a feeling that I miss something and this task can be solved easier, with one useEffect
. Please help to refactor the code on convince me that I'm using React hooks in a proper way. Thanks!
As you are only setting the web socket once, I think a better approach is to use a ref instead of a state:
The order of useEffect
is important.
As suggested by George in the comments, in the first useEffect
ws.current
is saved to a variable to make sure that when close
is called it refers to the same instance.
export default function AppWs() { const [isPaused, setPause] = useState(false); const ws = useRef(null); useEffect(() => { ws.current = new WebSocket("wss://ws.kraken.com/"); ws.current.onopen = () => console.log("ws opened"); ws.current.onclose = () => console.log("ws closed"); const wsCurrent = ws.current; return () => { wsCurrent.close(); }; }, []); useEffect(() => { if (!ws.current) return; ws.current.onmessage = e => { if (isPaused) return; const message = JSON.parse(e.data); console.log("e", message); }; }, [isPaused]); return ( <div> <button onClick={() => setPause(!isPaused)}> {isPaused ? "Resume" : "Pause"} </button> </div> ); }
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With