域名 AXUM.RS 将于 2025 年 10 月到期。我们无意再对其进行续费,如果你有意接续这个域名,请与我们取得联系。
  • AXUM.RS 现仅需人民币 3000 元(大写:叁仟元整。接受适度议价
  • 按照行业规则,AXUM.RS 到期后,大概率会进入长时间的赎回期,该期间内,如果你想拥有该域名,将要付出高额的费用
  • 我们已启用 AXUM.EU.ORG 域名,并将持续运营
  • 仅接受微信或支付宝交易
如果你对 AXUM.RS 有兴趣,请和我们进行联系:

Javscript实现WebSocket客户端

本章我们将给我们的 ECHO 服务实现一个客户端。你要明确的是,很多语言都能写 WebSocket 客户端,包括 Rust 在内。但基于我们当前的环境,我们使用 JavaScript(TypeScript) 配合 React(Next.js)来实现。

JS客户端

设置事件监听函数

有两种方法,设置监听函数:

  • 使用 addEventListener(事件名, 监听函数),比如:
  ws.addEventListener('message', (ev)=> {
      console.log(ev);
  });
  • 使用 on事件名 = 监听函数,比如:
ws.onmessage = (ev)=>{
    console.log(ev);
};
  • "use client";:由于 WebSocket (以及其它交互)需要浏览器环境,所以,需要使用客户端组件

  • 注意,我们并不是直接修改 msgs 数组,而是通过 lastMsg 的变动来修改。如果直接修改 msgs 数组的话,在 message 等事件监听函数中,会清空历史信息:

      useEffect(() => {
        if (lastMsg) {
          setMsgs((prev) => prev?.concat({ ...lastMsg }));
        }
      }, [lastMsg]);
    
  • 我们是在点击“连接”时,才创建WebSocket连接

      const connectHandler = () => {
        const _ws = new WebSocket(url);
        _ws.addEventListener("message", (ev: MessageEvent<any>) => {
          setLastMsg(newMsg("RECV", ev.data as string));
        });
        _ws.addEventListener("open", () => {
          setLastMsg(newInfoMsg("已连接"));
          setConnected(true);
        });
        _ws.addEventListener("close", () => {
          setLastMsg(newInfoMsg("已断开连接"));
          setConnected(false);
        });
        setWs(_ws);
      };
    

    本章代码位于03/websocket-js-client 分支。

"use client";:由于 WebSocket (以及其它交互)需要浏览器环境,所以,需要使用客户端组件

注意,我们并不是直接修改 msgs 数组,而是通过 lastMsg 的变动来修改。如果直接修改 msgs 数组的话,在 message 等事件监听函数中,会清空历史信息:

  useEffect(() => {
    if (lastMsg) {
      setMsgs((prev) => prev?.concat({ ...lastMsg }));
    }
  }, [lastMsg]);

我们是在点击“连接”时,才创建WebSocket连接

  const connectHandler = () => {
    const _ws = new WebSocket(url);
    _ws.addEventListener("message", (ev: MessageEvent<any>) => {
      setLastMsg(newMsg("RECV", ev.data as string));
    });
    _ws.addEventListener("open", () => {
      setLastMsg(newInfoMsg("已连接"));
      setConnected(true);
    });
    _ws.addEventListener("close", () => {
      setLastMsg(newInfoMsg("已断开连接"));
      setConnected(false);
    });
    setWs(_ws);
  };

本章代码位于03/websocket-js-client 分支。

要查看完整内容,请先登录