目录

0 课程视频

1 RestTemplate-> 是Web Http 客户端请求 模板工具

1.1 使用RestTemplate -> 选择执行引擎 Http客户端请求工具

1.2 执行引擎 Http客户端请求工具

1.2.1 JDK HttpUrlConnection

1.2.2 Apache HttpClient

1.2.3 OkHttp 

1.2 升级版 -> WebClient -> 非阻塞

2 RestTemplate 的 GET请求 -> 定时存入数据库

2.1 RestTemplate.getForObject  获取对象

2.2 RestTemplate.getForEntity 获取 对象 状态码 请求头

2.2.1 请求获取数据

2.2.2 请求到的数据格式

2.2.3 数据格式转化 -> hutool工具包->加依赖

2.2.4 list 里数据 for循环加入数据库

2.2.5 定时请求获取数据 -> 存入数据库 -> 完整代码

3 完整

3.1 配置

3.1.1 加依赖

3.1.2 yml 配置文件--> 正常连接数据库方式

3.2 代码

3.2.1 RestDto

3.2.2 DtoMapper

3.2.3 DtoService(imp)

3.2.4 Controller

4 数据库创建表

---

0 课程视频

Java Web 编程 之 RestTemplate 实战全集 & SpringBoot & Spring 框架集成_哔哩哔哩_bilibiliJava Web 编程 之 RestTemplate 实战全集 & SpringBoot & Spring 框架集成共计5条视频，包括：1 SpringBoot 集成 RestTemplate、2 SpringBoot HTTP 状态码解析、3 SpringBoot RestTemplate执行Http Get请求等，UP主更多精彩视频，请关注UP账号。https://www.bilibili.com/video/BV1tJ41147uj/?spm_id_from=333.337.search-card.all.click&vd_source=ff8b7f852278821525f11666b36f180a

1 RestTemplate-> 是Web Http 客户端请求 模板工具

1.1 使用RestTemplate -> 选择执行引擎 Http客户端请求工具

1.2 执行引擎 Http客户端请求工具

1.2.1 JDK HttpUrlConnection

// RestTemplate restTemplate = new RestTemplate();// 默认


RestTemplate restTemplate = new RestTemplate(new HttpComponentsClientHttpRequestFactory());

1.2.2 Apache HttpClient

1.2.3 OkHttp 

1.2 升级版 -> WebClient -> 非阻塞

2 RestTemplate 的 GET请求 -> 定时存入数据库

2.1 RestTemplate.getForObject  获取对象

2.2 RestTemplate.getForEntity 获取 对象 状态码 请求头

2.2.1 请求获取数据

String url = "https://www.okx.com/api/v5/market/ticker?instId=BTC-USDT";
        Map<String, Long> paramMap = new HashMap<>(); // 入参 可写 可不写  这里没有入参

        ResponseEntity<HashMap> result = restTemplate.getForEntity(url, HashMap.class, paramMap);// RestDto.class 根据 这个 序列化

2.2.2 请求到的数据格式

{
"code":"0",
"msg":"",
"data":[
{"instType":"SPOT","instId":"BTC-USDT","last":"28754.7","lastSz":"0.05152543","askPx":"28754.8","askSz":"0.16142622","bidPx":"28754.7","bidSz":"0.08685457","open24h":"27951.7","high24h":"28886.3","low24h":"27662.3","volCcy24h":"278879302.893932331","vol24h":"9872.68298003","ts":"1683056681112","sodUtc0":"28073.1","sodUtc8":"28535.2"}
]
}

2.2.3 数据格式转化 -> hutool工具包->加依赖

JSONArray jsonArray = JSONUtil.parseArray(result.getBody().get("data")); // list [{},{},{}] --> list里面是字典

List<RestDto> postEntityList = jsonArray.toList(RestDto.class); // list [RestDto,RestDto,RestDto] --> list里面是实体类

2.2.4 list 里数据 for循环加入数据库

