Play-Utils 是一个专门为 Play Framework 开发的实用工具包模块，目前已实现如下功能：
第一次见到.repeatWhen()和.retryWhen()这两个操作符的时候就非常困惑了。不得不说，它们绝对是“最令人困惑弹珠图”的有力角逐者。
在网络请求时，有时候会出现需要进行重试的情况，重试的时候，有以下几点需要注意：
接上一篇《Js 异步处理演进，Callback=>Promise=>Observer》，可能不少掘友对 Observer 还心存疑虑，本篇继续解惑~
Subscription是什么? 当subscribe一个observable的时候, 返回的就是一个subscription. 它是一个一次性对象(disposable), 它有一个非常重要的方法
在使用路由延迟加载中，我们介绍了如何使用模块来拆分应用，在访问到这个模块的时候， Angular 加载这个模块。但这需要一点时间。在用户第一次点击的时候，会有一点延迟。
我们都知道 JavaScript 是个多范式语言，它既支持过程式编程，又支持函数式编程，两者分别适用于不同的场合。在同步环境下，两者各有优缺点，甚至有时候过程式会更简明一些，但在异步环境下（最典型的场景是一个 Ajax 请求完成后紧接着执行另一个 Ajax 请求），由于无法控制执行和完成的顺序，所以就无法使用传统的过程式写法，函数式就会展现出其优势。
在上一篇我们为大家介绍了WebClient的异常处理方法，我们可以对指定的异常进行处理，也可以分类处理400-499、500-599状态码的HTTP异常。 我们本节为大家介绍的实际上是另外一种异常处理机制：请求失败之后自动重试。当WebClient发起请求，没有得到正常的响应结果，它就会每隔一段时间再次发送请求，可以发送n次，这个n是我们自定义的。n次请求都失败了，最后再将异常抛出，可以通过我们上一节交给大家的方法进行异常处理。也就是针对连接超时异常、读写超时异常等，或者是HTTP响应结果为非正常状态码（不是200状态码段），都在自动重试机制的范畴内。
当前的OKR中已经全面接入动态压测模型了，不仅仅是效率的提升，还带来了一个非常意外的收获。
所谓创建类操作符，就是一些能够创造出一个 Observable 对象的方法，所谓“创造”，并不只是说返回一个 Observable 对象，因为任何一个操作符都会返回 Observable 对象，这里所说的创造，是指这些操作符不依赖于其他 Observable 对象，这些操作符可以凭空或者根据其他数据源创造出一个 Observable 对象。
基本概念 Observable 可观察者, 生产数据 Observer 观察者， 消费数据 Subscription 订阅/可清理对象, 用以清理资源或中断Observeable执行 Subject 多播主体, 向多个订阅者广播数据 Operators 操作符, 处理数据的函数 数据获取方式, 推送/拉取 数据的获取方式，表示了数据生产者和数据消费者之间的通信关系 拉取: 由消费者控制何时获取数据, 例如：请求状态管理器中的状态指 推送: 有生产者控制何时获取数据, 例如：向服务器请求数据 可观察者 Obs
（1）RouterModule对象提供了两个静态的方法:forRoot()和forChild()来配置路由信息。
Node.js的力量源自于庞大的NPM生态圈，拥有超过150万个包。没有NPM，Node.js虽然仍然可以使用，但其功能将大打折扣。在本系列文章中，我们将探索每位开发者都应该了解的常用NPM包。本篇，我们继续介绍第11至20款工具库，让你在Node.js项目开发中如虎添翼。
在我们的日常开发中离不开I/O操作，尤其是网络请求，但并不是所有的请求都是可信赖的，因此我们必须为APP添加请求重试功能。
What is RxJS? RxJS是ReactiveX编程理念的JavaScript版本。ReactiveX是一种针对异步数据流的编程。简单来说，它将一切数据，包括HTTP请求，DOM事件或者普通数
介绍RxJS前，先介绍Observable 可观察对象（Observable） 可观察对象支持在应用中的发布者和订阅者之间传递消息。 可观察对象可以发送多个任意类型的值 —— 字面量、消息、事件。 基本用法和词汇 作为发布者，你创建一个 Observable 的实例，其中定义了一个订阅者（subscriber）函数。 当有消费者调用 subscribe() 方法时，这个函数就会执行。 订阅者函数用于定义“如何获取或生成那些要发布的值或消息”。 要执行所创建的可观察对象，并开始从中接收通知，你就要调用它的 s
在命令行输入ionic g provider youProviderName 在创建好后，系统会自动导入从@angular/http里导入Http这个类，方便后续做直接使用此类做HTTP请求。
下面介绍几个可以创建Observable的运算符，具体的介绍请问官网 例子：https://codepen.io/mafeifan/pen/eQKNvN
尽管看起来Http请求的返回结果是一个可观测对象，但是它却没有map方法，当需要对http请求返回的可观测对象进行操作时，可以使用pipe操作符来实现：
路由的概念在前端的框架中得到了广泛的应用,对于路由的感念不做阐述,路由的应用无外乎就是嵌套、传参，高级一些的功能如懒加载、预加载，再高级一些的如：路由守卫等。本篇我们就一起来看一看在Angular中如何使用路由。
Spring 5 引入了一个名为 WebClient 的新反应式 Web 客户端。在这篇文章中，我将展示何时以及如何使用 Spring WebClient 与 RestTemplate。我还将描述 WebClient 提供的功能。
作者：TAT.郭林烁 joeyguo 原文地址 最近在 Alloyteam Conf 2016 分享了《使用RxJS构建流式前端应用》，会后在线上线下跟大家交流时发现对于 RxJS 的态度呈现出两大类
我们很高兴地宣布Angular 5.0.0——五角形甜甜圈发布啦！这又是一个主版本，包含新功能并修复了很多bug。它再次体现了我们把Angular做得更小、更快、更好用的一贯目标。
这两个模式是 Observable 的基础，下面我们先来介绍一下 Observer Pattern。
使用 Rxjs，对于初学者来说，当我们处理 observables 错误的时候容易疑惑，因为我们会考虑使用 try-catch 方式捕获。但是，Rxjs 是通过操作符来管理错误。
RxJS是ReactiveX编程理念的JavaScript版本。ReactiveX是一种针对异步数据流的编程。简单来说，它将一切数据，包括HTTP请求，DOM事件或者普通数据等包装成流的形式，然后用强大丰富的操作符对流进行处理，使你能以同步编程的方式处理异步数据，并组合不同的操作符来轻松优雅的实现你所需要的功能
前面讲了基于Nest生成Web API项目，如果不清楚请移步：【Nest教程】基于Nest初始化Web API项目，文章只讲解了使用脚手架搭建简单的项目并且可以正常运行。
持续创作，加速成长！这是我参与「掘金日新计划 · 6 月更文挑战」的第22天，点击查看活动详情
怀着对于RxJS这项技术的好奇，笔者花了数天时间研究了这项技术，并肝了一包枸杞才完成这篇文章的撰写，属实不易。不过也正是通过这段时间的学习，我发现这项技术在一定程度上可以解决我在日常业务中遇到的一些痛点，以及有种想马上应用到自己的新项目中的欲望，的确这种以数据流的理念来管控大型项目中的数据能给人带来一种十分优雅的编程体验。
Disruptor是一个开源框架，研发的初衷是为了解决高并发下队列锁的问题，最早由LMAX提出并使用，能够在无锁的情况下实现队列的并发操作，并号称能够在一个线程里每秒处理6百万笔订单
随着实时数据的日渐普及，企业需要流式计算系统满足可扩展、易用以及易整合进业务系统。Structured Streaming是一个高度抽象的API基于Spark Streaming的经验。Structured Streaming在两点上不同于其他的Streaming API比如Google DataFlow。 第一，不同于要求用户构造物理执行计划的API，Structured Streaming是一个基于静态关系查询（使用SQL或DataFrames表示）的完全自动递增的声明性API。 第二，Structured Streaming旨在支持端到端实时的应用，将流处理与批处理以及交互式分析结合起来。 我们发现，在实践中这种结合通常是关键的挑战。Structured Streaming的性能是Apache Flink的2倍，是Apacha Kafka 的90倍，这源于它使用的是Spark SQL的代码生成引擎。它也提供了丰富的操作特性，如回滚、代码更新、混合流\批处理执行。 我们通过实际数据库上百个生产部署的案例来描述系统的设计和使用，其中最大的每个月处理超过1PB的数据。
在不断发展的JavaScript编程领域，响应式编程技术正变得愈加流行。本文章系列希望能够介绍这一领域的发展现状，分享在这个主题下的多项技术变种。从Elm等新语言到Angular 2对RxJS的支持，无论从事什么工作的开发者均有相关新技术可供使用。
在正常使用RX做监听的时，时不时有些页面需要重复点击进入，这样在进入该页面的时候，会产生多次触发subscribe方法，这个时候往往会出现多次赋值或者多次提交操作，即浪费资源，也让某些功能直接成为了Bug。于是博主就寻找了一天的源码与探讨了方法，特此记录下来。
一、Disruptor是什么 Disruptor是一个高性能的异步处理框架，或者可以认为是最快的消息框架(轻量的JMS)，也可以认为是一个观察者模式实现，或者事件-监听模式的实现，直接称disruptor模式。 Disruptor最大特点是高性能，它被设计用于在生产者—消费者问题（producer-consumer problem，简称PCP）上获得尽量高的吞吐量（TPS,Transaction Per Second)）和尽量低的延迟。Disruptor是LMAX在线交易平台的关键组成部分，LMAX平台使
前言 Rxjava，由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。 如果还不了解RxJava，请看文章：Android：这是一篇 清晰 & 易懂的R
Rxjava，由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。
在当今的数字时代，分布式系统已成为处理大规模数据和高并发请求的标准架构。在这样的系统中，生成全局唯一的标识符（ID）对于追踪和区分每一个数据项至关重要。传统的自增ID生成方式在分布式环境中面临着诸多挑战，例如性能瓶颈、水平扩展限制等问题。
1）Tumble Count Window：累积固定个数的元素就视为一个窗口，该类型的窗口无法像时间窗口一样事先切分好。
实际的业务场景是这样的：前端需要轮循请求后端接口获取文件处理进度，并在前端用进度条展示。如下方所示：
我不是 Angular 的布道者，但如今自称 Angular 派，使用 Angular 做项目让我有一种兴奋感。目前的三大主流前端框架都研究过，博客中也有三者的相关教程，最早接触的是 React，但是并没有实际的项目经验，只做过一些 Demo 。使用 Vue 做过一个比较复杂的移动端大数据项目，技术栈采用 Framework7 + Vue + Vuex，整体效果还是满意的。
如Flink1.4 生成时间戳与Watermarks所介绍的，Flink提供了一个抽象类，允许程序员可以分配自己的时间戳并发送Watermark。更具体地说，可以通过AssignerWithPeriodicWatermarks或AssignerWithPunctuatedWatermarks接口来实现，具体实现取决于用户具体情况。第一个接口将周期性的发送Watermark，第二个则基于传入记录的某些属性发送Watermark，例如，当在流中遇到特殊元素时。
记得当年我刚学 JavaScript 的时候，是从原生的 dom api 学起的，用原生的 dom api 完成一些增删改的功能，之后就会学习 JQuery。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
