草庐IT

XXL-JOB定时任务框架(Oracle定制版)

努力的小雨 2023-05-07 原文

特点

xxl-job是一个轻量级、易扩展的分布式任务调度平台，能够快速开发和简单学习。开放源代码并被多家公司线上产品使用，开箱即用。尽管其确实非常好用，但我在工作中使用的是Oracle数据库，因为xxl-job是针对MySQL设计的，所以使用起来需要进行一些魔改。为了方便后人使用，我已经创建了许多SQL和自增序列，并将其整合到了xxl-job-2.3.0版本中，环境已经在线上正常使用了，所以可以放心使用。此外，我还将钉钉群报警机器人集成在了框架中，一旦有任何错误报警就会直接锁定日志URL，方便快速查看和处理响应！

xxl-job-2.3.0版本

gitee地址：xxl-job-oracle

项目介绍：SQL文件在sql-doc中，如果不使用钉钉报警机制，请删掉DDTalkUtil工具类及其引用。如果使用，则需要申请钉钉报警机器人相关token，相关教程请移步官方地址：自定义机器人接入

自定义机器人接入

申请完成后，请修改相关DDTalkUtil中的***标注，我在这里还提供了一张表来标识测试环境和生产环境机器人的不同，也有一个字段表示是否需要提醒。如果您不需要此功能，可以直接删除。改掉具体如下：

public class DDTalkUtil {

    private static Logger logger = LoggerFactory.getLogger(DDTalkUtil.class);

    private static RestTemplate restTemplate = new RestTemplate();

    public static void toTalk(String jobtitle,String text,long jobid){
        try {
            CrmInterfaceUrlVO crmInterfaceUrlVO = XxlJobAdminConfig.getAdminConfig().getXxlJobInfoDao().getEnv("***");
            logger.info("获取对象："+crmInterfaceUrlVO.toString());
            //不提醒
            if ("N".equals(crmInterfaceUrlVO.getUseYn())) {
                return;
            }
            String finalUrl = "https://oapi.dingtalk.com/robot/send?access_token=***";
            JsonObject json = new JsonObject();
            json.addProperty("msgtype","link");
            HttpHeaders headers = new HttpHeaders();
            headers.add("Content-Type", "application/json;charset=UTF-8");
            JsonObject link = new JsonObject();
            link.addProperty("text",text);
            link.addProperty("title",crmInterfaceUrlVO.getName()+jobtitle);
            link.addProperty("messageUrl",crmInterfaceUrlVO.getUrl()+jobid);
            json.add("link",link);
            HttpEntity<String> formEntity = new HttpEntity<String>(json.toString(), headers);
            logger.info(restTemplate.exchange(finalUrl, HttpMethod.POST, formEntity, String.class, (Object) null).getBody());
        }catch (Exception e){
            logger.error("钉钉报警错误：{}",e.getMessage());
        }
    }
}

实际上，xxl-job功能非常强大，您还可以根据您的业务场景自定义修改DDTalkUtil工具类来满足需求。在页面中点击页签即可跳转到xxl-job的日志记录网页，非常方便和快捷。最终效果如下：


Oracle语句

本博主已经将相关SQL修改完毕，自行在Oracle库中复制粘贴即可。

  1. 执行sql-doc文件中的table.sql脚本，用户默认密码是admin/123456
  2. 相关xxl-job的教程，移步官网：XXL-JOB，本博主就不多解释了
  3. 请修改application.properties文件中的Oracle数据库连接
spring.datasource.url=jdbc:oracle:thin:@ip:port:**
spring.datasource.username=**
spring.datasource.password=**
spring.datasource.driver-class-name=oracle.jdbc.driver.OracleDriver

结语

虽然现在有其他支持Oracle数据库连接的定时任务框架，但我在使用该项目时并未发现其他好的定时任务框架，所以只能进行大量改动。毕竟，xxl-job框架一直在不断更新完善，社区也十分丰富，因此它被众多公司使用。

制版XXL-JOB自定crmInterfaceUrlVOJava

