iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Removing unmerged files from demo article

Browse Source
This commit is contained in:
Chirag Dewan 2018-08-08 22:28:28 +05:30
parent 216715010b
commit 99b800c5b9
3 changed files with 0 additions and 91 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventStreamingApplication.java
View File

@ -1,38 +0,0 @@
package com.baeldung.reactive.webflux.eventstreaming;
import java.util.HashMap;
import java.util.Map;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.web.reactive.HandlerMapping;
import org.springframework.web.reactive.handler.SimpleUrlHandlerMapping;
import org.springframework.web.reactive.socket.WebSocketHandler;
import org.springframework.web.reactive.socket.server.support.WebSocketHandlerAdapter;
@SpringBootApplication
public class EventStreamingApplication {
public static void main(String[] args) {
SpringApplication.run(EventStreamingApplication.class, args);
}
@Bean
public HandlerMapping webSocketMapping() {
Map<String, WebSocketHandler> map = new HashMap<>();
map.put("/events", new EventWebSocketHandler());
SimpleUrlHandlerMapping mapping = new SimpleUrlHandlerMapping();
mapping.setUrlMap(map);
mapping.setOrder(1);
return mapping;
}
@Bean
public WebSocketHandlerAdapter handlerAdapter() {
return new WebSocketHandlerAdapter();
}
}

26
spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventWebSocketClient.java
View File

@ -1,26 +0,0 @@
package com.baeldung.reactive.webflux.eventstreaming;
import java.net.URI;
import java.net.URISyntaxException;
import java.time.Duration;
import org.springframework.web.reactive.socket.WebSocketMessage;
import org.springframework.web.reactive.socket.client.ReactorNettyWebSocketClient;
import org.springframework.web.reactive.socket.client.WebSocketClient;
public class EventWebSocketClient {
private static final String REMOTE_URL = "ws://localhost:8080/events";
public static void main(String[] args) throws URISyntaxException {
WebSocketClient client = new ReactorNettyWebSocketClient();
client.execute(
URI.create(REMOTE_URL),
session -> session.receive()
.map(WebSocketMessage::getPayloadAsText)
.log().then())
.block(Duration.ofMinutes(10L));
}
}

27
spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventWebSocketHandler.java
View File

@ -1,27 +0,0 @@
package com.baeldung.reactive.webflux.eventstreaming;
import java.text.MessageFormat;
import java.time.Duration;
import java.time.LocalTime;
import java.util.UUID;
import org.springframework.web.reactive.socket.WebSocketHandler;
import org.springframework.web.reactive.socket.WebSocketSession;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
public class EventWebSocketHandler implements WebSocketHandler {
MessageFormat mf = new MessageFormat("EventID: {0} , Event Time: {1}") ;
@Override
public Mono<Void> handle(WebSocketSession session) {
return session.send(
Flux.<String> generate(sink -> sink.next(
mf.format(new Object[] {UUID.randomUUID(),LocalTime.now()})))
.delayElements(Duration.ofSeconds(1))
.map(session::textMessage));
}
}