Spring boot 定时任务和发送请求

﹏ヽ暗。殇╰゛Y 2022-09-11 08:29 64阅读 0赞

# Spring boot 定时任务和发送请求 #

使用 @EnableScheduling 开启定时任务  
使用 @Scheduled(cron = “20 \* \* \* \* ?”) 设置定时时间  
cron 格式 百度一下  
使用 RestTemplate 发送请求  
使用 HttpHeaders 添加请求头信息  
使用 HttpEntity 请求实体  
使用 ResponseEntity 响应实体

代码：

package com.example.springboot01.task;
    
    import org.springframework.http.HttpEntity;
    import org.springframework.http.HttpHeaders;
    import org.springframework.http.HttpMethod;
    import org.springframework.http.ResponseEntity;
    import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Component;
    import org.springframework.web.client.RestTemplate;
    
    import com.alibaba.fastjson.JSON;
    import com.alibaba.fastjson.TypeReference;
    
    import java.time.LocalDateTime;
    import java.util.HashMap;
    import java.util.Map;
    
    @Component      //1.注册组件
    @EnableScheduling   // 2.开启定时任务
    public class HttpTask { 
        // cron 格式：[秒][分][小时][日][月][周][年]
        // 这里是每20秒执行一次
        @Scheduled(cron = "20 * * * * ?")
        private void requestTasks() { 
            System.err.println("执行定时任务的时间: " + LocalDateTime.now());
            // Rest 服务的客户端库
            RestTemplate restTemplate = new RestTemplate();
            // 请求头
            HttpHeaders httpHeaders = new HttpHeaders();
            // 添加请求头信息
            httpHeaders.add("Content-Type", "application/json; charset=UTF-8");
            // 请求参数
            Map<String, Object> params = new HashMap<>();
            params.put("userName", "a11");
            params.put("nickName", "111");
            // 请求实体，加入请求参数和请求头
            HttpEntity<Map<String, Object>> requestEntity = new HttpEntity<>(params, httpHeaders);
            // 响应实体
            ResponseEntity<String> resp = null;
            // 无参数get请求
    // HttpEntity<Map<String, Object>> requestEntity = null;
    // resp = restTemplate.exchange("http://127.0.0.1:8080/", HttpMethod.GET, requestEntity, String.class);
            // 有参数post请求
            // 请求数据
            resp = restTemplate.exchange("http://127.0.0.1:8080/postplay/user", HttpMethod.POST, requestEntity, String.class);
            // 获取body数据
            String body = resp.getBody();
            // 转成map
            Map<String, Object> res = JSON.parseObject(body, new TypeReference< Map<String,Object>>() { 
            });
            System.out.println(res);
        }
    }

话说，既然ResponseEntity可以用泛型，那为什么不直接用Map呢

package com.example.springboot01.task;
    
    import org.springframework.http.HttpEntity;
    import org.springframework.http.HttpHeaders;
    import org.springframework.http.HttpMethod;
    import org.springframework.http.ResponseEntity;
    import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Component;
    import org.springframework.web.client.RestTemplate;
    
    import java.time.LocalDateTime;
    import java.util.HashMap;
    import java.util.Map;
    
    @Component      //1.注册组件
    @EnableScheduling   // 2.开启定时任务
    public class HttpTask { 
        // cron 格式：[秒][分][小时][日][月][周][年]
        // 这里是每20秒执行一次
        @Scheduled(cron = "20 * * * * ?")
        private void requestTasks() { 
            System.err.println("执行定时任务的时间: " + LocalDateTime.now());
            // Rest 服务的客户端库
            RestTemplate restTemplate = new RestTemplate();
            // 请求头
            HttpHeaders httpHeaders = new HttpHeaders();
            // 添加请求头信息
            httpHeaders.add("Content-Type", "application/json; charset=UTF-8");
            // 请求参数
            Map<String, Object> params = new HashMap<>();
            params.put("userName", "a11");
            params.put("nickName", "111");
            // 请求实体，加入请求参数和请求头
            HttpEntity<Map<String, Object>> requestEntity = new HttpEntity<>(params, httpHeaders);
            // 响应实体，直接用Map
            ResponseEntity<Map> resp = null;
            // 无参数get请求
    // HttpEntity<Map<String, Object>> requestEntity = null;
    // resp = restTemplate.exchange("http://127.0.0.1:8080/", HttpMethod.GET, requestEntity, String.class);
            // 有参数post请求
            // 请求数据，最后一个参数是对应ResponseType，所以上面Response实体是Map，这里也用Map
            resp = restTemplate.exchange("http://127.0.0.1:8080/postplay/user", HttpMethod.POST, requestEntity, Map.class);
            // 获取body数据，直接赋值给Map
            Map<String, Object> body = resp.getBody();
            System.out.println(body);
        }
    }

关于中文乱码，需要设置restemplate编码

// 设置restemplate编码为utf-8
    restTemplate.getMessageConverters().set(1,new StringHttpMessageConverter(StandardCharsets.UTF_8));

因为对Java一些库的不了解，造成了，请求响应的中文乱码弄了很久，才找到这个解决方法，我一直想着拿到的字符串做转换，结果都不成功，今天同事说他都是使用 HutoolUtil 的请求类做会方便很多，学到了