| 失效链接处理 |
|
Java reactive programming - Reactor 3 and Spring WebFlux PDF 下载
相关截图：
 主要内容：
响应式编程是⼀种⾮阻塞异步编程
import reactor.ipc.netty.tcp.TcpServer;
import reactor.ipc.netty.tcp.TcpClient;
CountDownLatch latch = new CountDownLatch(10);
TcpServer server = TcpServer.create(port);
TcpClient client = TcpClient.create("localhost", port);
final JsonCodec<Pojo, Pojo> codec = new JsonCodec<Pojo, Pojo>(Pojo.class);
server.start(input -> input.send(input.decode(codec).log("serve").map(codec), 5)).await();
client.start(input -> {
input.take(10).decode(codec).log("receive").subscribe(data -> latch.countDown());
input.send(Flux.range(1, 10).map( it -> new Pojo("test" + it)).log(“send").map(codec))
.subscribe();
return Mono.never();
}).await();
latch.await(10, TimeUnit.SECONDS);
client.shutdown().await();
server.shutdown().await();
|
苏公网安备 32061202001004号
