掌握分布式应用新纪元：Stateful Functions

在复杂多变的分布式系统世界中，Stateful Functions 是一个基于状态的函数库，旨在简化分布式状态应用程序的开发。它解决了诸如扩展性、一致性状态管理、分布式服务之间的可靠交互以及资源管理等常见挑战。

这个项目的核心构建于强大的 Apache Flink 之上，提供了一种新的抽象方式来构建分布式应用程序和服务。

核心概念

抽象层

Stateful Functions 应用由以下核心组件组成：

• 状态函数：构成应用的基本构建块，它们是通过消息调用的小型逻辑单元。每个函数作为可唯一寻址的虚拟实例存在，由类型和内部独一无二的 ID（字符串）定义。
• 状态：每个虚拟函数实例都有其私有本地状态，可以通过局部变量访问。
• 入口（Ingresses）与出口（Egresses）：入口用于事件最初进入应用，而出口则标准化了事件离开应用的方式。路由器（Routers）负责决定事件最初应由哪个功能实例处理。

模块化与可扩展性

模块 是向 Stateful Functions 应用添加基础构建块（如入口、出口、路由器和状态函数）的入口点。一个应用可以结合多个模块，每个模块贡献整体应用的一部分。这使得不同部分的应用可以由不同的模块贡献，促进了团队间的独立工作，但所有部分仍然部署在同一更大的应用上。

开始使用

获取与构建

需求

• Docker
• Maven 3.5.x 或以上
• Java 8 或以上

1. 克隆项目并安装依赖：

git clone <repository-url>
mvn clean install

2. 构建 Docker 基础镜像（如果计划使用 Docker 部署）：

./tools/docker/build-stateful-functions.sh

运行示例

尝试运行预先存在的 Greeter 示例：

cd statefun-examples/statefun-greeter-example
docker-compose build
docker-compose up

发送消息到 names 主题并查看 greetings 的响应以了解示例如何工作。

项目设置

创建一个简单的 Stateful Functions 应用，使用 Maven 快速启动模板：

mvn archetype:generate \
  -DarchetypeGroupId=org.apache.flink \
  -DarchetypeArtifactId=statefun-quickstart \
  -DarchetypeVersion=1.1-SNAPSHOT

然后导入你的IDE进行开发和测试。

IDE 中运行

参考 Harness 示例了解如何在 IDE 中直接运行应用。

部署应用

你可以将 Stateful Functions 应用打包为独立应用或 Flink 作业提交给 Flink 集群。

使用 Docker 镜像部署

创建一个 Dockerfile 来构建应用镜像。

将应用作为 Flink 任务部署

只需简单地将 statefun-flink-distribution 添加为你的应用依赖即可。

参与贡献

如果你对 Stateful Functions 感兴趣或者对其增强有兴趣，欢迎参与进来！你可以从 Apache Flink 网站 学习如何贡献，并在 Jira 上查看 "Stateful Functions" 组件中的社区工作进展。

许可证

本仓库代码遵循 Apache Software License 2 许可。