使用Java写一个使用RestTemplate限流调用第三方HTTP接口获取接口返回值,再利用MyBatis-Plus将接口响应报文写入MySQL数据库

好的，下面是一个使用RestTemplate限流调用第三方HTTP接口获取接口返回值，并利用MyBatis-Plus将接口响应报文写入MySQL数据库的示例代码：

首先，需要在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
    <version>1.1.23</version>
</dependency>

<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>3.4.3.1</version>
</dependency>

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId>
</dependency>

接着，在application.properties文件中添加以下配置：

# 配置第三方API的URL
api.url=http://example.com/api

# 配置限流规则
resilience4j.circuitbreaker.instances.default.slidingWindowSize=10
resilience4j.circuitbreaker.instances.default.minimumNumberOfCalls=5
resilience4j.circuitbreaker.instances.default.failureRateThreshold=50
resilience4j.circuitbreaker.instances.default.waitDurationInOpenState=5000
resilience4j.circuitbreaker.instances.default.slowCallRateThreshold=100
resilience4j.circuitbreaker.instances.default.slowCallDurationThreshold=1000

# 配置数据库连接
spring.datasource.url=jdbc:mysql://localhost:3306/mydatabase?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

# 配置MyBatis-Plus
mybatis-plus.mapper-locations=classpath*:mapper/**/*.xml
mybatis-plus.type-aliases-package=com.example.demo.entity

然后，创建一个名为ApiService的类，用于调用第三方API：

@Service
public class ApiService {
    
    @Autowired
    private RestTemplate restTemplate;
    
    @Value("${api.url}")
    private String apiUrl;
    
    @Retry(name = "apiServiceRetry", fallbackMethod = "fallback")
    @CircuitBreaker(name = "apiServiceCircuitBreaker", fallbackMethod = "fallback")
    public String callApi() {
        ResponseEntity<String> response = restTemplate.getForEntity(apiUrl, String.class);
        return response.getBody();
    }
    
    public String fallback(Throwable t) {
        return "fallback";
    }
}

在上面的代码中，我们使用了Resilience4j框架提供的注解@Retry和@CircuitBreaker来实现重试和熔断功能。如果第三方API调用失败，会自动重试一定次数（默认为3次），如果重试仍然失败，则进入熔断状态。在熔断状态下，调用fallback方法返回一个默认值。

接下来，创建一个名为ApiResponse的实体类，用于封装接口响应报文：

@Data
public class ApiResponse {
    private String response;
}

然后，创建一个名为ApiDao的Mapper接口，用于定义数据访问方法：

@Mapper
public interface ApiDao extends BaseMapper<ApiResponse> {
}

接着，创建一个名为ApiService的Service类，用于调用第三方API并将响应报文写入数据库：

@Service
public class ApiService {
    
    @Autowired
    private RestTemplate restTemplate;
    
    @Autowired
    private ApiDao apiDao;
    
    @Value("${api.url}")
    private String apiUrl;
    
    @Retry(name = "apiServiceRetry", fallbackMethod = "fallback")
    @CircuitBreaker(name = "apiServiceCircuitBreaker", fallbackMethod = "fallback")
    public String callApi() {
        ResponseEntity<String> response = restTemplate.getForEntity(apiUrl, String.class);
        ApiResponse apiResponse = new ApiResponse();
        apiResponse.setResponse(response.getBody());
        apiDao.insert(apiResponse);
        return response.getBody();
    }
    
    public String fallback(Throwable t) {
        return "fallback";
    }
}

在上面的代码中，我们使用了MyBatis-Plus提供的BaseMapper接口进行数据库操作，调用insert方法将ApiResponse对象写入数据库。

最后，在Controller中使用ApiService类进行调用：

@RestController
public class ApiController {
    
    @Autowired
    private ApiService apiService;
    
    @GetMapping("/api")
    public String api() {
        return apiService.callApi();
    }
}

这样，我们就完成了一个使用RestTemplate限流调用第三方HTTP接口获取接口返回值，并利用MyBatis-Plus将接口响应报文写入MySQL数据库的SpringBoot项目。