for (RestDto postEntity : postEntityList) { // 循环 取实体类list

                int xxx = dtoService.save(postEntity);
                System.out.println(xxx);

2.2.5 定时请求获取数据 -> 存入数据库 -> 完整代码

@RestController
@Component // 代表这个类确保会被springboot扫描到
public class AutoController {

    private RestTemplate restTemplate = new RestTemplate() ;
    @Resource
    private DtoService dtoService;

    @Scheduled(fixedDelay = 3000) // 定时3000ms
    public void  autoData() {

        String url = "https://www.okx.com/api/v5/market/ticker?instId=BTC-USDT";
        Map<String, Long> paramMap = new HashMap<>(); // 入参 可写 可不写  这里没有入参

        // Map<String, Object> result = restTemplate.getForObject(url, Map.class, paramMap);// RestDto.class 根据 这个 序列化
        ResponseEntity<HashMap> result = restTemplate.getForEntity(url, HashMap.class, paramMap);// RestDto.class 根据 这个 序列化


        if(result.getStatusCode()== HttpStatus.OK) {
            JSONArray jsonArray = JSONUtil.parseArray(result.getBody().get("data")); // list [{},{},{}] --> list里面是字典

            List<RestDto> postEntityList = jsonArray.toList(RestDto.class); // list [RestDto,RestDto,RestDto] --> list里面是实体类

            for (RestDto postEntity : postEntityList) { // 循环 取实体类list

                int xxx = dtoService.save(postEntity);
                System.out.println(xxx);

            }
            
        }

    }
}

3 完整

3.1 配置

3.1.1 加依赖

<!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>2.0.29</version>
        </dependency>

<!--hutool-all 各种算法-->
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.8.12</version>
        </dependency>

3.1.2 yml 配置文件--> 正常连接数据库方式

3.2 代码

3.2.1 RestDto

@Data
@NoArgsConstructor
@AllArgsConstructor
@TableName("rest_dto") //连接数据库表名
public class RestDto implements Serializable {
    @TableId(value = "id", type = IdType.AUTO) // 解决 id 自动生成太大
    private Integer id; // 主键
    /**
     * SPOT
     */

    private String instType;
    /**
     * BTC-USDT
     */

    private String instId;
.
.
.
.
.
}

3.2.2 DtoMapper

@Mapper
public interface DtoMapper extends BaseMapper<RestDto> {
}

3.2.3 DtoService(imp)

@Service
@Transactional
public class DtoService {
    @Resource
    private DtoMapper dtoMapper;

    public int save(RestDto dto) { // 在controller中被调用

        int result = dtoMapper.insert(dto); // userMapper是操作数据库的方法

        return result ;

    }
}

3.2.4 Controller

@RestController
@Component // 代表这个类确保会被springboot扫描到
public class AutoController {

    private RestTemplate restTemplate = new RestTemplate() ;
    @Resource
    private DtoService dtoService;

    @Scheduled(fixedDelay = 3000) // 定时3000ms

    public void  autoData() {

        String url = "https://www.okx.com/api/v5/market/ticker?instId=BTC-USDT";
        Map<String, Long> paramMap = new HashMap<>(); // 入参 可写 可不写  这里没有入参

        // Map<String, Object> result = restTemplate.getForObject(url, Map.class, paramMap);// RestDto.class 根据 这个 序列化
        ResponseEntity<HashMap> result = restTemplate.getForEntity(url, HashMap.class, paramMap);// RestDto.class 根据 这个 序列化

        if(result.getStatusCode()== HttpStatus.OK) {
            JSONArray jsonArray = JSONUtil.parseArray(result.getBody().get("data")); // list [{},{},{}] --> list里面是字典

            List<RestDto> postEntityList = jsonArray.toList(RestDto.class); // list [RestDto,RestDto,RestDto] --> list里面是实体类

            for (RestDto postEntity : postEntityList) { // 循环 取实体类list

                int xxx = dtoService.save(postEntity);
                System.out.println(xxx);

            }

        }

    }
}

4 数据库创建表