在前端应用程序中，我们经常需要向服务器发送请求并等待服务器响应。通常情况下，我们使用 HTTP 客户端发送请求和接收返回值。但是，在某些情况下，我们需要建立一个实时的连接，使服务器可以随时向我们发送数据。这时，可以用 Server-sent Events 和 AMQP 的结合来实现。
Server-sent Events
Server-sent Events (SSE) 是一种服务器向客户端推送事件的技术。它允许浏览器自动接收来自服务器的事件通知。SSE 可以提供一种简单而且有效的方法，使服务器可以向客户端推送数据，因此非常适合前端实时数据交互的场景。
使用 SSE，客户端向服务器发送一个 HTTP GET 请求，服务器将一条或多条数据以流的方式通过连接发送到客户端。客户端看到这些数据后就可以进行一些实时响应操作。
下面是一个示例代码，它演示了如何使用 SSE：
const eventSource = new EventSource('/stream');
eventSource.onmessage = (event) => {
console.log(event.data);
};在上面的示例中，我们创建了一个事件源（EventSource）对象，并将其连接到服务器上的一个 URL。如果服务器有消息需要发送，则 EventSource 对象就会自动接收这些消息并触发 onmessage 事件。
AMQP
AMQP（Advanced Message Queuing Protocol）是一种标准化的消息协议，允许应用程序之间进行可靠而且异步的消息传递。AMQP 设计用于基于消息的体系结构，可用于构建高可用性、可扩展的分布式系统。
使用 AMQP，我们可以将发送的消息路由到不同的队列，以便多个消费者可以同时接收这些消息。这种模型类似于部分订阅-发布模型。
下面是一个示例代码，它演示了如何使用 AMQP 发送消息：
-- -------------------- ---- -------
----- ---- - -------------------
----- ---- - ----- ------- -------- -- -
----- ---------- - ----- ---------------------------------
----- ------- - ----- ---------------------------
----- ---------------------------
----- -------------------------- ----------------------
-------------------- ---- -- -----------
----- ----------------
----- -------------------
--在上面的示例中，我们使用 amqplib 库连接到本地 AMQP 服务器，并发送一条消息到指定的队列中。接收者可以创建一个专门的队列用于接收这些消息。
结合使用 Server-sent Events 和 AMQP
在某些情况下，我们需要将 SSE 和 AMQP 结合起来使用，以便处理实时数据的交互。通常情况下，我们可以使用一个 AMQP 接收者接收来自服务器的消息，并将这些消息重新以 SSE 的方式向客户端推送。
下面是一个示例代码，它演示了如何使用 SSE 和 AMQP 结合发送数据：
-- -------------------- ---- -------
----- ---- - -------------------
----- ------- - -------------------
----- - ------------ - - ------------------
----- --- - ----------
----- ------- - --- ---------------
----- ---- - ----- ------- -------- -- -
----- ---------- - ----- ---------------------------------
----- ------- - ----- ---------------------------
----- ---------------------------
----- -------------------------- ----------------------
-------------------- ---- -- -----------
----- ----------------
----- -------------------
--
------------------ ----- ---- -- -
------------------ -
--------------- --------------------
---------------- -----------
------------- ------------
---
----- --------- - ------ -- -
---------------- --------------
--
--------------------- -----------
--------------- -- -- -
---------------------- -----------
---
---
----- ------------- - ----- ------- -- -
----- ---------- - ----- ---------------------------------
----- ------- - ----- ---------------------------
----- ---------------------------
----- -------------- - ----- ----- -- -
--------------------- ------- ---- -----------
----------------------- ------------------------
-----------------
--
----- ---------------------- ----------------
--
-------------- ------ ---------
------------------------在上面的示例中，我们创建了一个基于 Express 的服务器，该服务器支持 SSE。当客户端连接到 /stream 路径时，服务器将向客户端推送消息，对应的事件处理程序是 sendEvent。
我们还定义了一个名为 emitter 的 EventEmitter 实例，用于将来自 AMQP 服务器的消息发送给客户端。当我们收到来自 AMQP 队列的消息时，调用 receiveMessage 处理程序将消息发送到 emitter 上。
需要注意的是，通过 AMQP 的方式发送消息，只需要按照我们在前面的示例中给出的 send 方法就可以了。
总结
这篇文章给出了详细的 Server-sent Events 和 AMQP 的结合使用说明，并包含了示例代码。如果您正在构建一个需要向服务器发送请求并随时等待服务器响应的前端应用，那么深入了解 Server-sent Events 和 AMQP 的结合使用是非常有必要的。这种技术的应用范围非常广泛，特别是对于实时数据交互，非常重要。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/64531f52968c7c53b078fe55