黑马程序员技术交流社区

标题: 【郑州校区】学成在线-第19天-讲义-分布式事务 七 [打印本页]

---

作者: 我是楠楠    时间: 2020-1-15 14:39
标题: 【郑州校区】学成在线-第19天-讲义-分布式事务 七

【郑州校区】学成在线-第19天-讲义-分布式事务 七

4.3 查询前N条任务
4.3.1 Dao
在XcTaskRepository中自定义方法如下：

[AppleScript] 纯文本查看 复制代码

 public interface XcTaskRepository extends JpaRepository<XcTask, String> {

//取出指定时间之前的记录

Page<XcTask> findByUpdateTimeBefore(Pageable pageable,Date updateTime);

}

4.3.2 Service

[AppleScript] 纯文本查看 复制代码

 @Service

public class TaskService {

@Autowired

XcTaskRepository xcTaskRepository;

@Autowired

RabbitTemplate rabbitTemplate;

//取出前n条任务,取出指定时间之前处理的任务

public List<XcTask> findTaskList(Date updateTime,int n){

//设置分页参数，取出前n 条记录

Pageable pageable = new PageRequest(0, n);

Page<XcTask> xcTasks = xcTaskRepository.findByUpdateTimeBefore(pageable,updateTime);

return xcTasks.getContent();

}

}

4.5.3 编写任务类
编写任务类，每分钟执行任务，启动订单工程，观察定时发送消息日志，观察rabbitMQ队列中是否有消息，代码如下：

[AppleScript] 纯文本查看 复制代码

package com.xuecheng.order.mq;

@Component

public class ChooseCourseTask {

private static final Logger LOGGER = LoggerFactory.getLogger(ChooseCourseTask.class);

@Autowired

TaskService taskService;

//每隔1分钟扫描消息表，向mq发送消息

@Scheduled(fixedDelay = 60000)

public void sendChoosecourseTask(){

//取出当前时间1分钟之前的时间

Calendar calendar =new GregorianCalendar();

calendar.setTime(new Date());

calendar.add(GregorianCalendar.MINUTE,‐1);

Date time = calendar.getTime();

List<XcTask> taskList = taskService.findTaskList(time, 1000);

}

｝

启动工程，测试读取任务列表的功能。
4.5 定时发送任务
4.5.1 Dao

[AppleScript] 纯文本查看 复制代码

添加更新任务方法：

 //更新任务处理时间

@Modifying

@Query("update XcTask t set t.updateTime = :updateTime where t.id = :id ")

public int updateTaskTime(@Param(value = "id") String id,@Param(value = "updateTime")Date

updateTime); 

4.5.2 Service

[AppleScript] 纯文本查看 复制代码

添加发送消息方法：

 /**

* //发送消息

* @param xcTask 任务对象

* @param ex 交换机id

* @param routingKey

*/

@Transactional

public void publish(XcTask xcTask,String ex,String routingKey){

//查询任务

Optional<XcTask> taskOptional = xcTaskRepository.findById(taskId);

if(taskOptional.isPresent()){

XcTask xcTask = taskOptional.get();

//String exchange, String routingKey, Object object

rabbitTemplate.convertAndSend(ex,routingKey,xcTask);

//更新任务时间为当前时间

xcTask.setUpdateTime(new Date());

xcTaskRepository.save(xcTask);

}

}

4.5.3 编写任务类
编写任务类，每分钟执行任务，启动订单工程，观察定时发送消息日志，观察rabbitMQ队列中是否有消息，代码如下：

[AppleScript] 纯文本查看 复制代码

package com.xuecheng.order.mq;

@Component

public class ChooseCourseTask {

private static final Logger LOGGER = LoggerFactory.getLogger(ChooseCourseTask.class);

@Autowired

TaskService taskService;

//每隔1分钟扫描消息表，向mq发送消息

@Scheduled(fixedDelay = 60000)

public void sendChoosecourseTask(){

//取出当前时间1分钟之前的时间

Calendar calendar =new GregorianCalendar();

calendar.setTime(new Date());

calendar.add(GregorianCalendar.MINUTE,‐1);

Date time = calendar.getTime();

List<XcTask> taskList = taskService.findTaskList(time, 1000);

//遍历任务列表

for(XcTask xcTask:taskList){

//发送选课消息

taskService.publish(xcTask, xcTask.getMqExchange(),xcTask.getMqRoutingkey());

LOGGER.info("send choose course task id:{}",taskId);

}

}

｝

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2