redis的数据同步到MySQL的springboot代码

以下是Redis数据同步到MySQL的Spring Boot代码示例：

1. 创建一个Redis订阅者

创建一个Redis订阅者，监听Redis中的特定事件，以便在事件发生时同步数据到MySQL。以下是一个示例：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

@Component
@Configuration
public class RedisSubscriber implements MessageListener {
    
    private final RedisTemplate<String, String> redisTemplate;

    @Autowired
    public RedisSubscriber(RedisTemplate<String, String> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    @Override
    public void onMessage(Message message, byte[] pattern) {
        String data = redisTemplate.getStringSerializer().deserialize(message.getBody());
        String channel = redisTemplate.getStringSerializer().deserialize(message.getChannel());
        System.out.println("Received data : " + data);
        System.out.println("Received channel : " + channel);
        // 在此处编写同步到MySQL的代码逻辑
    }
}

2. 声明一个Redis消息监听器容器

使用Spring框架中的`RedisMessageListenerContainer`类创建一个Redis消息监听器容器。以下是示例代码：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.ChannelTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

@Configuration
public class RedisConfiguration {

    private final RedisSubscriber redisSubscriber;

    @Autowired
    public RedisConfiguration(RedisSubscriber redisSubscriber) {
        this.redisSubscriber = redisSubscriber;
    }

    @Bean
    public RedisMessageListenerContainer redisContainer(RedisConnectionFactory factory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(factory);
        container.addMessageListener(redisSubscriber, new ChannelTopic("channel-name"));
        container.setTopicSerializer(new StringRedisSerializer());
        return container;
    }
}

在上面的代码中，我们使用`ChannelTopic`对象指定要监听的Redis频道。在本例中，我们监听名为“channel-name”的频道。

3. 编写将数据同步到MySQL的代码逻辑

一旦收到Redis事件并解码数据后，我们需要编写代码将数据同步到MySQL数据库。这一步可以根据具体业务需求进行实现。

4. 运行Spring Boot应用程序

最后，运行Spring Boot应用程序以启动Redis消息监听器容器和Redis订阅者。一旦Redis中的数据发生变化，Redis消息监听器容器将自动通知RedisSubscriber对象，并调用onMessage()方法同步数据到MySQL。