当前位置： 首页 > news >正文

Spark Streaming 内部运行机制详解

news 来源：原创 2025/7/5 10:42:30

核心思想：将实时数据流切割为“微批次”，利用 Spark Core 的批处理能力进行准实时计算。

1. 核心流程拆解

  1. 数据接收（Input Data Stream）

    • 输入源：Kafka、Flume、Socket 等实时数据流。

    • 接收器（Receiver）：Spark Streaming 启动接收器线程，持续监听数据流并缓存到内存（或磁盘）。

  2. 批次划分（Micro-Batching）

    • 时间窗口：按固定时间间隔（如 1秒、5秒）将数据流切割为多个小批次（DStream）。

    • 示例：若间隔为 2秒，则每 2秒的数据组成一个批次，形成 Batch 1, Batch 2...

  3. Spark Core 处理

    • RDD 转换：每个批次的数据转换为一个 RDD，调用 Spark Core 的算子（如 map、reduce）处理。

    • 并行计算：Driver 将任务分发给 Executor，各节点并行处理对应分区的数据。

  4. 结果输出

    • 输出操作：处理完一个批次后，结果写入外部系统（如 HDFS、数据库）或展示在实时仪表盘。

2. 核心概念：DStream（离散化流）

  • 本质：DStream 是 Spark Streaming 的核心抽象，表示按时间切分的 RDD 序列。

  • 特性：

    • 每个时间间隔生成一个 RDD（如 DStream = [RDD1, RDD2, ...]）。

    • 支持与 RDD 类似的转换操作（如 map、filter、reduceByKey）。

示例代码：

// 创建 DStream（从 Socket 接收数据，批次间隔 1秒）
val ssc = new StreamingContext(sparkConf, Seconds(1))
val lines = ssc.socketTextStream("localhost", 9999)// 处理数据：按单词拆分并计数
val words = lines.flatMap(_.split(" "))
val wordCounts = words.map(word => (word, 1)).reduceByKey(_ + _)// 输出结果
wordCounts.print()
ssc.start()         // 启动计算
ssc.awaitTermination()  // 等待终止
3. 为何称为“准实时”？

  • 微批处理（Micro-Batching）：

    • 数据按固定时间窗口（如 1秒）分批处理，延迟 = 窗口间隔 + 处理时间（通常秒级）。

    • 对比真正的实时处理（如 Flink 的逐事件处理），延迟稍高但吞吐量更大。

  • 适用场景：

    • 日志分析、实时仪表盘、异常检测等允许秒级延迟的场景。

    • 不适用于毫秒级延迟需求（如高频交易）。

4. 容错与可靠性

  • 数据恢复：

    • Checkpoint 机制：定期保存 DStream 的血缘（Lineage）和元数据，故障时从检查点恢复。

    • WAL（Write-Ahead Log）：接收器将数据写入预写日志，确保数据不丢失。

  • Exactly-Once 语义：

    • 结合事务性写入（如数据库事务），保证每个批次的数据处理且仅处理一次。

5. 性能优化要点
优化方向方法
减少批次间隔缩小窗口间隔（如从 2秒 → 1秒），但需平衡吞吐量和延迟。
并行度调整增加接收器和 Executor 的数量，提升数据接收与处理并行度。
内存管理控制接收器缓存大小（spark.streaming.receiver.maxRate），避免 OOM。
背压机制启用 spark.streaming.backpressure.enabled，动态调整接收速率。

总结

Spark Streaming = 微批处理 + Spark Core 批处理引擎

  • 优势：继承 Spark 的易用性、容错性和高吞吐量。

  • 局限：秒级延迟，不适合超低延迟场景（此类需求可转向 Structured Streaming 或 Flink）。

  • 核心公式：
    实时数据流 → 按时间切分为 DStream → 转换为 RDD 批次处理 → 输出结果

相关文章：

Spark Streaming 内部运行机制详解

核心思想：将实时数据流切割为“微批次”，利用 Spark Core 的批处理能力进行准实时计算。 1. 核心流程拆解 数据接收（Input Data Stream） 输入源：Kafka、Flume、Socket 等实时数据流。 接收器（Receiver&…...

编程日记 2025/7/5 10:42:30

Feign+Resilience4j实现微服务熔断机制：原理与实战

