Pulsar特性解析[Effectively once]
前言 https://www.splunk.com/en_us/blog/it/effectively-once-semantics-in-apache-pulsar.html pulsar在文章中详细介绍了是如何支持Effectively once的，本文不再重复阐述，下面只把文章中描述的结论做总结。后面会进行源码解析。 为了实现Effectively once，pulsar从两个方面支...
使用GitLab高效管理开发
本篇文章介绍了如何使用GitLab进行高效的远程开发协作。 开发流程介绍总体流程分为Issue指定，开发，版本发布三个步骤。 OKR制定创建一个新的OKR的时候，首先小组组长罗列出这个OKR中的主要目标，然后发起电话会议邀请组内成员一起讨论分析OKR的具体任务是那些 制定Milestones根据OKR讨论出来的任务创建Milestones，用来关联OKR中讨论出来的任务，这样可以在M...
无处不在的队列
队列定义先进者先出 内存队列顺序队列：使用数组实现的队列链式队列：使用链表实现的队列循环队列：避免顺序队列下队列满的数据搬移，动态计算tail和head指针阻塞队列：入队满阻塞，出队空阻塞并发队列：支持并发入队和并发出队双端队列：对头队尾都支持入队和出队操作。既是生产者又是消费者有界队列：队列大小固定无界队列：队列大小无固定优先队列：实际不是队列 应用场景生产者-消费者（阻塞并发队列）单消...
Websocket推送中心(四)-推送中心的集群架构
概述本文是WebSocket推送中心的第三章节， 本系列文章是在Spring Websocket Stomp的基础上实现的推送系统，计划包含如下几篇文章： 第一篇：Spring Websocket Stomp介绍第二篇：基于Websocket Stomp的推送中心实现第三篇：推送中心单机支持百万级连接的晋级之路第四篇：推送中心的集群架构方案设计落地 本章主线前三章介绍了推送中心的设计，单机支...
Websocket推送中心(三)-单机100W连接(C1000K)达成
概述本文是WebSocket推送中心的第三章节， 本系列文章是在Spring Websocket Stomp的基础上实现的推送系统，计划包含如下几篇文章： 第一篇：Spring Websocket Stomp介绍第二篇：基于Websocket Stomp的推送中心实现第三篇：推送中心单机支持百万级连接的晋级之路第四篇：推送中心的集群架构方案设计落地<br 本章主线上篇文章介绍了如何使用...
Websocket推送中心(二)-基于Stomp的推送中心设计
概述本文是WebSocket推送中心的第二章节， 本系列文章是在Spring Websocket Stomp的基础上实现的推送系统，计划包含如下几篇文章： 第一篇：Spring Websocket Stomp介绍第二篇：基于Websocket Stomp的推送中心实现第三篇：推送中心单机支持百万级连接的晋级之路第四篇：推送中心的集群架构方案设计落地 本章主线上篇文章介绍了Spring Web...
Websocket推送中心(一)-Spring Websocket Stomp介绍
概述公司开发项目众多，各个项目都有和终端推送的需求，于是决定实现一个公司级的推送中心，屏蔽技术细节，服务全公司。笔者在设计实现完后记录下心路历程。 本系列文章是在Spring Websocket Stomp的基础上实现的推送系统，计划包含如下几篇文章： 第一篇：Spring Websocket Stomp介绍第二篇：基于Websocket Stomp的推送中心实现第三篇：推送中心单机支持百万...
Flink源码解析[Source](三) - 旧版Data Sources详解&源码
概述本系列文章是旨在熟悉摸头flink的source-connect原理，希望可以做到自己可以实现一个新的source，代码解析将会以kafka的实现配合flink的api为主线解析。 flink版本为1.12.0 第一篇：为什么要解析Source源码第二篇：如何创建Flink kafka source第三篇：新版Data Srouces详解&源码 FlinkPulsarSou...
