1

2

3

4

5

6

7

8

/**

 * Created by kl on 2018/7/20.

 * Content :延时job

 */

public class DelayJob {

    private Map jobParams;//job执行参数

    private Class aClass;//具体执行实例实现

}

1

2

3

4

5

6

7

/**

 * Created by kl on 2018/7/20.

 * Content :延时job执行器接口

 */

public interface ExecuteJob {

     void execute(DelayJob job);

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

@Component

public class JobTimer {

    static final String jobsTag = "customer_jobtimer_jobs";

    @Autowired

    private RedissonClient client;

    @Autowired

    private ApplicationContext context;

    ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * 2);

    @PostConstruct

    public void startJobTimer() {

        RBlockingQueueblockingQueue = client.getBlockingQueue(jobsTag);

        new Thread() {

            @Override

            public void run() {

                while (true) {

                    try {

                        DelayJob job = blockingQueue.take();

                        executorService.execute(new ExecutorTask(context, job));

                    } catch (Exception e) {

                        e.printStackTrace();

                        try {

                            TimeUnit.SECONDS.sleep(60);

                        } catch (Exception ex) {

                        }

                    }

                }

            }

        }.start();

    }

    class ExecutorTask implements Runnable {

        private ApplicationContext context;

        private DelayJob delayJob;

        public ExecutorTask(ApplicationContext context, DelayJob delayJob) {

            this.context = context;

            this.delayJob = delayJob;

        }

        @Override

        public void run() {

            ExecuteJob service = (ExecuteJob) context.getBean(delayJob.getaClass());

            service.execute(delayJob);

        }

    }

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

/**

 * Created by kl on 2018/7/20.

 * Content :延时job服务

 */

@Component

public class DelayJobService {

    @Autowired

    private RedissonClient client;

    public void submitJob(DelayJob job, Long delay, TimeUnit timeUnit){

        RBlockingQueueblockingQueue = client.getBlockingQueue(JobTimer.jobsTag);

        RDelayedQueue delayedQueue = client.getDelayedQueue(blockingQueue);

        delayedQueue.offer(job,delay,timeUnit);

    }

}