首页 > 其他分享 >PowerJob 快速上手 Ruoyi接入PowerJob

PowerJob 快速上手 Ruoyi接入PowerJob

时间:2023-04-02 15:23:05浏览次数:36  
标签:接入 worker Ruoyi powerjob tech PowerJob import message

一、引入依赖

1、pom.xml(ruoyi)

           <!--快速集成PowerJob执行器-->
            <dependency>
                <groupId>tech.powerjob</groupId>
                <artifactId>powerjob-worker-spring-boot-starter</artifactId>
                <version>4.3.1</version>
            </dependency>

2、pom.xml(ruoyi-admin)

        <dependency>
            <groupId>tech.powerjob</groupId>
            <artifactId>powerjob-worker-spring-boot-starter</artifactId>
        </dependency>

3、pom.xml(ruoyi-quartz)

        <dependency>
            <groupId>tech.powerjob</groupId>
            <artifactId>powerjob-worker-spring-boot-starter</artifactId>
        </dependency>

二、配置文件修改

#powerjob配置
powerjob:
  worker:
    app-name: rouyi
    akka-port: 27777
    server-address: 192.168.56.12:7700
    protocol: http
    store-strategy: disk
    max-result-length: 4096
    max-appended-wf-context-length: 4096
    max-lightweight-task-num: 1024
    max-heavy-task-num: 64

三、powerJob注册应用

四、代码

package com.ruoyi.quartz.processors;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.stereotype.Component;
import tech.powerjob.worker.core.processor.ProcessResult;
import tech.powerjob.worker.core.processor.TaskContext;
import tech.powerjob.worker.core.processor.sdk.BasicProcessor;

import java.util.Date;

@Component
public class NoticeProcessors  implements BasicProcessor {

    @Autowired
    private JavaMailSender javaMailSender;
    @Override
    public ProcessResult process(TaskContext taskContext) throws Exception {

        //创建简单的邮件发送对象
        SimpleMailMessage message = new SimpleMailMessage();
        message.setFrom(taskContext.getJobParams()+"<[email protected]>");           // 设置发件人邮箱(若配置默认邮箱则不用再设置)
        message.setTo("[email protected]");            // 设置收件人邮箱
        message.setCc("[email protected]");            // 设置抄报人邮箱(可以不填写)
        message.setBcc("[email protected]");             // 设置密送人邮箱(可以不填写)
        message.setSubject("打卡提醒");                  // 设置邮件主题
        message.setText("新的一天开始了,别忘记打卡哟!!!"); // 设置邮件文本内容
        message.setSentDate(new Date());                // 设置邮件发送时间
        //发送
        javaMailSender.send(message);
        boolean success = true;
        return new ProcessResult(success, taskContext + ": " + success);    }
}

 

 当然也可以自己单独建一个模块

五、PowerJob配置

六、测试

 

 

标签:接入,worker,Ruoyi,powerjob,tech,PowerJob,import,message
From: https://www.cnblogs.com/mangoubiubiu/p/17280540.html

相关文章

  • 开发一个二方包,优雅地为系统接入ELK(elasticsearch+logstash+kibana)
    去年公司由于不断发展,内部自研系统越来越多,所以后来搭建了一个日志收集平台,并将日志收集功能以二方包形式引入各个自研系统,避免每个自研系统都要建立一套自己的日志模块,节约了开发时间,管理起来也更加容易。这篇文章主要介绍如何编写二方包,并整合到各个系统中。先介绍整个ELK日志......
  • 局域网主机共享单个公网IP地址接入Internet(SNAT)
    SNAT策略的原理   源地址转换,SourceNetworkAddressTranslation   修改数据包的源IP地址1.准备一台局域网里的主机做客户机,配置好ip、子网掩码,网关,dns服务器地址 局域网各主机正确设置IP地址/子网掩码 局域网各主机正确设置默认网关地址/dns服务器地址 内网的虚拟机......
  • 双网卡设备通过HIKSDK接入EasyCVR平台显示离线是什么原因?
    EasyCVR视频融合平台基于云边端协同架构,具有强大的数据接入、处理及分发能力,平台支持海量视频汇聚管理,可支持多协议接入,包括市场主流标准协议与厂家私有协议及SDK,如:国标GB28181、RTMP、RTSP/Onvif、海康Ehome、海康SDK、宇视SDK等(具体见下图)。平台能在复杂的网络环境中,将分散的各......
  • 华为NVR设备接入EasyCVR视频融合平台后不显示摄像头的问题排查与解决
    在上期的文章中,我们和大家分享了关于EasyCVR平台与华为IVS3800平台的对接相关经验分享,感兴趣的用户可以翻阅我们往期的文章进行查看。今天我们来分享一下华为NVR设备接入平台后不显示摄像头的问题排查与解决。在EasyCVR对接华为NVR设备的过程中,通常是使用国标GB28181协议,但是有......
  • SHELL创建钉钉群接入机器人推送报警信息(text消息类型)
    步骤一:获取自定义机器人Webhook选择需要添加机器人的群聊,然后依次单击群设置 > 智能群助手。在机器人管理页面选择自定义机器人,输入机器人名字并选择要发送消息的群,同时可以为机器人设置机器人头像。 完成必要的安全设置,勾选我已阅读并同意《自定义机器人服务......
  • ChatGPT 微信接入 C#完整源码
    1.无需搭建服务器,操作极其简单。  2.winform运行程序扫码进行微信登录,勾上自动回复,就可以充当机器人调用chatGPT可实现自动回复,可以申请小号操作。  3.可以识别会话消息和群聊消息,拉入群聊@机器人可以进行群聊的消息回复,可以得到@自己的回复消息。4.代码是完整的也......
  • EasyCVR视频融合平台国标GB28181协议设备接入时,可支持过滤通道类型
    EasyCVR基于云边端智能协同架构,能支持海量视频的轻量化接入与集中汇聚管理,平台可支持多协议接入,包括市场主流标准协议与厂家私有协议及SDK,如:国标GB28181、RTMP、RTSP/Onvif、海康Ehome、海康SDK、宇视SDK等(具体见下图),可分发多格式的视频流,包括:RTSP、RTMP、HTTP-FLV、WS-FLV、HLS、......
  • 玩转RuoYi-Cloud-Plus--7.docker部署nacos(单机)
    7.docker部署nacos(单机)仅部署nacos-server,不使用prometheus/grafana等监控组件 1.拉取镜像dockerpullnacos/nacos-serverdockerpullna......
  • TB平台接入API调用商品详情
    API地址:https://api-gw.…….cn/taobao/调用示例:https://api-gw.…….cn/taobao/item_search/?key=&&q=女装&start_price=0&end_price=0&page=1&cat=0&discount_only=&sor......
  • 国标GB28118协议设备接入EasyCVR平台,视频无法播放的原因排查与解决
    EasyCVR视频融合平台基于云边端协同一体化架构,具备强大的数据接入、处理及分发能力,平台可提供视频直播、录像、回放、检索、云存储、级联、告警等功能。将EasyCVR与智能分......