引言：为什么需要熔断器？ 在微服务架构中，服务间的依赖调用变得非常普遍。想象一下这样的场景：订单服务依赖支付服务，支付服务又依赖银行网关服务。如果银行网关服务出现故障，故障会向上蔓延，导…...

编程日记 2025/6/29 1:23:04

什么是SparkONYarn模式

1. 什么是 Spark on YARN？ Spark on YARN 是 Apache Spark 的一种部署模式，允许 Spark 应用程序在 Hadoop YARN 集群上运行，充分利用 YARN 的资源管理和调度能力。这种模式将 Spark 与 Hadoop 生态深度集成，使企业能够在同一集群…...

编程日记 2025/7/5 10:38:12

鸿蒙北向应用开发: deveco5.0 创建开源鸿蒙项目

本地已经安装deveco5.0 使用5.0创建开源鸿蒙项目 文件->新建->新建项目 直接创建空项目,一路默认 next 直接编译项目 直接连接开源鸿蒙5.0开发板编译会提示 compatibleSdkVersion and releaseType of the app do not match the apiVersion and releaseType on the dev…...

编程日记 2025/6/29 0:40:18

操作系统：内存管理

目录 1、主要目标 2、核心概念和技术 2.1 物理内存与虚拟内存 2.2 内存分页机制 2.3 页面置换算法 3、监控与性能优化 3.1 查看物理内存 3.2 查看虚拟内存 3.3 性能问题 1> 内存不足（OOM） 2> 内存泄漏 3> 内存碎片 3.4 性能优化策…...

编程日记 2025/6/29 1:23:29

腾讯优化DeepSeek的DeepEP通信框架：开启AI大模型训练新时代

事件背景 在人工智能（AI）技术迅猛发展的当下，大规模AI模型训练的需求与日俱增。高效的数据通信成为了提升AI模型训练效率的关键环节。混合专家模型（MoE）作为一种高效的大模型架构，通过动态分配专家网络处理…...

编程日记 2025/7/5 10:39:15

CSP-J普及组第一轮真题单选题专项训练（二）

