其他分享
首页 > 其他分享> > Solon Aop 特色开发(6)新鲜货提取器,提取Bean的函数进行定制开发

Solon Aop 特色开发(6)新鲜货提取器,提取Bean的函数进行定制开发

作者:互联网

Solon,更小、更快、更自由!本系列专门介绍Solon Aop方面的特色:

为什么需要提取Bean的函数?绝不是闲得淡疼。比如:控制器的@Mapping;再比如:Xxl-Job的@XxlJob。这些都是要提取Bean的函数并定制加工的。

一、比如提取 @XxlJob 注解的函数,并注册到执行器

对Xxl-Job框架来说@XxlJob注解是已经存在的。适配,只需要注册一个Bean提取器即可:

 Aop.context().beanExtractorAdd(XxlJob.class, (bw, method, anno)->{
    //简单写下,以示意这个特性...
    //
    String name = anno.value();
    IJobHandler handler = new MethodJobHandler(bw.raw(), method, null, null);
    
    XxlJobExecutor.registJobHandler(name, handler);
 });

一顿简单操作,Bean里的函数已经变成Xxx-Job里job了。

二、应用

@Component
public class SampleXxlJob {
    /**
     * 1、简单任务示例(Bean模式)
     */
    @XxlJob("demoJobHandler")
    public void demoJobHandler() throws Exception {
        XxlJobHelper.log("XXL-JOB, Hello World.");

        for (int i = 0; i < 5; i++) {
            XxlJobHelper.log("beat at:" + i);
            TimeUnit.SECONDS.sleep(2);
        }
        // default success
    }


    /**
     * 2、分片广播任务
     */
    @XxlJob("shardingJobHandler")
    public void shardingJobHandler() throws Exception {

        // 分片参数
        int shardIndex = XxlJobHelper.getShardIndex();
        int shardTotal = XxlJobHelper.getShardTotal();

        XxlJobHelper.log("分片参数:当前分片序号 = {}, 总分片数 = {}", shardIndex, shardTotal);

        // 业务逻辑
        for (int i = 0; i < shardTotal; i++) {
            if (i == shardIndex) {
                XxlJobHelper.log("第 {} 片, 命中分片开始处理", i);
            } else {
                XxlJobHelper.log("第 {} 片, 忽略", i);
            }
        }

    }
}

如果你不喜欢这个注解,也可以很快换成像:@CloudJob。通过提取器,将Method注册到它的执行器就OK。

附:Solon 是什么?

一个插件式的 Java 微型基础开发框架。支持Web、Job、Remoting、MicoService等开发。

项目地址:

附:入门示例

标签:Solon,示例,XxlJobHelper,Bean,Aop,提取,XxlJob
来源: https://www.cnblogs.com/noear/p/14801249.html