我们消息中心是负责承载各个业务（比如电商，物流，营销中心，券中心，会员中心，积分中心，停车场等等）的消息发送需求，那么消息呢就可能有延迟需求，比如物流到货后十五分钟进行一次邀...
发简信
IP属地：江苏
-
基于RabbitMq的实现消息延时发送的优点以及其局限性； -
git cherry-pick用法
场景: 如果你的应用已经发布了一个版本2.0, 代码分支叫release-2.0, 现在正在开发3.0, 代码的分支叫dev-3.0. 那么有一天产品说, 要把正在开发的...
-
浅析DO、VO、DTO、PO的概念与区别
概念： VO（View Object）： 视图对象，用于展示层，它的作用是把某个指定页面（或组件）的所有数据封装起来。 DTO（Data Transfer Object）： ...
-
单线程Redis为何可以支持10w+qps
Redis为什么这么快 1、完全基于内存，绝大部分请求是纯粹的内存操作，非常快速。2、采用单线程，避免了不必要的上下文切换和竞争条件，也不存在多进程或者多线程导致的切换而消耗...
-
flink使用05-窗口简介和简单的使用
窗口是流式计算中非常重要的一个概念, 很多常见的功能都是通过各种窗口实现的, 比如每5分钟统计一下刚去1小时的热度. Flink DataStream API 将窗口独立成 ...
-
flink使用04-几种时间概念和watermark时间概念 在做实时计算的时候, 首先就需要搞清楚一个问题, 这个实时到底是怎么样的一个时间概念. 在 Flink 中, 总共有3种时间概念, 分别是 事件时间 ( Event...
-
flink使用03-数据输入的几种不同方法
flink的数据输入源主要分为两大类: 1. 内置数据源 集合数据源可以将数组或者集合作为 flink 的数据源,分别有不同的方法可以使用, 这种方式比较适合本地调试使用//...
-
flink使用02-从WordCount开始
相信大家在学习spark的时候接触的第一个案例肯定也是 wordCount, 本文也想通过这样一个简单的例子来讲一下一个简单的 flink 程序是什么样子的, 让大家对 fl...
-
flink使用12-用 table API 实现WordCount
Table API 是 Flink 构建在 DataSet 和 DataStream API 之上的一套结构化编程接口. 本文希望通过一个简单的 wordCount 的例子首...
