通过使用 SSE 协议简单实现服务器和客户端 - 在 JAVA 语言中

Question

我正在寻找通过JAVA语言使用SSE（简单发送事件）协议实现服务器和客户端的简单实现。我知道这可能是通过码头或生涩，但寻找简单的例子开始。

Answer 1

你可以做这样的事情：

添加

球衣的依赖关系或添加罐

子

在您的项目中添加 jar 的依赖项或添加 jar，例如

<dependency>
    <groupId>org.glassfish.jersey.media</groupId>
    <artifactId>jersey-media-sse</artifactId>
</dependency>

然后为服务器创建一个类，如下所示：

@Path("events")
public static class SseResource {
    @GET
    @Produces(SseFeature.SERVER_SENT_EVENTS)
    public EventOutput getServerSentEvents() {
            final EventOutput eventOutput = new EventOutput();
            new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        for (int i = 0; i < 10; i++) {
                            // ... code that waits 1 second
                            final OutboundEvent.Builder eventBuilder
                            = new OutboundEvent.Builder();
                            eventBuilder.name("message-to-client");
                            eventBuilder.data(String.class,
                                "Hello world " + i + "!");
                            final OutboundEvent event = eventBuilder.build();
                            eventOutput.write(event);
                        }
                    } catch (IOException e) {
                        throw new RuntimeException(
                            "Error when writing the event.", e);
                    } finally {
                        try {
                            eventOutput.close();
                        } catch (IOException ioClose) {
                            throw new RuntimeException(
                                "Error when closing the event output.", ioClose);
                        }
                    }
                }
            }).start();
            return eventOutput;
        }
}

然后在客户端上使用以下代码：

Client client = ClientBuilder.newBuilder()
        .register(SseFeature.class).build();
WebTarget target = client.target("http://localhost:9998/events");
EventInput eventInput = target.request().get(EventInput.class);
while (!eventInput.isClosed()) {
    final InboundEvent inboundEvent = eventInput.read();
    if (inboundEvent == null) {
        // connection has been closed
        break;
    }
    System.out.println(inboundEvent.getName() + "; "
        + inboundEvent.readData(String.class));
}

检查以下链接以及他们通过简单示例的详细信息。

https://jersey.java.net/documentation/latest/sse.html

http://viralpatel.net/blogs/html5-server-sent-events-java-servlets-example/

http://en.kodcu.com/2013/11/jaxrs-2-html-5-server-sent-events-on-glassfish-4/