场景数据下载采用rpa实现数据服务采用java springboot实现需要进行一键数据补录操作1、设置消息承载的通信队列java 发送任务到rabbitmq和rpa端收到消息neimeng_data_download后将下载结果通过neimeng_data_download_result队列发给java spring 客户端监听的消息队列import org.springframework.amqp.core.Queue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Lazy; Configuration public class MQConfig { public static final String DOWNLOAD_QUEUE neimeng_data_download; public static final String DOWNLOAD_QUEUE_RESULT neimeng_data_download_result; Bean Lazy(value false) public Queue neimeng_data_download_result() { return new Queue(DOWNLOAD_QUEUE_RESULT, true); } Bean Lazy(value false) public Queue neimeng_data_download() { return new Queue(DOWNLOAD_QUEUE, true); } }2、监听端实现import com.alibaba.fastjson.JSON; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import cn.togeek.config.MQConfig; import cn.togeek.pojo.dto.SupplementMqDTO; import cn.togeek.service.DataSupplementService; import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; Slf4j Component RequiredArgsConstructor public class DataSupplementListener { private final DataSupplementService service; RabbitHandler RabbitListener(queues MQConfig.DOWNLOAD_QUEUE_RESULT, concurrency 10-20) public void handle(String message) { log.info(获取到消息{}, message); SupplementMqDTO msg JSON.parseObject(message, SupplementMqDTO.class); service.handData(msg); } }3、配置文件配置spring: rabbitmq: host: loclahost port: 56721 virtual-host: / username: user1 password: password listener: simple: acknowledge-mode: auto direct: retry: enabled: true # 开启消费重试机制 max-attempts: 3 # 最大重试机制默认为3 initial-interval: 1000 # 重试间隔,单位毫秒,默认10004、依赖管理implementation org.springframework.boot:spring-boot-starter-amqp