进入正题之前，我们先看两个大厂案例： 10年IBM Lotes OA迁移 -来自国内500强发动机全链路制造公司 主要有如下几个痛点： 系统老旧，扩展性一般，无法集成现有的其他业务系统 随着人员的增加，经常性的出现卡…

使用CountDownLatch可以实现等待多个线程执行完毕的功能，实现线程之间的协调，让它们按照我们期望的顺序执行，从而避免了可能出现的并发问题。 CountDownLatch是如何实现主线程等待子线程全部结束的呢？ 代码用例 这里我们使用一段…

1 窗口触发机制 窗口计算的触发机制都是由Trigger类决定的,Flink中为各类内置的WindowsAssigner都设计了对应的默认Trigger. 层次结构如下: Trigger ProcessingTimeoutTriggerEventTimeTriggerCountTriggerDeltaTriggerNeverTrigger in GlobalWindowsContinuousEventTimeTrigge…

Stream流的收集操作 收集Stream流的含义：就是把Stream流操作后的结果数据 转回 到 集合 或者 数组 中去。Stream流：方便操作 集合 / 数组 的 手段。集合 / 数组：才是开发中的 目的 。 Stream流的收集方法 R collect（Collector co…

在大家熟悉的现货黄金交易软件MT4上，当订单被投放到市场之后，如果之前想要的价格已经不存在，订单就会以最接近其要求的价格执行，如果最终执行价比预期价格要高，则称为正向滑点，反之则为反向滑点。 从理论上…

1、benos_payload.bin结构分析 韦东山老师提供的开发文档里已经对程序的结构做了分析，这里不再赘述，下面是讨论mysbi跳转到benos的问题； 2、mysbi跳转到benos的代码 3、跳转产生的疑问 我认为mysbi.bin最后跳转到0x22000地址处执行&#xff0…

上篇文章canal 消费进度说到直接使用ClusterCanalConnector并发消费是有问题的，可以先用单点将canal事件发送到mq中，再由mq并发处理，另外mq还可以做到削峰的作用，让canal数据不至于阻塞。 使用队列，可以自己起一个单实…

以centos7为例进行数据盘挂载的操作演示，挂载一个200G盘 1、切换至root用户 z 2、查看要挂载的硬盘 执行sfdisk -s 或 fdisk -l可以看到有一个200G。 sfdisk -s fdisk -l 需要挂载200G的这块硬盘。 3、执行lvs查看当前的lvm信息 4、执行pvcreate /dev/sdb创建…