@Component
public class BeanModeJob {
    
    @XxlJob("beanModeJobHandler")
    public void execute() throws Exception {
        XxlJobHelper.log("Bean模式任务执行");
        // 业务逻辑
    }
}

@XxlJob("shardingJob")
public void shardingJob() {
    // 获取分片参数
    int shardIndex = XxlJobHelper.getShardIndex();
    int shardTotal = XxlJobHelper.getShardTotal();
    
    // 分片处理逻辑
    List<Long> userIds = getUserIdsByMod(shardIndex, shardTotal);
    for (Long userId : userIds) {
        processUser(userId);
    }
}

private List<Long> getUserIdsByMod(int shardIndex, int shardTotal) {
    return jdbcTemplate.queryForList(
        "SELECT id FROM user WHERE id % ? = ?",
        Long.class,
        shardTotal,
        shardIndex
    );
}

public class JobScheduleHelper {
    private Thread scheduleThread;
    private Thread ringThread;
    
    public void start() {
        // 调度线程
        scheduleThread = new Thread(() -> {
            while (!scheduleThreadToStop) {
                // 扫描待调度任务
                List<Long> scheduleList = getScheduleList();
                
                // 触发调度
                for (Long jobId : scheduleList) {
                    scheduleJob(jobId);
                }
                
                // 休眠等待
                TimeUnit.SECONDS.sleep(1);
            }
        });
        scheduleThread.start();
    }
}

CacheConfiguration<String, User> cacheCfg = new CacheConfiguration<>();

// 设置缓存名称
cacheCfg.setName("userCache");

// 设置缓存模式
cacheCfg.setCacheMode(CacheMode.PARTITIONED);

// 设置原子性模式
cacheCfg.setAtomicityMode(CacheAtomicityMode.ATOMIC);

// 设置备份数
cacheCfg.setBackups(1);

// 获取计算网格实例
IgniteCompute compute = ignite.compute();

// 获取集群组
ClusterGroup remoteGroup = ignite.cluster().forRemotes();
IgniteCompute remoteCompute = ignite.compute(remoteGroup);

@Data
@QuerySqlField.Group(
    indexes = {
        @QuerySqlField.Index(name = "idx_salary", fields = {"salary"}),
        @QuerySqlField.Index(name = "idx_dept_salary", fields = {"department", "salary"})
    }
)
public class Employee {
    @QuerySqlField(index = true)
    private long id;
    
    @QuerySqlField(index = true)
    private String name;
    
    @QuerySqlField
    private String department;
    
    @QuerySqlField
    private double salary;
}

public interface CalculatorService {
    int add(int a, int b);
    int subtract(int a, int b);
    int multiply(int a, int b);
    double divide(int a, int b);
}