网站排名易下拉排名做外贸重新设计网站

网站排名易下拉排名,做外贸重新设计网站,柜子定制,镇江网站建站快速开始#xff08;本地IDE版#xff09; 官方教程:https://www.yuque.com/powerjob/guidence/quick_start PowerJob 的设计目标为企业级的分布式任务调度平台#xff0c;即成为公司内部的调度中间件。整个公司统一部署调度中心 powerjob-server#xff0c;旗下所有业务…快速开始本地IDE版官方教程:https://www.yuque.com/powerjob/guidence/quick_startPowerJob 的设计目标为企业级的分布式任务调度平台即成为公司内部的调度中间件。整个公司统一部署调度中心 powerjob-server旗下所有业务线应用只需要依赖 powerjob-worker 即可接入获取任务调度与分布式计算能力通过不同的 appName 相互隔离。因此PowerJob 由调度服务器powerjob-server,Power Job服务系统和执行器(powerjob-worker,你的业务系统上的定时任务)两部分组成powerjob-server 负责提供 Web 服务和完成任务的调度powerjob-worker 则负责执行用户所编写的任务代码同时提供分布式计算能力。以下为在本地开发环境快速搭建并试用 PowerJob 的教程。下载power job代码——运行调度服务——开发配置业务系统处理器及配置项——配置定时任务。STEP1: 初始化项目下载Power Job 程序代码,git clone https://github.com/PowerJob/PowerJob.gitgit clone https://gitcode.com/PowerStack/PowerJob.git导入 IDE源码结构如下我们需要启动调度服务器powerjob-server同时在 samples 工程中编写自己的处理器代码STEP2: 启动调度服务器创建数据库仅需要创建数据库找到你的 DB运行 SQL CREATE DATABASE IF NOT EXISTSpowerjob-dailyDEFAULT CHARSET utf8mb4搞定修改配置文件配置文件的说明官方文档写的非常详细此处不再赘述。需要修改的地方(路径: PowerJob/powerjob-server/powerjob-server-starter/src/main/resources/application-daily.properties)为数据库配置spring.datasource.core.jdbc-url、spring.datasource.core.username和spring.datasource.core.password当然有 mongoDB 的同学也可以修改spring.data.mongodb.uri以获取完全版体验。#参考配置文件代码 oms.envDAILY logging.configclasspath:logback-dev.xml #修改数据库相关配置 spring.datasource.core.driver-class-namecom.mysql.cj.jdbc.Driverspring.datasource.core.jdbc-urljdbc:mysql://127.0.0.1:3306/powerjob-daily?useUnicodetruecharacterEncodingUTF-8serverTimezoneAsia/Shanghaispring.datasource.core.usernameroot spring.datasource.core.passwordroot spring.datasource.core.maximum-pool-size20spring.datasource.core.minimum-idle5#修改数据库相关配置 oms.storage.dfs.mysql_series.drivercom.mysql.cj.jdbc.Driveroms.storage.dfs.mysql_series.urljdbc:mysql://127.0.0.1:3306/powerjob-daily?useUnicodetruecharacterEncodingUTF-8serverTimezoneAsia/Shanghaioms.storage.dfs.mysql_series.usernameroot oms.storage.dfs.mysql_series.passwordroot oms.storage.dfs.mysql_series.auto_create_tabletrue####### 邮件配置不需要邮件报警可以删除以下配置来避免报错 ####### #spring.mail.hostsmtp.163.com #spring.mail.usernamezqq163.com#spring.mail.passwordGOFZPNARMVKCGONV #spring.mail.properties.mail.smtp.authtrue#spring.mail.properties.mail.smtp.starttls.enabletrue#spring.mail.properties.mail.smtp.starttls.requiredtrue####### 钉钉配置(不需要的话删除以下配置来避免报错 ####### #oms.alarm.ding.app-keydingauqwkvxxnqskknfv #oms.alarm.ding.app-secretXWrEPdAZMPgJeFtHuL0LH73LRj-74umF2_0BFcoXMfvnX0pCQvt0rpb1JOJU_HLl #oms.alarm.ding.agent-id847044348#######Resourcecleaning properties ####### oms.instanceinfo.retention1oms.container.retention.local1oms.container.retention.remote-1#######Cacheproperties ####### oms.instance.metadata.cache.size1024#######Thresholdin precise fetchingserver(0~100).100means full detection of server,in which ####### ####### split-brain could be avoidedwhileperformance overhead would increase.####### oms.accurate.select.server.percentage50完成配置文件的修改后可以直接通过启动类 tech.powerjob.server.PowerJobServerApplication 启动调度服务器注意需要使用 daily 配置文件启动可自行百度搜索“SpringBoot 指定配置文件启动”观察启动日志查看是否启动成功启动成功后访问 http://127.0.0.1:7700/ 如果能顺利出现 Web 界面则说明调度服务器启动成功注册应用○ v4.x及前序版本点击主页应用注册按钮填入 powerjob-worker-samples 和控制台密码用于进入控制台注册示例应用当然你也可以注册其他的 appName只是别忘记在示例程序中同步修改○ v5.x 版本■ 选择 PowerJob Account进行登录简单起见可直接使用超级管理员登录账号 ADMIN密码 powerjob_admin登录后进入应用管理TAB点击右上角新增进行应用注册即可。STEP3: 编写示例代码进入示例工程powerjob-worker-samples修改配置文件连接powerjob-server并编写自己的处理器代码。1.修改 powerjob-worker-samples 的 application.properties将 powerjob.worker.app-name 改为刚刚在控制台注册的名称。server.port8081spring.jpa.open-in-viewfalse########### powerjob-worker 配置 ########### # akka 工作端口可选默认27777powerjob.worker.akka-port27777# 接入应用名称用于分组隔离推荐填写 本 Java 项目名称 powerjob.worker.app-namepowerjob-worker-samples # 调度服务器地址IP:Port 或 域名多值逗号分隔 powerjob.worker.server-address127.0.0.1:7700,127.0.0.1:7701# 持久化方式可选默认 disk powerjob.worker.store-strategydisk # 任务返回结果信息的最大长度超过这个长度的信息会被截断默认8192powerjob.worker.max-result-length4096# 单个任务追加的工作流上下文最大长度超过这个长度的会被直接丢弃默认8192powerjob.worker.max-appended-wf-context-length40962.编写自己的处理器随便找个地方新建类继承你想要使用的处理器各个处理器的介绍可见官方文档文档非常详细这里为了简单演示选择使用单机处理器 BasicProcessor以下是代码示例。Slf4jComponent//单击执行示例publicclassStandaloneProcessorDemoimplementsBasicProcessor{OverridepublicProcessResultprocess(TaskContextcontext)throwsException{// PowerJob 在线日志功能使用该 Logger 打印的日志可以直接在 PowerJob 控制台查看OmsLoggeromsLoggercontext.getOmsLogger();omsLogger.info(StandaloneProcessorDemo start process,context is {}.,context);returnnewProcessResult(true,process successfully~);}}启动示例程序即直接运行主类 tech.powerjob.samples.SampleApplication观察控制台输出信息判断是否启动成功。STEP4: 任务的配置与运行调度服务器与示例工程都启动完毕后再次前往Web页面 http://127.0.0.1:7700/ 进行任务的配置与运行。进入执行器应用的主界面v4.x 及前序版本在首页输入框输入配置的应用名称成功操作后会正式进入前端管理界面v5.x在应用管理页面选择对应的应用点击右侧“进入”按钮即可。进入注册应用首页后出现如下图页面新建任务点击“任务管理” - “新建任务”右上角开始创建任务。可按下图说明填写参数任务运行运维完成任务创建后即可在控制台看到刚才创建的任务如果觉得等待调度太过于漫长可以直接点击运行按钮立即运行本任务。前往任务实例边栏查看任务的运行状态和在线日志基础的教程到这里也就结束了PowerJob Worker 与 Server 的通信机制通信模式说明1.双向通信架构Worker 主动连接 ServerWorker 启动时主动连接 ServerServer 控制 Worker通过心跳机制实现任务调度和管理长连接维持建立持久的通信通道2.配置验证根据 [application.properties](file:///E:/java/PowerJob/powerjob-worker-samples/src/main/resources/application.properties) 中的配置powerjob.worker.server-addressWorker 需要知道 Server 地址powerjob.worker.protocol使用 HTTP 协议通信powerjob.worker.allow-lazy-connect-server当前设置为false强制验证连接3.通信流程初始化连接Worker 启动时连接到 Server心跳机制维持连接状态和任务状态同步任务执行Server 通过连接下发任务指令结果回传Worker 执行完成后将结果发送回 Server4.工作模式Server 作为控制中心负责任务分发和调度Worker 作为执行节点负责实际任务执行双向数据流任务下发和结果回传同时存在所以是Worker 既接受 Server 调度也主动与 Server 通信形成完整的分布式任务调度体系。PowerJob 执行方式区别执行类型分类1.单机执行Standalone特点任务在一个 Worker 节点上执行适用场景简单任务、不需要分布式处理的任务优势执行简单资源消耗少2.广播执行Broadcast特点任务被发送到所有可用的 Worker 节点同时执行适用场景需要在所有节点执行相同操作的场景应用场景系统通知、配置更新、缓存清理等3.MapReduce 执行特点Map 阶段将任务分解到多个 Worker 并行处理Reduce 阶段汇总各节点处理结果适用场景大数据处理、复杂计算任务优势充分利用分布式计算能力提高处理效率通信机制所有执行类型都通过powerjob.worker.server-address配置的 Server 地址进行任务调度Worker 通过powerjob.worker.protocol指定的协议与 Server 通信任务执行状态和结果通过心跳机制反馈给 Server