glue java

glue java是什么，讓我們一起了解一下？

GLUE是一種新型的分布式平臺，它用純Java語言編寫，能提供類似于CORBA和RMI的分布對象技術(shù)。它不僅適用于企業(yè)級的分布式計算，也適用于并行科學(xué)計算。

例如我們讓XXL-Job使用GLUE(Java)調(diào)度REST接口該如何操作？

首先xxl-job-admin你應(yīng)該先跑起來，然后新建一個SpringBoot項目里面加上xxl-job的依賴，xxl-job的config等配置信息。

com.xuxueli
xxl-job-core
2.1.0

在application.properties中追加以下內(nèi)容。

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;
????}
}

以上就是小編今天的分享了，希望可以幫助到大家。