Spring Boot 定时任务：每隔 5 秒读取数据库数据

如何使用 Spring Boot 框架用 Java 代码每隔 5 秒从数据库中读取数据

本文将详细介绍如何使用 Spring Boot 框架实现每隔 5 秒从数据库读取数据的定时任务。

1. 配置依赖项

首先，在 pom.xml 文件中添加 Spring Boot 和 MySQL 依赖项：

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

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
</dependency>

2. 配置数据库连接

在 application.properties 文件中添加 MySQL 数据库的连接信息：

spring.datasource.url=jdbc:mysql://localhost:3306/mydatabase
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

3. 创建数据访问对象（DAO）

创建一个数据访问对象（DAO）来处理数据库读取操作。例如，可以创建一个名为 UserDao 的类：

@Repository
public class UserDao {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    public List<User> findAll() {
        String sql = 'SELECT * FROM users';
        List<User> users = jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(User.class));
        return users;
    }

}

4. 创建服务类

创建一个服务类来定期执行数据库读取操作。例如，可以创建一个名为 UserService 的类：

@Service
public class UserService {

    @Autowired
    private UserDao userDao;

    @Scheduled(fixedRate = 5000)
    public void readFromDatabase() {
        List<User> users = userDao.findAll();
        System.out.println('Read ' + users.size() + ' users from database.');
    }

}

5. 启用定时任务

在应用程序的主类中添加 @EnableScheduling 注释来启用定时任务：

@SpringBootApplication
@EnableScheduling
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

}

这样，每隔 5 秒钟，Spring Boot 应用程序将从数据库中读取数据，并将其输出到控制台。

注意：

请根据您的实际情况调整数据库连接信息、SQL 语句和实体类 User 的定义。
@Scheduled(fixedRate = 5000) 表示每隔 5000 毫秒（即 5 秒）执行一次任务。
为了保证数据的一致性，建议在读取数据前进行数据库事务处理。
可以根据需要使用其他定时任务配置选项，例如 cron 表达式。

通过以上步骤，您就可以使用 Spring Boot 框架轻松实现每隔 5 秒从数据库读取数据的定时任务。