使用springboot一键按钮将redis数据同步到MySQL

A：使用springboot实现将redis数据同步到MySQL可以采取以下步骤：

1. 配置pom.xml依赖，引入redis和MySQL驱动。

2. 编写RedisRepository类，继承RedisTemplate，并实现将Redis数据转为MySQL数据的方法。

3. 编写MySQLRepository类，使用JdbcTemplate进行MySQL数据操作。

4. 编写同步服务类，使用注解@Scheduled定时任务，从RedisRepository获取Redis数据并转成MySQL数据，再存储到MySQLRepository中。

5. 在Springboot启动类中添加@EnableScheduling注解开启定时任务。

6. 运行程序，即可实现将Redis数据同步到MySQL。

下面是示例代码：

1. pom.xml依赖配置

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
        <version>2.2.2.RELEASE</version>
    </dependency>

    <dependency>
         <groupId>mysql</groupId>
         <artifactId>mysql-connector-java</artifactId>
         <version>8.0.17</version>
    </dependency>
</dependencies>

2. RedisRepository类

public class RedisRepository extends RedisTemplate<String, Object> {
    public RedisRepository(RedisConnectionFactory redisConnectionFactory) {
        setConnectionFactory(redisConnectionFactory);
        afterPropertiesSet();
    }

    // 将Redis数据转为MySQL数据
    public List<Map<String, Object>> redisToMysqlData() {
        List<Map<String, Object>> dataList = new ArrayList<>();

        Cursor<Map.Entry<String, Object>> cursor = this.opsForHash().scan("redis_key", ScanOptions.NONE);
        while (cursor.hasNext()) {
            Map.Entry<String, Object> entry = cursor.next();

            Map<String, Object> data = new HashMap<>();
            data.put("id", entry.getKey());
            data.put("value", entry.getValue());

            dataList.add(data);
        }

        return dataList;
    }
}

3. MySQLRepository类

public class MySQLRepository{
    private final JdbcTemplate jdbcTemplate;

    public MySQLRepository(DataSource dataSource) {
        jdbcTemplate = new JdbcTemplate(dataSource);
    }

    // 存储MySQL数据
    public void storeMysqlData(List<Map<String, Object>> dataList) {
        dataList.forEach(data -> {
            String sql = "INSERT INTO `mysql_table` (`id`, `value`) VALUES (?, ?)";

            Object[] params = new Object[]{data.get("id"), data.get("value")};
            jdbcTemplate.update(sql, params);
        });
    }
}

4. 同步服务类

@Service
public class SyncService {
    private final RedisRepository redisRepository;
    private final MySQLRepository mySQLRepository;

    public SyncService(RedisRepository redisRepository, MySQLRepository mySQLRepository) {
        this.redisRepository = redisRepository;
        this.mySQLRepository = mySQLRepository;
    }

    // 定时任务，每5分钟同步一次
    @Scheduled(cron = "0 */5 * * * ?")
    public void syncRedisToMySQL() {
        List<Map<String, Object>> dataList = redisRepository.redisToMysqlData();
        mySQLRepository.storeMysqlData(dataList);
    }
}

5. 启动类添加@EnableScheduling注解

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

这样就完成了将Redis数据同步到MySQL的操作。