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

SnailJob发布任务类型详解

news 2026/5/12 5:52:30

SnailJob 任务类型详解：集群任务、广播任务、固定分片任务、Map任务和MapReduce任务

SnailJob 是一个强大的分布式调度框架，支持多种任务类型以满足不同的业务需求。本文将详细介绍五种主要的任务类型：集群任务（Cluster Job）、广播任务（Broadcast Job）、固定分片任务（Sharding Job）、Map任务（Map Job）和MapReduce任务（MapReduce Job），并提供相应的代码示例和适用场景。

1. 集群任务（Cluster Job）

1.1 概述

集群任务是一种确保在一个分布式环境中只有一个节点执行特定任务的机制。这有助于避免重复执行相同的工作负载，并减少资源浪费。

1.2 使用范围

防止重复执行：适用于需要在多个节点上运行但只需要一个节点执行的任务。
数据同步：例如数据库备份或日志清理等操作，只需要在一个节点上执行即可。

1.3 示例代码

importcom.aizuda.snailjob.client.job.core.openapi.SnailJobOpenApi;publicclassClusterJobExample{publicstaticvoidmain(String[]args){SnailJobOpenApi.addClusterJob().setJobName("cluster-job-example").setExecutorInfo("executor-name").setCron("0 0/5 * * * ?")// 每5分钟执行一次.setDescription("This is a cluster job example").execute();}}

2. 广播任务（Broadcast Job）

2.1 概述

广播任务是指所有注册的执行器节点都会接收到该任务并执行。这种任务类型适用于需要在所有节点上进行某些操作的场景。

2.2 使用范围

缓存刷新：例如需要在所有节点上刷新本地缓存。
配置更新：如需通知所有节点重新加载配置文件。

2.3 示例代码

importcom.aizuda.snailjob.client.job.core.openapi.SnailJobOpenApi;publicclassBroadcastJobExample{publicstaticvoidmain(String[]args){SnailJobOpenApi.addBroadcastJob().setJobName("broadcast-job-example").setExecutorInfo("executor-name").setCron("0 0/10 * * * ?")// 每10分钟执行一次.setDescription("This is a broadcast job example").execute();}}

3. 固定分片任务（Sharding Job）

3.1 概述

固定分片任务允许你将一个大任务拆分成多个小任务（分片），每个分片可以独立执行。你可以指定分片的数量及其参数。

3.2 使用范围

大规模数据处理：如批量导入数据时，可以按批次划分任务。
并行处理：通过并行执行多个分片来提高处理效率。

3.3 示例代码

importcom.aizuda.snailjob.client.job.core.openapi.SnailJobOpenApi;publicclassShardingJobExample{publicstaticvoidmain(String[]args){SnailJobOpenApi.addShardingJob().setJobName("sharding-job-example").setExecutorInfo("executor-name").setCron("0 0/15 * * * ?")// 每15分钟执行一次.setDescription("This is a sharding job example").addShardingArgs("shard-1","shard-2","shard-3").setParallelNum(3)// 并行执行三个分片.execute();}}

4. Map任务（Map Job）

4.1 概述

Map任务允许你动态地定义任务的分片数量，通常根据实际的数据量来确定分片数。每个分片会独立执行，并传递相应的参数。

4.2 使用范围

动态数据处理：如从数据库查询出一批记录，然后为每条记录创建一个分片任务。
消息队列消费：处理消息队列中的消息时，可以根据消息的数量动态创建分片任务。

4.3 示例代码

importcom.aizuda.snailjob.client.job.core.openapi.SnailJobOpenApi;publicclassMapJobExample{publicstaticvoidmain(String[]args){SnailJobOpenApi.addMapJob().setJobName("map-job-example").setExecutorInfo("executor-name").setCron("0 0/20 * * * ?")// 每20分钟执行一次.setDescription("This is a map job example").setDataSources(Arrays.asList("item-1","item-2","item-3")).execute();}}

5. MapReduce任务（MapReduce Job）

5.1 概述

MapReduce任务不仅包括了Map阶段，还增加了Reduce阶段。在Map阶段，各个分片独立执行；在Reduce阶段，所有分片的结果会被汇总。

5.2 使用范围

结果汇总：如统计各分片处理的成功数，并在最后汇总总数。
合并输出：如合并多个分片生成的文件。

5.3 示例代码

importcom.aizuda.snailjob.client.job.core.openapi.SnailJobOpenApi;publicclassMapReduceJobExample{publicstaticvoidmain(String[]args){SnailJobOpenApi.addMapReduceJob().setJobName("mapreduce-job-example").setExecutorInfo("executor-name").setCron("0 0/30 * * * ?")// 每30分钟执行一次.setDescription("This is a mapreduce job example").setDataSources(Arrays.asList("item-1","item-2","item-3")).setReduceHandlerClassName("com.example.ReduceHandler")// Reduce阶段处理器类名.execute();}}