标签 ‘ RxJava

一文带你彻底了解Java异步编程

随着RxJavaReactor等异步框架的流行,异步编程受到了越来越多的关注,尤其是在IO密集型的业务场景中,相比传统的同步开发模式,异步编程的优势越来越明显。

那到底什么是异步编程?异步化真正的好处又是什么?如何选择适合自己团队的异步技术?在实施异步框架落地的过程中有哪些需要注意的地方?

阅读全文

阻塞数据流的检测和测试 – RxJava

原文链接 作者:Tomasz Nurkiewicz 译者:simonwang

想象一下,你有一个数据流以不定的频率推送一些event。在某些时候,你期望数据流会以每秒几十个消息的频率进行推送,但事实上几秒时间内一个event都没被推送。如果你的数据流是通过web socket,SSE或者其他网络协议进行传输,那么长时间的数据静默则可以断定为网络问题。这时我们经常会人为地发送events(pings)来确保:

阅读全文

小规模的流处理框架.Part 2: RxJava 1.x/2.x

原文链接 作者:Tomasz Nurkiewicz 译者:simonwang
part 1: thread pools中,我们设计并实现了一个相对简单的实时处理events的系统。在阅读本文之前你应该确保已经读懂了Part1的那篇文章,这里重新阐述一遍系统的设计要求:
阅读全文

Java中的Functor与monad

原文链接 作者:Tomasz Nurkiewicz  译者:simonwang

这篇文章最初是我们的Reactive Programming with RxJava一书中的附录,然而提到monad即使它与响应式编程有关,但也只是一点点,所以我决定把它单独拿出来出一篇博客。我意识到对monad一边解释一边纠正,对我而言这就像是在编程博客上使用“Hello World”一样(是对是错拉出来溜溜)。而且这篇文章从Java数据结构与库的角度对functor与monad给出了独特见解,因此我认为这值得拿出来分享。

阅读全文

return top