Как заставить клиента получать отправленные сервером события с использованием Javalin? - PullRequest
Новая
       42

Как заставить клиента получать отправленные сервером события с использованием Javalin?

2 голосов
/ 26 марта 2019

Я пытаюсь реализовать серверный клиентский проект, которому требуется, чтобы сервер отправлял данные клиенту каждые 5 минут, а клиент запрашивает только в начале соединения. События, отправленные сервером, похоже, являются подходящим решением.

Я пытался использовать функции, приведенные в Джавалинских документах. Я могу получить ответ с помощью простого получения с сервера. Но я не мог установить sse-соединение. Код входит в лямбда-функцию на сервере, но клиент ничего не получает. Я не уверен, есть ли проблема у клиента или сервера, или даже у обоих. Единственный вывод, который мы получаем из приведенных ниже кодов, «подключен» на стороне сервера. Заранее спасибо.

Код для сервера 

import io.javalin.Javalin;

public class SimpleTwitter {

  public static void main(String[] args) {

    Javalin app = Javalin.create().start(7000);

    app.sse("/sse", client ->{
        System.out.println("connected");
        client.sendEvent("message","Hello, SSE");
        client.onClose(() -> System.out.println("Client disconnected"));
    });

    app.get("/", ctx -> ctx.result("Hello World"));

   }
}

Код для клиента 

<!DOCTYPE html>
<html>
<body>

<h1>Getting server updates</h1>
<div id="result"></div>

<script>
if(typeof(EventSource) !== "undefined") {
  var source = new EventSource("http://localhost:7000/sse");
  source.onmessage = function(event) {
    document.getElementById("result").innerHTML += event.data + "<br>";
  };
} else {
  document.getElementById("result").innerHTML = "Sorry, your browser does not support server-sent events...";
}
</script>

</body>
</html>

1 Ответ

2 голосов
/ 28 марта 2019

Оказывается, проблема была не в коде.Изучив инструменты разработчика в chrome, мы увидели следующее:

"Доступ к ресурсу в 'http://localhost:7000/sse' из источника' null 'был заблокирован политикой CORS: Нет' ДоступЗаголовок -Control-Allow-Origin 'присутствует на запрошенном ресурсе. "

Когда мы установили расширение Chrome под названием" Allow-Control-Allow-Origin: * ", мы смогли увидетьвывод.

Также, вот обновленные улучшенные рабочие коды: 

> <<!DOCTYPE html> <html> <body>
> 
> <h1>Tweets</h1>
> 
> <script> new
> EventSource('http://localhost:7000/sse').addEventListener( "hi", msg
> =>{       document.write(msg.data); }); </script>
> 
> </body> </html>

... 

public static void main(String[] args) throws InterruptedException {

        Queue<SseClient> clients = new ConcurrentLinkedQueue<>();

        Javalin app = Javalin.create().start(7000);
                app.sse("/sse", client -> {
            clients.add(client);
            client.onClose(() -> clients.remove(client));
        });

        while (true) {
            for (SseClient client : clients) {
                client.sendEvent("hi", "hello world");
            }
            TimeUnit.SECONDS.sleep(1);
        }

    }
...