首页 > 其他分享 >消费任务进行审核文章

消费任务进行审核文章

时间:2023-07-05 19:45:57浏览次数:32  
标签:wmNewsAutoScanService responseResult 拉取 任务 文章 审核

文章审核:按照固定的频率拉取任务,每秒钟拉取一次,再审核文章。

 @Autowired
    private WmNewsAutoScanService wmNewsAutoScanService;
    /**
     * 消费任务【拉取任务】
     */
    @Scheduled(fixedRate = 1000)
    @Override
    public void scanNewsByTask() {

        log.info("消费任务,审核文章");

        ResponseResult responseResult = scheduleClient.poll(TaskTypeEnum.NEWS_SCAN_TIME.getTaskType(), TaskTypeEnum.NEWS_SCAN_TIME.getPriority());
        if(responseResult.getCode().equals(200) && responseResult.getData() != null){
            String s = JSON.toJSONString(responseResult.getData());
            Task task = JSON.parseObject(s, Task.class);
            WmNews wmNews = ProtostuffUtil.deserialize(task.getParameters(), WmNews.class);
            wmNewsAutoScanService.autoScanWmNews(wmNews.getId());
        }
    }

再自媒体微服务启动类上开启调度任务

@EnableScheduling //开启调度任务

标签:wmNewsAutoScanService,responseResult,拉取,任务,文章,审核
From: https://www.cnblogs.com/fxzm/p/17529627.html

相关文章

  • 去除内容多余样式php函数-文章来源 植物号 www.zhiwuhao.com
    去除内容多余样式php函数-文章来源植物号 www.zhiwuhao.comfunctionKillStyle($content){$content=preg_replace("/STYLE=.+?['|\"]/i",'',$content);//去除样式$content=preg_replace("/style=.+?['|\"]/i",'',$conte......
  • 未来数据定时刷新——从zset中获取预设时间内的任务添加到list中
    未来数据定时刷新——实现步骤:定时任务/每分钟————》未来数据的keys————》按照分值查询zset,判断数据是否到期——到期》同步到Redis中的list 1、如何获取zset中所有的key?keys模糊匹配,future。效率低SCNA命令:SCAN命令是一个基于游标的迭代器,SCAN命令......
  • Windows设置定时任务运行脚本/程序
    1、win+x打开计算机管理工具2、点击任务计划程序创建任务3、创建任务名称4、创建定时任务5、选择要运行的脚本及程序6、结果......
  • 拉取任务
    实现思路:消费任务————————》从redis中的list中pop数据——————》修改数据库的任务参数:任务的类型和优先级  pop:取出数据并删除删除任务&修改任务日志/***按照任务类型和优先级拉取任务*@paramtype*@paramprior......
  • 取消任务
    场景:第三接口网络不通,使用延迟任务进行重试,当达到阈值以后,取消任务。taskId——》删除任务——》更新日志状态——》删除redis中的数据1、根据taskid删除任务,修改任务日志状态为2(取消)2、删除redis中对应的任务数据,包括list和zset/***取消任务*@paramt......
  • 6.29 celery分布式异步任务框架
    1.celery:分步式异步任务框架 /1 异步任务/2 延迟任务/3 定时任务/4 celery架构消息中间件(broker):消息队列:可以使用redis,rabbitmq任务执行单元(worker):执行单元执行提交的任务任务执行结果存储(banckend):可以使用mysql,redis/5安装celery模块:cmd中......
  • 面试再问MySQL存储过程和触发器就把这篇文章给他
    Mysql存储过程及触发器trigger存储过程一、一个简单的存储过程1,一个简单的存储过程delimiter$$ createproceduretesta() begin Select*fromemp; Select*fromdept; End; $$; delimiter; --调用存储过程 calltesta();存储过程的结构组成:1,创建格式:createpr......
  • 面试再问MySQL存储过程和触发器就把这篇文章给他
    Mysql存储过程及触发器trigger 存储过程一、一个简单的存储过程1,一个简单的存储过程 delimiter$$ createproceduretesta() begin Select*fromemp; Select*fromdept; End; $$; delimiter; --调用存储过程 calltesta();存储过程的结构组成:1,创建......
  • webapi中用Quartz(定时任务)的步骤
         文件---新建---项目---ASP.NETWEB应用程序---程序命名---webapiNuget---Quartz(/v2.5)创建要在定时任务中执行的工作内容publicclassRJJob:Ijob创建调度任务(确定执行时间)Global.asax中,加入启动代码:JobScheduler.Start();......
  • 易基因: RRBS揭示基于DNA甲基化驱动基因的肾透明细胞癌预后模型的鉴定和验证|项目文章
    大家好,这里是专注表观组学十余年,领跑多组学科研服务的易基因。肾细胞癌(RCC)是最常见的肾癌亚型,每年超400万例新发病例,是泌尿系统恶性肿瘤导致的第二大死因。2%-70%的RCC为透明细胞RCC(Clearcellrenalcellcarcinoma,ccRCC)。DNA甲基化(DNAmethylation,DNAm)是主要的表观遗传修饰之一......