logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Flink+Kafka消费

分布式处理引擎Flink使用至少一个【job】调度和至少一个【task】实现分布式处理有界:就是指flink【消费指定范围内】的数据。例如我定义某个作业间隔时间为0.5秒,则flink已0.5秒为界,进行数据处理。有界数据用在离线数据的处理场景较多无界:就是指flink始终【监听数据源】里的数据,获取到就处理。无界数据往往用在【实时数据】处理下的场景较多。我这里结合我们项目的场景来给各位说一下该选

文章图片
#flink#kafka#linq
漏桶和令牌桶的区别

一、漏桶把请求比作是水,请求进来了就把请求先放进桶里,但是不处理,并以限定的速度出水,出水就相当于处理请求。当水来得过猛而出水不够快时就会导致水直接溢出,即拒绝服务漏桶算法可以很好的控制流量的访问速度,一旦超过该速度就拒绝服务。二、令牌桶令牌桶算法的原理是系统会以一个恒定的速度往桶里放入令牌,而如果请求需要被处理,则需要先从桶里获取一个令牌,当桶里没有令牌可取时,则拒绝服务。三、区别漏桶:如果一下

Jstack查询线程堆栈

Jstack是什么?jstack是java虚拟机自带的一种堆栈跟踪工具。jstack主要用来查看Java线程的调用堆栈的,可以用来分析线程问题(如死锁)。线程快照是当前java虚拟机内每一条线程正在执行的方法堆栈的集合,生成线程快照的主要目的是定位线程出现长时间停顿的原因,如线程间死锁、死循环、请求外部资源导致的长时间等待等。 线程出现停顿的时候通过jstack来查看各个线程的调用堆栈,就可以知道

文章图片
#java
深入分析AQS实现原理

深入分析AQS实现原理简单解释一下J.U.C,是JDK中提供的并发工具包,java.util.concurrent。里面提供了很多并发编程中很常用的实用工具类,比如atomic原子操作、比如lock同步锁、fork/join等。从Lock作为切入点我想以lock作为切入点来讲解AQS,毕竟同步锁是解决线程安全问题的通用手段,也是我们工作中用得比较多的方式。Lock APILock是一个接口,方法定

#java
查看navicat连接数据库的密码

在decrypt里面把加密的密码贴进去就可以了,加密密码怎么来在navicat里面文件-导出-选择-导出密码。然后再文件里面找到password。

文章图片
#matlab#开发语言
Spring boot中获取application.yml配置

在实际开发中,我们会在把环境配置放到yml中那么我们如何获取yml的值呢。先上3种ymlmavenDemo:port: 80mavenDemo1:super:port: 81mavenDemo2:List:- port: 82- port: 83比如这种yml格式我们如何分别获取他们的值呢。方式一:使用@Value注解的方式。public class DemoProperties {@Value(

#spring boot#java#spring
4-API-Redisson

Redisson:if (redis.call('exists', KEYS[1]) == 0) then判断key是否存在redis.call('hset', KEYS[1], ARGV[2], 1);如果不存在,则设置key的 某个字段value=1redis.call('pexpire', KEYS[1], ARGV[1]);设置key的过期时间return nil;end;if (redi

#java#redis#缓存
到底了