Java HttpClient 接收 SSE 流数据：完整指南

使用 Java HttpClient 接收 SSE 流数据

本指南介绍如何使用 Java HttpClient 和 SseClient 库接收服务器发送事件 (SSE) 流数据。

1. 添加 SseClient 库依赖

在 Maven 项目的 pom.xml 文件中添加以下依赖：

<dependency>
    <groupId>com.launchdarkly.eventsource</groupId>
    <artifactId>eventsource-java</artifactId>
    <version>1.2.0</version>
</dependency>

2. 接收 SSE 流数据的 Java 代码示例

import com.launchdarkly.eventsource.EventSource;
import com.launchdarkly.eventsource.EventHandler;
import com.launchdarkly.eventsource.MessageEvent;

import java.net.URI;
import java.util.concurrent.CountDownLatch;

public class SseClientExample {
    public static void main(String[] args) throws Exception {
        // 创建 CountDownLatch 等待 SSE 连接建立
        CountDownLatch latch = new CountDownLatch(1);

        // 创建 EventHandler 处理 SSE 事件
        EventHandler eventHandler = new EventHandler() {
            @Override
            public void onOpen() {
                System.out.println("SSE 连接已建立");
                latch.countDown();
            }

            @Override
            public void onMessage(String event, MessageEvent message) {
                System.out.println("接收到 SSE 消息：" + event + ", " + message.getData());
            }

            @Override
            public void onError(Throwable t) {
                System.err.println("SSE 连接出现错误：" + t.getMessage());
                latch.countDown();
            }
        };

        // 创建 EventSource 连接 SSE 服务器
        EventSource eventSource = new EventSource.Builder(eventHandler, URI.create("http://example.com/sse"))
                .build();

        // 等待 SSE 连接建立
        latch.await();

        // 等待一段时间后关闭 SSE 连接
        Thread.sleep(5000);
        eventSource.close();
    }
}

3. 代码解析

• 使用 CountDownLatch 等待 SSE 连接建立完成。
• EventHandler 处理接收到的 SSE 事件，包括连接建立、接收消息和连接错误。
• EventSource 连接 SSE 服务器。
• 可以根据需要自定义 EventHandler，例如处理不同类型的 SSE 事件。

4. 注意事项

• 将示例代码中的 URI 替换为实际的 SSE 服务器 URI。
• 可以根据需要对 EventHandler 进行更多定制。

希望本指南能帮助您使用 Java HttpClient 接收 SSE 流数据。