logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

【API篇】十一、Flink水位线传递与迟到数据处理

(本来8.30上课,老师等等家远的学生,说8.40开始讲课,结果你却9.00才到,那就门口站着取,别听了,类比数据不会再被对应窗口统计)如果过了推迟时间,你仍没有到,那就窗口关闭,教室关门,你去网吧游荡吧。在上面的延迟关窗与允许迟到的基础上,肯定还是不能囊括所有数据,因为乱序程度理论上可以无限大,如上的例子,对于等了10分钟才开课,且到了关教室门的时间还没到的学生,让去网吧游荡也不合理(类比流中直

文章图片
#flink#大数据
【Java设计模式】十六、责任链模式

三个请求处理者(领导)连成一条线,现在张三来请假,只需找其部分负责人即可,部门负责人看张三请假的天数,自己能批准就批准,不能批准就找他自己的上级(副总经理),以此类推。需求:请假流程控制,一天以下只需小组长同意,1到3天需要部门经理同意,3到7天需要总经理同意。责任链模式,即:为了避免请求发送者和多个请求处理者耦合在一起,让所有请求处理者通过下一对象的引用连成一条链。如此实现,扩展性强很强:如果以

文章图片
#java#设计模式#责任链模式
【ElasticSearch】ES案例:旅游酒店搜索

接下来添加品牌、城市、星级、价格的过滤功能。这里参与搜索的条件对应着不同的搜索类型,有全文检索,有精确查找,自然要用复合查询Boolean Search。从页面分析,我们需要实现搜索、分页、排序等功能。接下来实现根据这个坐标,将酒店结果按照到这个点的距离升序排序。接下来实现酒店搜索功能,完成关键字搜索和分页。重启服务,搜索和分页已实现。

文章图片
#elasticsearch#旅游#大数据
前端和Postman调用同一个接口,拿到的数据不一样

联调一个List接口,Postman自测得到的ID和前端调用得到的ID,结果不一样。

文章图片
#前端#postman
Java后端设置服务器允许跨域

简言之就是发送OPTION请求到服务器,服务器根据预检请求的请求头信息,自行判断是否允许跨域,并把判断结果放到响应的header中返回给浏览器。预检请求的请求头中包含了一些关键信息,例如请求方法、请求头字段、请求的URL等。这个示例中,浏览器向 https://www.example.com 发送了一个OPTIONS请求,用于检查是否允许发送POST请求,并且是否允许包含Content-Type请

文章图片
#java#服务器#开发语言
@SchedulerLock处理Spring Task在分布式环境下的重复执行问题

@SchedulerLock处理Spring Task在分布式环境下的重复执行问题

文章图片
#spring#分布式#java
【网课平台】Day5.XXL-Job实现分布式任务调度

视频文件的内容主要包括视频和音频,其文件格式是按照一 定的编码格式去编码,并且按照该文件所规定的封装格式将视频、音频、字幕等信息封装在一起,播放器会根据它们的封装格式去提取出编码,然后由播放器解码,最终播放音视频。以上三种能完成简单的任务,如给定开始时间与重复间隔,重复执行某任务,但比较复杂的实现不了,如:设置每月第一天凌晨1点执行任务、复杂调度任务的管理、任务间传递数据等等。任务的调度,即指系统

文章图片
#java#音视频
Java分布式锁

一个微服务有多个实例,或者说多个pod,也就有多个JVM,此时,想保证不同实例里的线程同步执行,靠synchronized这种JVM级别的锁就不能实现了,而要通过分布式锁,一种独立于JVM之外的锁

文章图片
#java#分布式
SpringBoot整合Flyway实现数据库的初始化和版本管理

Flyway 是一款开源的数据库版本管理工具。它可以很方便的在命令行中使用,或者在Java应用程序中引入,用于管理我们的数据库版本。

文章图片
#数据库#spring boot#java
    共 63 条
  • 1
  • 2
  • 3
  • 7
  • 请选择