用RScheduledExecutorService定时任务

大家好，欢迎来到IT知识分享网。

redisson可以实现分布式的定时任务，本文是使用redis单节点实现的定时任务。

1、redisson配置文件

singleServerConfig: idleConnectionTimeout: 10000 connectTimeout: 10000 timeout: 3000 retryAttempts: 3 retryInterval: 1500 password: subscriptionsPerConnection: 5 clientName: null address: "redis://192.168.31.141:6379" subscriptionConnectionMinimumIdleSize: 1 subscriptionConnectionPoolSize: 50 connectionMinimumIdleSize: 24 connectionPoolSize: 64 database: 11 dnsMonitoringInterval: 5000 threads: 16 nettyThreads: 32 codec: ! 
  
    {} transportMode: "NIO" 
  

2、新建一个实现Runnable接口的调度任务

public class RunnableTask implements Runnable, Serializable { / * */ private static final long serialVersionUID = 0L; @RInject RedissonClient redisson; @Override public void run() { RAtomicLong atomic = redisson.getAtomicLong("myAtomic"); System.out.println("=======================>" + atomic.getAndIncrement()); } } 

3、启动类中实现RScheduledExecutorService

public class App { public static void main(String[] args) throws InterruptedException, ExecutionException { Config config = null; try { config = Config.fromYAML(App.class.getClassLoader().getResourceAsStream("config.yml")); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } RedissonClient redisson = Redisson.create(config); RedissonNodeConfig nodeConfig = new RedissonNodeConfig(config); nodeConfig.setExecutorServiceWorkers(Collections.singletonMap("myExceutorService", 5)); RedissonNode node = RedissonNode.create(nodeConfig); node.start(); RScheduledExecutorService executorService = redisson.getExecutorService("myExceutorService"); if (!executorService.isShutdown()) { RScheduledFuture 
   schedule = executorService.schedule(new RunnableTask(), CronSchedule.of("0/5 * * * * ?")); schedule.get(); } executorService.shutdown(); node.shutdown(); } }