glue java是什么,讓我們一起了解一下?
GLUE是一種新型的分布式平臺,它用純Java語言編寫,能提供類似于CORBA和RMI的分布對象技術。它不僅適用于企業級的分布式計算,也適用于并行科學計算。
例如我們讓XXL-Job使用GLUE(Java)調度REST接口該如何操作?
首先xxl-job-admin你應該先跑起來,然后新建一個SpringBoot項目里面加上xxl-job的依賴,xxl-job的config等配置信息。
com.xuxueli xxl-job-core 2.1.0
在application.properties中追加以下內容。
xxl.job.admin.address?=?http://127.0.0.1:8080/xxl-job-admin xxl.job.executor.appname?=?rone-spark xxl.job.executor.ip?=?127.0.0.1 xxl.job.executor.port?=?9999 xxl.job.executor.logpath?=?/data/applogs/xxl-job/jobhandler xxl.job.executor.logretentiondays?=?-1
然后在新建一個xxl-job-config類。
package?com.rone.demo.XXLJob; import?com.xxl.job.core.executor.impl.XxlJobSpringExecutor; import?org.slf4j.Logger; import?org.slf4j.LoggerFactory; import?org.springframework.beans.factory.annotation.Value; import?org.springframework.context.annotation.Bean; import?org.springframework.context.annotation.Configuration; @Configuration public?class?XxlJobConfig?{ ????private?Logger?logger?=?LoggerFactory.getLogger(XxlJobConfig.class); ????@Value("${xxl.job.admin.address}") ????private?String?adminAddresses?;//="http://localhost:8080/xxl-job-admin"?; ????@Value("${xxl.job.executor.appname}") ????private?String?appName?;//="RoneDemo"; ????@Value("${xxl.job.executor.ip}") ????private?String?ip?;//=?"127.0.0.1"; ????@Value("${xxl.job.executor.port}") ????private?int?port?;//=?9999; ???/*?@Value("${xxl.job.accessToken}")*/ ????private?String?accessToken; ????@Value("${xxl.job.executor.logpath}") ????private?String?logPath?; ????//@Value("${xxl.job.executor.logretentiondays}") ????private?int?logRetentionDays?=?-1; ????@Bean(initMethod?=?"start",?destroyMethod?=?"destroy") ????public?XxlJobSpringExecutor?xxlJobExecutor()?{ ????????logger.info(">>>>>>>>>>>?xxl-job?config?init."); ????????XxlJobSpringExecutor?xxlJobSpringExecutor?=?new?XxlJobSpringExecutor(); ????????xxlJobSpringExecutor.setAdminAddresses(adminAddresses); ????????xxlJobSpringExecutor.setAppName(appName); ????????xxlJobSpringExecutor.setIp(ip); ????????xxlJobSpringExecutor.setPort(port); ????????xxlJobSpringExecutor.setAccessToken(accessToken); ????????xxlJobSpringExecutor.setLogPath(logPath); ????????xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays); ????????return?xxlJobSpringExecutor; ????} }
以上就是小編今天的分享了,希望可以幫助到大家。