最新发布第2页

西门飞冰的博客梦想成为架构师的普通运维

Flink 状态管理

状态的概念在流处理中，数据是连续不断到来和处理的。每个任务进行计算处理时，可以基于当前数据直接转换得到输出结果；也可以依赖一些其他数据。这些由一个任务维护，并且用来计算输出结果的所有数据，就叫作这个任务的状态。什么场景会用到状态，下面列举了三种场景：去重：比如上游的系统数...

1个月前 (12-23) 84℃ 0喜欢

窗口的概念我们知道Flink是一个可以处理无限流的流式处理引擎，无限流有个特点就是数据无休无止，源源不断，这种情况下要是想做统计聚合的话，就没有数据的尽头，因为数据在一直不停的更新。在这种情况下，业务就想看之前一个小时或者一天的数据，就需要人为的给无界流增加一个界限，一个范围...

1个月前 (12-20) 105℃ 4喜欢

Flink中的时间语义如上图所示，在事件发生之后，生成的数据被收集起来，首先进入消息队列，然后被Flink系统中的Source算子读取消费，进而向下游的转换算子传递，最终由窗口进行计算处理。很明显这里面有两个时间点 Event Time：是事件创建的时间，叫...

1个月前 (12-20) 86℃ 0喜欢

什么是中断机制首先：一个线程不应该由其他线程来强制中断或停止，而是应该由线程自己自行停止。所以，Thread.stop, Thread.suspend, Thread.resume 都已经被废弃了。其次：在Java中没有办法立即停止一条线程，然而停止线程却显得尤为重要，...

2个月前 (12-09) 121℃ 4喜欢

Future 介绍 Future 是Java5新加的一个接口，它提供了一种异步并行计算的功能。如果主线程需要执行一个很耗时的计算任务，我们就可以通过future把这个任务放到异步线程中执行。主线程继续处理其他任务或者先行结束，在通过Future获取计算结果。一句话：Futur...

2个月前 (12-07) 98℃ 0喜欢

介绍 SpringBoot拦截器，它主要用于拦截用户的请求并做相应的处理，通常应用在权限验证、记录请求信息的日志、判断用户是否登录等功能上。示例场景说明示例场景：在SpringBoot中自定义一个拦截器，判断用户的请求中是否携带了token，要是用户请求携带了token则让用...

2个月前 (11-20) 124℃ 4喜欢

说明本文档根据B站UP主分享内容整理，视频原版连接：【IT老齐140】非常实用！Spring AOP与自定义注解实现共性需求介绍 Spring AOP可以帮助我们Java在不修改源代码的前提下实现功能增强，其底层实现基于Java动态代理或者CGLIB。以往我们使⽤exec...

2个月前 (11-20) 138℃ 0喜欢

介绍在java.util.concurrent中，提供了工具类Executors(调度器)对象来创建线程池，可创建的线程池有四种： 1、CachedThreadPool：可缓存线程池，如果数据请求过多，它会不断创建新的线程，并且它还可以灵活回收空闲的线程 2、FixedThre...

2个月前 (11-19) 177℃ 1喜欢

说明本文档根据B站UP主分享内容整理，视频原版连接：B站链接：超实用！接口调用出错怎么办？介绍在我们进行分布式业务调用的时候，各个服务之间的调用不可能是百分百成功的，所以我们在调用接口的时候，就要考虑如果调用出错了该怎么办。故障转移利用重试的机制，选择其他可用节点，完成...

2个月前 (11-17) 171℃ 1喜欢

前言作为后端应用，我们暴露的接口不是所有人都可以访问的，只有经过授权并拥有相应角色的时候才可以访问。那么针对于这种权限控制，该怎么设计呢？这个就是JWT的应用场景了 JWT介绍 JWT是什么 JWT（Json Web Token）是一个经过加密的，包含用户信息的且具有时效性的固...

2个月前 (11-17) 179℃ 0喜欢