在 Web 开发中，实时通信已经成为了越来越常见的需求。传统的 HTTP 协议是一种请求-响应方式的通信协议，无法满足实时通信的需求。WebSocket 是一种全双工的通信协议，能够实现服务器与客户端之间的实时双向通信。
Angular 是一个流行的前端框架，它提供了强大的组件化和数据绑定功能，并且比较容易与 WebSocket 集成。本文将介绍如何在 Angular 中使用 WebSocket 进行实时通信。
WebSocket 简介
WebSocket 是一种全双工的通信协议，它基于 TCP 协议，能够实现服务器与客户端之间的实时双向通信。与 HTTP 协议不同，WebSocket 协议是一种长连接，客户端和服务器之间可以互相发送消息，不需要每次发送数据都建立新的连接。
WebSocket 协议有以下几个特点：
- 基于 TCP 协议，与 HTTP 协议不同，它是一种长连接协议，客户端和服务器之间可以互相发送消息，不需要每次发送数据都建立新的连接。
- 可以在浏览器和服务器之间双向传递消息。
- 支持跨域通信。
- 与 HTTP 协议共用 80 和 443 端口。
在 Angular 中使用 WebSocket
Angular 提供了 HttpClient 来进行 HTTP 请求，但是它不能直接使用 WebSocket 进行实时通信。不过 Angular 中有一个名为 WebSocketSubject 的类，它是 RxJS 中的一个 Observable 对象，能够将 WebSocket 转换成可观察对象。
下面是一个简单的 Angular 组件，演示了如何使用 WebSocket 进行实时通信：
-- -------------------- ---- -------
------ - --------- - ---- ----------------
------ - ---------- ---------------- - ---- -----------------
--------- ------- -
----- -------
----- ----
-
------------
--------- -----------
------------ -----------------------
---------- -----------------------
--
------ ----- ------------ -
---- --------------------------
------------- -
-------- - ------------------------------------------
-------------------
------- -- ---------------------- -- ---------
--- -- -------------------- --------- -- -----
-- -- ---------------------- --------
--
-
------------- -
----- -------- ------- - -
----- -------
----- ------- -----------
--
-----------------------
-
-在这个示例中，我们创建了一个 WebSocketSubject 对象 ws$，并订阅它。订阅后，我们可以在回调函数中处理接收到的数据。在 sendMessage 方法中，我们创建了一个消息对象，并使用 ws$.next() 方法将它发送给服务器。
WebSocketSubject
WebSocketSubject 是 RxJS 中的一个类，它将 WebSocket 作为一个可观察对象。它的构造函数接受一个 URL，表示要连接的 WebSocket 地址。使用 ws$.next() 方法可以向服务器发送数据，使用 ws$.subscribe() 方法可以监听服务器发送的数据。
WebSocketSubject 还有一些其他的方法，包括 ws$.connect() 方法可以手动连接到服务器，ws$.disconnect() 方法可以手动关闭连接。
RxJS 操作符
除了 WebSocketSubject 之外，Angular 还提供了一些 RxJS 操作符，可以方便地处理 WebSocket 发送和接收的数据。
filter：过滤符合条件的值；map：将值转换为另一个值；skip：跳过指定数量的值；take：只取指定数量的值；debounceTime：防抖，只有在指定时间内没有新值时才会发送值。
WebSocket 服务器
WebSocket 是一种协议，它需要服务器端支持。在 Node.js 中，可以使用 Node.js 的 ws 模块提供的功能来创建 WebSocket 服务器。下面是一个简单的 Node.js WebSocket 服务器：
-- -------------------- ---- -------
----- -- - --------------
----- ------ - --- ----------- ----- ---- ---
----------------------- ------ -- -
-------------------- ------- -- -
---------------------- -- ---------
----- -------- - -
----- -------
----- ------- --------- - - -------
--
--------------------------------------
---
------------------ -- -- ---------------------- ----------
---在这个服务器中，我们创建了一个 WebSocket 服务器实例 server，然后监听它的 connection 事件。在连接建立后，我们可以监听 message 事件来接收客户端发送的消息，并通过 send 方法将响应发送给客户端。在连接关闭时，我们会收到 close 事件。
总结
WebSocket 是一种实现实时通信的重要协议，它可以实现服务器和客户端之间的双向通信。Angular 提供了 WebSocketSubject 类，方便开发者使用 WebSocket 进行实时通信。在 Node.js 中，可以使用 ws 模块创建 WebSocket 服务器，实现服务器端的 WebSocket 通信。
通过本文的介绍，您现在已经了解了如何在 Angular 中使用 WebSocket 进行实时通信，也了解了 WebSocket 的基本概念和使用方式。希望本文能够对您在实际项目中使用 WebSocket 进行实时通信有所帮助。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6471556b968c7c53b0f38c83