有关XXL-JOB定时任务框架(Oracle定制版)的更多相关文章

  1. ruby - 其他文件中的 Rake 任务 - 2

    我试图在一个项目中使用rake，如果我把所有东西都放到Rakefile中，它会很大并且很难读取/找到东西，所以我试着将每个命名空间放在lib/rake中它自己的文件中，我添加了这个到我的rake文件的顶部:Dir['#{File.dirname(__FILE__)}/lib/rake/*.rake'].map{|f|requiref}它加载文件没问题，但没有任务。我现在只有一个.rake文件作为测试，名为“servers.rake”，它看起来像这样:namespace:serverdotask:testdoputs"test"endend所以当我运行rakeserver:testid时

  2. ruby - 如何使用 RSpec::Core::RakeTask 创建 RSpec Rake 任务？ - 2

    如何使用RSpec::Core::RakeTask初始化RSpecRake任务？require'rspec/core/rake_task'RSpec::Core::RakeTask.newdo|t|#whatdoIputinhere?endInitialize函数记录在http://rubydoc.info/github/rspec/rspec-core/RSpec/Core/RakeTask#initialize-instance_method没有很好的记录；它只是说:-(RakeTask)initialize(*args,&task_block)AnewinstanceofRake

  3. TimeSformer：抛弃CNN的Transformer视频理解框架 - 2

    Transformers开始在视频识别领域的“猪突猛进”，各种改进和魔改层出不穷。由此作者将开启VideoTransformer系列的讲解，本篇主要介绍了FBAI团队的TimeSformer，这也是第一篇使用纯Transformer结构在视频识别上的文章。如果觉得有用，就请点赞、收藏、关注！paper:https://arxiv.org/abs/2102.05095code(offical):https://github.com/facebookresearch/TimeSformeraccept:ICML2021author:FacebookAI一、前言Transformers(VIT)在图

  4. ruby-on-rails - Rake 任务仅调用一次时执行两次 - 2

    我写了一个非常简单的rake任务来尝试找到这个问题的根源。namespace:foodotaskbar::environmentdoputs'RUNNING'endend当在控制台中执行rakefoo:bar时，输出为:RUNNINGRUNNING当我执行任何rake任务时会发生这种情况。有没有人遇到过这样的事情？编辑上面的rake任务就是写在那个.rake文件中的所有内容。这是当前正在使用的Rakefile。requireFile.expand_path('../config/application',__FILE__)OurApp::Application.load_tasks这里

  5. ruby-on-rails - bundler : not executable: script/delayed_job - 2

    我正在尝试在我的远程服务器上运行以下命令(通过capistrano或ssh):bundleexecRAILS_ENV=productionscript/delayed_jobstart但我收到此错误消息:bundler:notexecutable:script/delayed_job以前从未见过这个，谷歌也没有适合我的东西。知道可能是什么问题吗？ 最佳答案 也许它没有运行权限？尝试运行这个命令chmod+xscript/delayed_job然后再次执行文件。 关于ruby-on-rai

  6. ruby - 帮助使用 Ruby 中的 "Whenever"gem 来执行 cron 任务 - 2

    我以前没有使用过cron，所以我不能确定我这样做是对的。我想要自动化的任务似乎没有运行。我在终端中执行了这些步骤:sudogeminstall每当切换到应用程序目录无论何时。(这创建了文件schedule.rb)我将此代码添加到schedule.rb:every10.minutesdorunner"User.vote",environment=>"development"endevery:hourdorunner"Digest.rss",:environment=>"development"end我将此代码添加到deploy.rb:after"deploy:symlink","depl

  7. ruby - 在 rake 任务中运行 capybara - 2

    如何在Rake任务中运行Capybara功能？例如:访问('http://google.com')谢谢! 最佳答案 在任务中尝试这样的事情:require'capybara'require'capybara/dsl'Capybara.current_driver=:seleniumBrowser=Class.new{includeCapybara::DSL}page=Browser.new.pagepage.visit("http://www.google.com")puts(page.html)

  8. ruby - sinatra 框架的 MVC 模式 - 2

    我想开始使用“Sinatra”框架进行编码，但我找不到该框架的“MVC”模式。是“MVC-Sinatra”模式或框架吗？ 最佳答案 您可能想查看Padrino这是一个围绕Sinatra构建的框架，可为您的项目提供更“类似Rails”的感觉，但没有那么多隐藏的魔法。这是使用Sinatra可以做什么的一个很好的例子。虽然如果您需要开始使用这很好，但我个人建议您将它用作学习工具，以对您来说最有意义的方式使用Sinatra构建您自己的应用程序。写一些测试/期望，写一些代码，通过测试-重复:)至于ORM，你还应该结帐Sequel其中(imho

  9. ruby - 在 Rakefile 中动态生成 Rake 测试任务(基于现有的测试文件) - 2

    我正在根据Rakefile中的现有测试文件动态生成测试任务。假设您有各种以模式命名的单元测试文件test_.rb.所以我正在做的是创建一个以“测试”命名空间内的文件名命名的任务。使用下面的代码，我可以用raketest:调用所有测试require'rake/testtask'task:default=>'test:all'namespace:testdodesc"Runalltests"Rake::TestTask.new(:all)do|t|t.test_files=FileList['test_*.rb']endFileList['test_*.rb'].eachdo|task|n

  10. ruby-on-rails - 使用 Rspec 测试 rake 任务不接受参数 - 2

    根据thispostbyStephenHagemann，我正在尝试为我的一个rake任务编写Rspec测试.lib/tasks/retry.rake:namespace:retrydotask:message,[:message_id]=>[:environment]do|t,args|TextMessage.new.resend!(args[:message_id])endendspec/tasks/retry_spec.rb:require'rails_helper'require'rake'describe'retrynamespaceraketask'dodescribe're

随机推荐