前言 GitHub Actions 可以构建一组自动化的工作流程，并提供了拉取请求、合并分支等事件来触发他们。一般成熟的开源项目会在每个版本发布时提供 releases ，它就是通过 Actions 来自动发布的。本文就以自动发布 releases 这个例子来认识 Actions。 创建 workflow workflow 被称为工作流，每个工作流以一个…
Guava是Google发布的一个开源库，主要提供了一些在Java开发中非常有用的工具类和API，比如字符串处理、集合操作、函数式编程、缓存等等。不管是工作还是学习都是非常值得我们去熟悉的，一起来看看吧。 字符串（Strings） Strings是Guava提供的一组字符串工具，它提供了许多有用的方法来处理字符串。以下是Strings的主要方法：…
前言 在现代软件开发中，能够充分利用多核处理器的并发编程已经变得越来越重要。Java作为一门古老而强大的语言，提供了一整套并发编程的API。在本文中，我们将一起探索Java并发编程的基础，从线程的基本概念到同步机制，再到并发集合和线程池的使用。 线程基础 什么是线程…
Elasticsearch中Discovery模块负责发现集群中的节点以及Master的选举，其默认的实现称为Zen Discovery。 在Elasticsearch的配置文件中，有一项为node.master，如果将该配置设为true，该节点即可参与Master选举，获得被选举为Master节点的资格。 Master选举算法 （1）Paxos算法…
Elasticsearch写入分为单个文档的写入和批量写入，单个文档的写入称作Index请求，批量写入称为Bulk请求，他们具有相同的处理逻辑，请求被统一封装为BuklRequest。 单个文档的写入流程： 1.客户端向Node1发送写入请求…
GET基本流程 GET是根据index、type和ID向ES发送请求，获取文档数据，是读取操作，因此主分片或者副本分片都可以返回文档，不过新增的文档已经写入到主分片中但是还没有复制到副本分片时，副本分片可能会报告文档不存在。 假设有三个节点，分别存储着分片0和分片1，P开头的为主分片，R开头的为副本分片： 1.客户端向节点1发送GET请求…
前言 在当今数据风暴的时代，实时数据处理已经成为众多企业关注的热点。Apache Flink作为一个高性能、可扩展的实时计算框架，在实时数据处理领域占据着举足轻重的地位。Spring Boot则以其快速开发、简化配置而广受欢迎，将两者结合，我们可以快速地搭建起一个实时数据处理平台。本文将详细讲述如何将Flink应用集成到Spring…
