使用Java代码实现Redis和数据库数据同步
更新时间：2024年06月03日 08:39:38 作者：浮夸的小白菜
这篇文章主要介绍了使用Java代码实现Redis和数据库数据同步问题,文中通过代码示例给大家讲解的非常详细,对大家的学习或工作有一定的帮助,需要的朋友可以参考下
这里我用到了Redis当中的发布订阅模式实现(JAVA代码实现)
先看图示
下面为代码实现
首先将RedisMessageListenerContainer交给Spring管理.
@Configuration
public class redisConfig {
@Autowired
RedisConnectionFactory redisConnectionFactory;
@Autowired
@Qualifier("carServiceDb")
private CarService carService;//操作数据库
@Bean
public RedisMessageListenerContainer listenerContainer(){
//创建一个Redis消息监听器容器对象
RedisMessageListenerContainer listenerContainer = new RedisMessageListenerContainer();
//设置Redis连接工厂对象
listenerContainer.setConnectionFactory(redisConnectionFactory);
//向监听器容器中添加一个监听器，该监听器的主题为INSERTED
listenerContainer.addMessageListener(new MessageListener() {
@Override
public void onMessage(Message message, byte[] pattern) {
System.out.println("*************insert*************");
String carJsonStr = new String(message.getBody());
Car car = JSONObject.parseObject(carJsonStr, Car.class);
carService.addCar(car);
System.out.println(new String(message.getBody()));
System.out.println(new String(pattern));
System.out.println("*************insert*************");
}
}, new ChannelTopic(ChannelEnum.INSERTED.name()));
//向监听器容器中添加一个监听器，该监听器的主题为UPDATED
listenerContainer.addMessageListener(new MessageListener() {
@Override
public void onMessage(Message message, byte[] pattern) {
System.out.println("*************UPDATED*************");
String carJsonStr = new String(message.getBody());
Car car = JSONObject.parseObject(carJsonStr, Car.class);
carService.updataCount(car.getBookId(),car.getNumber(),car.getUserId());
System.out.println(new String(message.getBody()));
System.out.println(new String(pattern));
System.out.println("*************UPDATED*************");
}
}, new ChannelTopic(ChannelEnum.UPDATED.name()));
//向监听器容器中添加一个监听器，该监听器的主题为DELETED
listenerContainer.addMessageListener(new MessageListener() {
@Override
public void onMessage(Message message, byte[] pattern) {
System.out.println("*************DELETED*************");
System.out.println(new String(message.getBody()));
System.out.println(new String(pattern));
List<String[]> strings = JSONArray.parseArray(new String(message.getBody()), String[].class);
String[] bookIds = strings.get(0);
String userId = strings.get(1)[0];
carService.delCar(bookIds,userId);
System.out.println("----------------------");
System.out.println(Arrays.toString(bookIds));
System.out.println(userId);
System.out.println("--------delete--------");
System.out.println("*************DELETED*************");
}
}, new ChannelTopic(ChannelEnum.DELETED.name()));
return listenerContainer;
}
}下面代码中的 stringRedisTemplate.convertAndSend();就是发送消息的，其中参数1是发送消息的名称，参数2是发送消息的内容
@Service("carService")
@Slf4j
public class CarServiceImpl extends ServiceImpl<CarMapper, Car> implements CarService {
//购物车hash的Key
public static final String CAR_KEY = "carKey";
//hash购物车中field的前缀
public static final String USER_CAR_HASH_FIELD_PREFIX = "car::";
@Resource
private StringRedisTemplate stringRedisTemplate;
/**
* 这里存储的时候采用Redis当中的hash存储
*
* @param car
*/
@Override
@Synchronized
public void addCar(Car car) {
//这里存储的时候采用Redis当中的hash存储
HashOperations<String, String, String> opsForHash = stringRedisTemplate.opsForHash();
//这里field为CAR_HASH_FIELD
String userCarKey = USER_CAR_HASH_FIELD_PREFIX + car.getUserId();
//Map<String,Car> 键(存储bookId) 值存储购物车某一个商品的信息
Map<String, Car> CarMap = null;
boolean flag = true;
//获得Redis中以存储的当前用户的购物车信息
if (opsForHash.hasKey(CAR_KEY, userCarKey)) {
//存在当前用户的购物车信息，那么获取原有的数据
String carMapJson = opsForHash.get(CAR_KEY, userCarKey);
CarMap = JSONObject.parseObject(carMapJson, new TypeReference<Map<String, Car>>() {
});
//检测当前购物车信息中是否包含新添加上的商品，如果包含则更新数量，如果不包含才新增
if (CarMap.containsKey(car.getBookId())) {
//获取原先商品的数量
Integer BeforeNumber = CarMap.get(car.getBookId()).getNumber();
log.info("BeforeNumber==============>{}", BeforeNumber);
Integer nowNumber = car.getNumber(); //前端传过来现在的
log.info("nowNumber==============>{}", nowNumber);
CarMap.get(car.getBookId()).setNumber(BeforeNumber + nowNumber);
flag = false; //存在商品
//修改
//包含才新增 图书的数量 在原有的基础上新增图书的数量
} else {
//新增
//如果不包含当前商品信息 那么直接将商品添加到购物车信息当中
CarMap.put(car.getBookId(), car);
}
} else {
/* 新增
*
* 当前的用户的购物车信息不存在
* 首先把其添加的商品首先存储到CarMap中
* */
CarMap = new HashMap<>();
CarMap.put(car.getBookId(), car);
}
//最后将其存入redis当中
opsForHash.put(CAR_KEY, userCarKey, JSONObject.toJSONString(CarMap));
if (flag){
//新增
stringRedisTemplate.convertAndSend(ChannelEnum.INSERTED.name(), JSONObject.toJSONString(CarMap.get(car.getBookId())));
}else {
//修改
stringRedisTemplate.convertAndSend(ChannelEnum.UPDATED.name(), JSONObject.toJSONString(CarMap.get(car.getBookId())));
}
}
@Override
public Collection<Car> getCarList(String userId) {
//这里存储的时候采用Redis当中的hash存储
HashOperations<String, String, String> opsForHash = stringRedisTemplate.opsForHash();
String userCarKey = USER_CAR_HASH_FIELD_PREFIX + userId;
String jsonStr = opsForHash.get(CAR_KEY, userCarKey);
Map<String,Car> CarMap = JSONObject.parseObject(jsonStr, Map.class);
return CarMap.values();
}
@Override
public void updataCount(String bookId, int number, String userId) {
//这里存储的时候采用Redis当中的hash存储
HashOperations<String, String, String> opsForHash = stringRedisTemplate.opsForHash();
String userCarKey = USER_CAR_HASH_FIELD_PREFIX + userId;
String jsonStr = opsForHash.get(CAR_KEY, userCarKey);
Map<String,Car> CarMap = JSONObject.parseObject(jsonStr, new TypeReference<Map<String, Car>>() {
});
if (!CarMap.containsKey(bookId)){ //不包含
return;
}
Car car = CarMap.get(bookId);
car.setNumber(number);
//最后将其存入redis当中
opsForHash.put(CAR_KEY, userCarKey, JSONObject.toJSONString(CarMap));
stringRedisTemplate.convertAndSend(ChannelEnum.UPDATED.name(), JSONObject.toJSONString(CarMap.get(car.getBookId())));
}
@Override
public void delCar(String[] bookIds, String userId) {
//获得操作RedisHash的对象
HashOperations<String, String, String> forHash = stringRedisTemplate.opsForHash();
String userCarKey = USER_CAR_HASH_FIELD_PREFIX+userId;
List<String[]> list = new ArrayList<>();
//从redis中获取用户对应的购物车数据
String carJsonStr = forHash.get(CAR_KEY, userCarKey);
//修改指定商品的数量
Map<String,Car> carMap = JSONObject.parseObject(carJsonStr, new TypeReference<Map<String,Car>>() {
});
for(String bookId : bookIds){
carMap.remove(bookId);
}
//将修改后的数据重新添加到redis中
forHash.put(CAR_KEY,userCarKey,JSONObject.toJSONString(carMap));
list.add(bookIds);
list.add(new String[]{userId});
stringRedisTemplate.convertAndSend(ChannelEnum.DELETED.name(), JSONObject.toJSONString(list));
}
}上述的两段代码中
第二段代码中stringRedisTemplate.convertAndSend();就是发送消息的，其中参数1是发送消息的名称，参数2是发送消息的内容
第一段代码中的这个就是监听到后接收到的消息，其中参数1{当中的onMessage方法的参数1Message为发送消息的内容，参数2pattern是发送消息的名称} 参数2为监听指定的消息名称（这个要和stringRedisTemplate.convertAndSend()中参数1的要保持一致）
listenerContainer.addMessageListener(new MessageListener() {
@Override
public void onMessage(Message message, byte[] pattern) {
}
}, new ChannelTopic(ChannelEnum.INSERTED.name()));以上就是使用Java代码实现Redis和数据库数据同步的详细内容，更多关于Java Redis和数据库同步的资料请关注脚本之家其它相关文章！
相关文章
这篇文章主要介绍了SpringBoot中的统一异常处理详细解析,该注解可以把异常处理器应用到所有控制器,而不是单个控制器,借助该注解,我们可以实现:在独立的某个地方,比如单独一个类,定义一套对各种异常的处理机制,需要的朋友可以参考下2024-01-01
本文主要介绍了Gradle 创建Task的多种方法，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-11-11
这篇文章主要介绍了Java 类的加载、连接和初始化的的相关资料，文中示例代码非常详细，帮助大家更好的理解和学习，感兴趣的朋友可以了解下2020-06-06
Springsecurity Oauth2如何设置token的过期时间
如果用户在指定的时间内有操作就给token延长有限期，否则到期后自动过期，如何设置token的过期时间，本文就来详细的介绍一下2021-08-08
这篇文章主要介绍了Java使用iTextPDF生成PDF文件的实现方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-02-02
Spring Data JPA开启批量更新时乐观锁失效问题的解决方法
乐观锁的基本思想是,认为在大多数情况下,数据访问不会导致冲突,因此,乐观锁允许多个事务同时读取和修改相同的数据,而不进行显式的锁定,本文给大家介绍了Spring Data JPA开启批量更新时乐观锁失效问题的解决方法,需要的朋友可以参考下2024-07-07
这篇文章主要介绍了Spring中的集合注入代码实例,集合注入是指在Spring框架中,通过配置文件或注解的方式将集合类型的数据注入到Bean中,集合类型包括List、Set、Map和Properties等,需要的朋友可以参考下2023-11-11
本文给大家分享一道史上最难的一道Java面试题，非常不错，具有参考借鉴价值，需要的朋友参考下吧2018-03-03
本文主要介绍了java终止线程的4种方式小结,包含布尔标志位,interrupt()方法,stop()方法和Thread.interrupt()方法,具有一定的参考价值,感兴趣的可以了解一下2024-05-05
这篇文章主要介绍了完美解决java double数相加和相减的方案，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-01-01
最新评论