CSP-J普及组第一轮真题单选题专项训练（二） (共15题，每2分，共30分;每题有且有一个正确选项） 1、一个 32 位整型变量占用（）个字节。 A. 32 B. 128 C. 4 D. 8 2、在内存储器中每个存储单元都被赋予一个唯一的序号,称为 A、下标 B、序号 C、地址 D、编号 3、编译器的主要…...

编程日记 2025/6/28 23:42:45

Android加固工具测评：易盾、顶象、360加固哪款更好用？

应用安全已经成为每个开发者和企业关注的核心问题。随着黑客技术的不断升级，单一的安全措施已经无法有效应对各种复杂的攻击威胁。Android加固工具应运而生，成为了提升应用安全的关键利器。这些加固工具通过代码混淆、加密、防篡改等技术手段&#xff0c…...

编程日记 2025/7/5 10:30:27

C++ 字符格式化输出

文章目录 一、简介二、实现代码三、实现效果 一、简介 这里使用std标准库简单实现一个字符格式化输出&#xff0c;方便后续的使用&#xff0c;它有点类似Qt中的QString操作。 二、实现代码 FMTString.hpp #pragma once#include <cmath> #include <cstdio> #include…...

编程日记 2025/6/28 23:58:29

内存中的“BANK”

一、BANK的定义与物理结构 基本概念 BANK&#xff08;存储体&#xff09; 是内存芯片内部的一个逻辑或物理分区&#xff0c;每个BANK由存储单元阵列、地址解码电路和缓冲器组成&#xff0c;用于分块管理内存操作。 作用&#xff1a;通过并行操作减少访问冲突&#xff0c;提升内…...

编程日记 2025/6/29 1:28:42

D-Pointer（Pimpl）设计模式（指向实现的指针）

Qt 的 D-Pointer&#xff08;Pimpl&#xff09;设计模式 1. Pimpl 模式简介 Pimpl&#xff08;Pointer to Implementation&#xff09;是一种设计模式&#xff0c;用于将类的接口与实现分离&#xff0c;从而隐藏实现细节&#xff0c;降低编译依赖&#xff0c;提高代码的可维护…...

编程日记 2025/7/5 10:32:51

XA协议和Tcc

基于 XA 协议的两阶段提交 (2PC)。这是一种分布式事务协议&#xff0c;旨在保证在多个参与者&#xff08;通常是不同的数据库或资源管理器&#xff09;共同参与的事务中&#xff0c;所有参与者要么都提交事务&#xff0c;要么都回滚事务&#xff0c;从而维护数据的一致性。 你…...

编程日记 2025/7/5 10:28:57

我们该如何使用DeepSeek帮我们减负？

在当今信息爆炸的时代&#xff0c;如何快速获取、筛选和分析信息已经成为各行各业的重要能力。而DeepSeek作为一种先进的智能搜索和信息挖掘工具&#xff0c;能够帮助用户快速找到所需的信息&#xff0c;并从海量数据中提取出有用的洞见。在这篇博文中&#xff0c;我们将深入探…...

编程日记 2025/7/5 10:30:26

25.5.13

感觉很久没有写算法题了&#xff0c;先来个滑动队列模板题试试水&#xff0c;就是用双端队列来实现会很方便&#xff0c;拿结构体来记录是第几个数和数的值即可&#xff0c;再定义两个双端队列&#xff0c;一个使他的值单调递增一个使他的值单调递减 使队头元素为最大值或者是最…...

编程日记 2025/7/5 10:30:27

软件测试——面试八股文（入门篇）

今天给大家分享软件测试面试题入门篇&#xff0c;看看大家能答对几题 一、 请你说一说测试用例的边界 参考回答&#xff1a; 边界值分析法就是对输入或输出的边界值进行测试的一种黑盒测试方法。通常边界值分析法是作为对等价类划分法的补充&#xff0c;这种情况下&#xff…...

编程日记 2025/7/5 10:33:37

脑机接口技术：开启人类与机器融合的新时代

摘要 脑机接口&#xff08;BCI&#xff09;技术作为一项前沿科技&#xff0c;正在逐步打破人类与机器之间的沟通障碍&#xff0c;为医疗、娱乐、教育等多个领域带来前所未有的变革。本文将详细介绍脑机接口技术的基本原理、发展现状、应用场景以及面临的挑战和未来发展趋势&…...

编程日记 2025/6/28 23:51:49

当三维地理信息遇上气象预警：电网安全如何实现“先知先觉”？

极端天气频发的当下&#xff0c;一场台风、一次暴雨就可能让电力系统陷入瘫痪。但你知道吗&#xff1f;如今的电网已能通过三维地理信息与气象数据的深度融合&#xff0c;在灾害来临前精准锁定风险&#xff0c;甚至将停电事故减少七成以上。这背后&#xff0c;正是国网电力空间…...

编程日记 2025/6/29 0:06:34

C++ string数据查找、string数据替换、string子串获取

string查找示例见下&#xff0c;代码见下&#xff0c;以及对应运行结果见下&#xff1a; #include<iostream>using namespace std;int main() {// 1string s1 "hellooooworld";cout << s1.find("oooo") << endl;// 2cout << (in…...

编程日记 2025/7/5 10:36:28

2025.5.13山东大学软件学院计算机图形学期末考试回忆版本

2025.5.13山东大学软件学院计图期末考试回忆版本 学院&#xff1a;软件学院 老师&#xff1a;周元峰、魏广顺 一、简述题&#xff08;2024原题一&#xff09; 1.图形绘制流水线的组成和作用 2.双缓冲机制是什么&#xff0c;有什么作用&#xff1f; 3.Delaunay三角化的四条…...

编程日记 2025/7/5 10:40:14

思极地图使用

思极地图api文档&#xff1a;思极地图开放平台 | 思极地图API SDK 思极地图SDK: <script src"https://map.sgcc.com.cn/maps?v3.0.0"></script> <script src"https://map.sgcc.com.cn/products/js-sdk/v3/assets/js/jquery-1.11.1.min.js&quo…...

编程日记 2025/7/5 10:36:28

Fiori学习专题四十一：表单控件

上节课我们学习了一些单一控件的使用&#xff0c;但是我们发现在页面内每个控件都占用了一行&#xff0c;这样子就显得不太好看&#xff0c;这节课我们引入一个表单控件来美化一下这个页面。 1.学习表单控件FORM之前我们先了解下哪些情况会使用到表单控件&#xff0c;最常见的场…...

编程日记 2025/6/29 1:09:11

基于STM32、HAL库的TDA7719TR音频接口芯片驱动程序设计

一、简介： TDA7719TR 是 NXP Semiconductors 推出的高性能音频处理芯片，专为汽车音响系统设计。它集成了 AM/FM 收音机调谐器、音频处理和音量控制功能，支持 I2C 控制接口，非常适合与 STM32 微控制器配合使用。 二、硬件接口： 典型的 STM32L4 与 TDA7719TR 硬件连接如下…...

编程日记 2025/6/29 1:15:50

Baklib智能云平台加速企业数据治理

Baklib数据治理核心优势 Baklib作为新一代企业级知识中台&#xff0c;其数据治理能力建立在全资产统一管理与智能化处理框架的双重基础之上。通过构建知识中台的核心架构&#xff0c;平台实现了图文、音视频等多模态数据的标准化存储与动态标签体系&#xff0c;有效解决传统管…...

编程日记 2025/7/5 10:29:37

面试中被问到谈谈你对threadlocal的理解

ThreadLocal 的核心理解 1. 基本概念 ThreadLocal 是 Java 提供的线程局部变量机制&#xff0c;用于在多线程环境中为每个线程维护独立的变量副本&#xff0c;实现线程隔离。其核心思想是空间换时间&#xff0c;通过避免共享变量带来的同步开销&#xff0c;提升并发性能。 2…...

编程日记 2025/7/5 10:31:16

Spring Boot 应用中实现基本的 SSE 功能

SSE 技术简介 SSE&#xff08;Server-Sent Events&#xff09;是一种允许服务器主动向客户端推送数据的技术。它基于 HTTP 长连接&#xff0c;使用简单&#xff0c;特别适合实时数据更新场景&#xff0c;如股票行情、新闻推送等。与 WebSocket 相比&#xff0c;SSE 更轻量级&a…...

编程日记 2025/7/5 10:38:12

【2025最新】Windows系统装VSCode搭建C/C++开发环境（附带所有安装包）

文章目录 为什么选择VSCode作为C/C开发工具&#xff1f;一、VSCode安装过程&#xff08;超简单&#xff01;&#xff09;二、VSCode中文界面设置&#xff08;再也不用对着英文发愁&#xff01;&#xff09;三、安装C/C插件&#xff08;编程必备神器&#xff01;&#xff09;四、…...

编程日记 2025/7/5 10:28:57

【MyBatis-8】MyBatis对象关联查询详解：高效处理复杂关系映射

在实际业务开发中&#xff0c;我们经常需要处理对象之间的关联关系&#xff0c;如一对一、一对多、多对多等。MyBatis作为一款优秀的持久层框架&#xff0c;提供了强大的对象关联查询能力。本文将深入探讨MyBatis中各种关联查询的实现方式、适用场景及最佳实践。 1. MyBatis关…...

编程日记 2025/7/5 10:31:58

Java基础(IO)

所有操作都在内存&#xff0c;不能长时间保存&#xff0c;IO主要在硬盘&#xff0c;可以长时间保存。 一、File类 File类被定义为文件和目录路径名的抽象表示形式&#xff0c;这是因为 File 类既可以表示文件也可以表示目录&#xff0c;他们都通过对应的路径来描述。 提供构…...

编程日记 2025/6/28 23:34:10

Trae IDE：AI深度集成的智能开发环境

&#xff08;以高效人机协作重塑编程体验&#xff09; 概述 Trae IDE&#xff08;发音 /treɪ/&#xff09;是一款深度集成AI能力的现代化开发工具&#xff0c;结合传统IDE的完备功能与前沿AI技术&#xff0c;提供智能问答、代码自动补全、跨文件编程及AI Agent驱动的自动化开…...

编程日记 2025/7/5 10:31:15

网站开发过程中样式忽然不显示问题

老规矩&#xff0c;先听故事&#xff1a;今天我开发网站时候遇到一个问题&#xff0c;就开发的这个网站在默认127.0.0.1运行样式有bug显示不出来&#xff0c;之前都可以&#xff0c;就完全一样的代码&#xff0c;之前可以正常运行显示&#xff0c;今天忽然就不行了&#xff0c;…...

编程日记 2025/7/5 10:29:37

双种群进化算法：动态约束处理与资源分配解决约束多目标优化问题

双种群进化算法&#xff1a;动态约束处理与资源分配解决约束多目标优化问题 一、引言 约束多目标优化问题&#xff08;CMOPs&#xff09;在工程设计、资源分配等领域广泛存在&#xff0c;其核心是在满足多个约束条件的同时优化多个目标函数。传统方法往往难以平衡约束满足与目…...

编程日记 2025/6/29 0:03:07

如何在 CentOS 7 虚拟机上配置静态 IP 地址并保持重启后 SSH 连接

在使用 CentOS 7 的虚拟机时&#xff0c;我们通常需要配置静态 IP 地址&#xff0c;以确保在每次虚拟机重启后能够通过 SSH 连接。本文将介绍如何在 CentOS 7 系统中配置静态 IP 地址&#xff0c;并确保配置在系统重启后依然生效。 步骤 1&#xff1a;检查虚拟机网络接口 首先…...

编程日记 2025/6/28 23:02:35

整数和浮点数转换时的精度损失

文章目录 int和float转换时的精度损失float组成解析&#xff08;1&#xff09; 32位浮点数的结构&#xff08;2&#xff09;示例&#xff1a;解析一个浮点数&#xff08;3&#xff09;偏置值的作用&#xff08;4&#xff09; 偏置值为什么是127&#xff1f;&#xff08;5&#…...

编程日记 2025/6/28 23:02:30

Protobuf工具

#region 知识点一 什么是 Protobuf //Protobuf 全称是 protocol - buffers&#xff08;协议缓冲区&#xff09; // 是谷歌提供给开发者的一个开源的协议生成工具 // 它的主要工作原理和我们之前做的自定义协议工具类似 // 只不过它更加的完善&…...

编程日记 2025/6/29 0:24:23

闭包原理与常见陷阱

引言 JavaScript闭包是前端开发中既强大又神秘的概念&#xff0c;它不仅是面试的必考题&#xff0c;更是解决复杂问题的利器。闭包让函数能够记住并访问其创建时的作用域&#xff0c;即使在该函数在其定义环境之外执行。 然而&#xff0c;正如许多强大的工具一样&#xff0c;…...

编程日记 2025/6/29 0:41:04

用 VS Code / PyCharm 编写你的第一个 Python 程序

用ChatGPT做软件测试 编写你的第一个 Python 程序——不只是“Hello, World”&#xff0c;而是构建认知、习惯与未来的起点 “第一行代码&#xff0c;是一个开发者认知世界的方式。” 编程的入门&#xff0c;不只是运行一个字符串输出&#xff0c;更是开始用计算机思维来理解、…...

编程日记 2025/7/5 10:32:51

Linux学习心得问题整理（一）

day01 运维初识 理解云计算运维目的是什么&#xff1f; 搭建云计算更有利于我们在公网环境下方便访问我们服务 节省时间的成本&#xff0c;能随时随地方便调度硬件资源&#xff0c;更容易搭建软件服务 安全可靠&#xff0c;售后期间支持技术支持维护 什么是运维&#xff1f…...

编程日记 2025/6/29 0:34:27

在scala中sparkSQL连接masql并添加新数据

以下是 Scala 中使用 Spark SQL 连接 MySQL 并添加数据的完整代码示例&#xff08;纯文本&#xff09;&#xff1a; 1. 准备连接参数&#xff08;需替换实际信息&#xff09; scala val jdbcUrl "jdbc:mysql://localhost:3306/test_db?useUnicodetrue&characterEnc…...

编程日记 2025/6/28 23:01:17

STM32F103_LL库+寄存器学习笔记22 - 基础定时器TIM实现1ms周期回调

导言 如上所示&#xff0c;STM32F103有两个基本定时器TIM6与TIM7&#xff0c;所谓「基本定时器」&#xff0c;即功能最简单的定时器。 项目地址&#xff1a; github: LL库: https://github.com/q164129345/MCU_Develop/tree/main/stm32f103_ll_library22_Basic_Timer寄存器方…...

编程日记 2025/7/5 10:28:57

.Net HttpClient 使用Json数据

HttpClient 使用Json数据 现代Web项目中&#xff0c;Json是最常用的数据格式。不论是前后端的交互中&#xff0c;还是纯前端项目中&#xff0c;都是如此。因此&#xff0c;.Net HttpClient 能不能更加方便、快捷的处理Json格式数据&#xff0c;也就至关重要了&#xff01; 文末…...

编程日记 2025/7/5 10:30:26

AI时代，如何实现人机共舞？

在科技飞速发展的当下&#xff0c;人工智能&#xff08;AI&#xff09;已不再是科幻作品中的遥远想象&#xff0c;而是深入渗透到我们生活与工作的方方面面。从智能手机中的语音助手&#xff0c;到金融领域的风险预测模型&#xff1b;从医疗影像的智能诊断&#xff0c;到工业生…...

编程日记 2025/6/28 23:42:55

flea-cache使用之Redis哨兵模式接入

Redis哨兵模式接入 1. 参考2. 依赖3. 基础接入3.1 定义Flea缓存接口3.2 定义抽象Flea缓存类3.3 定义Redis客户端接口类3.4 定义Redis客户端命令行3.5 定义哨兵模式Redis客户端实现类3.6 定义Redis哨兵连接池3.7 定义Redis哨兵配置文件3.8 定义Redis Flea缓存类3.9 定义抽象Flea…...

编程日记 2025/6/29 1:21:06

【Docker】Docker环境下快速部署Ollama与Open-WebUI：详细指南

Docker环境下快速部署Ollama与Open-WebUI&#xff1a;详细指南 在本篇文章中&#xff0c;我们将深入探讨如何在Docker中高效部署 Ollama 和 Open-WebUI&#xff0c;并解决在实际使用中常见的问题&#xff0c;确保你的模型服务稳定高效地运行。 一、Ollama 和 Open-WebUI 快速部…...

编程日记 2025/6/29 1:21:11

FFmpeg在Android开发中的核心价值是什么？

FFmpeg 在 Android 开发中的核心价值主要体现在其强大的多媒体处理能力和灵活性上&#xff0c;尤其在音视频编解码、流媒体处理及跨平台兼容性方面具有不可替代的作用。以下是具体分析&#xff1a; --- 1. 强大的音视频编解码能力 - 支持广泛格式&#xff1a;FFmpeg 支持几乎所…...

编程日记 2025/6/28 23:19:12

Java的进制转换

进制知识 Java 中使用不同的前缀表示数据&#xff0c;常见的进制数据有二进制&#xff08;0b&#xff09;、八进制&#xff08;0&#xff09;、十进制&#xff08;无&#xff09;、十六进制&#xff08;0x&#xff09;。 public class Demo1 {public static void main(String…...

编程日记 2025/6/28 23:01:19

SpringBoot中的拦截器

SpringBoot中的拦截器 Filter 典型场景 全局鉴权/接口耗时统计 WebFilter("/*") public class CostFilter implements Filter {Overridepublic void doFilter(ServletRequest req, ServletResponse res, FilterChain chain) {long start System.currentTimeMill…...

编程日记 2025/6/29 1:33:30

使用聊天模型和提示模板构建一个简单的 LLM 应用程序

官方教程 官方案例 在上面的链接注册后&#xff0c;请确保设置您的环境变量以开始记录追踪 export LANGSMITH_TRACING"true" export LANGSMITH_API_KEY"..."或者&#xff0c;如果在笔记本中&#xff0c;您可以使用以下命令设置它们 import getpass imp…...

编程日记 2025/6/28 23:45:00

paimon中批和流查看过去的快照的数据及变动的数据

1、批处理 创建表并插入三条数据 CREATE TABLE ws_t (id INT,ts BIGINT,vc INT,PRIMARY KEY (id) NOT ENFORCED ); INSERT INTO ws_t VALUES(2,2,2),(3,3,3),(4,4,4),(5,5,5); --设置执行模式为批处理 RESET execution.checkpointing.interval; SET execution.runtime-mode …...

编程日记 2025/6/28 23:56:31

Linux513 rsync本地传输 跨设备传输 一

ping节点bPing通 仅主机模式不需要设置网关节点a也可以Ping通节点b 同步成功 下载文件夹成功 今日源码 节点a 节点b...

编程日记 2025/6/29 0:55:32

c语言第一个小游戏：贪吃蛇小游戏08（贪吃蛇完结）

贪吃蛇撞墙和想不开咬死自己 #include <curses.h> #include <stdlib.h> struct snake{ int hang; int lie; struct snake *next; }; struct snake food; struct snake *head; struct snake *tail; int key; int dir; #define UP 1 #define DOWN -1 …...

编程日记 2025/6/28 23:07:52