浅谈Redis中的自动过期机制

CREATE TABLE `order_number` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`order_name` varchar(255) DEFAULT NULL,
`order_status` int(11) DEFAULT NULL,
`order_token` varchar(255) DEFAULT NULL,
`order_id` varchar(255) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=20 DEFAULT CHARSET=utf8;

vi redis.conf

/notify-keyspace-events

@Configuration
public class RedisListenerConfig {
@Bean
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
return container;
}
}

@Component
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
super(listenerContainer);
}

@Resource
private OrderMapper orderMapper;

/**
* 待支付
*/
private static final Integer ORDER_STAYPAY = 0;

/**
* 失效
*/
private static final Integer ORDER_INVALID = 2;

/**
* 使用该方法监听 当我们的key失效的时候执行该方法
*
* @param message
* @param pattern
*/
@Override
public void onMessage(Message message, byte[] pattern) {
String expiraKey = message.toString();
System.out.println(“该key：expiraKey：” + expiraKey + “失效啦~”);
// 前缀判断 orderToken
OrderEntity orderNumber = orderMapper.getOrderNumber(expiraKey);
if (orderNumber == null) {
return;
}
// 获取订单状态
Integer orderStatus = orderNumber.getOrderStatus();
// 如果该订单状态为待支付的情况下，直接将该订单修改为已经超时
if (orderStatus.equals(ORDER_STAYPAY)) {
orderMapper.updateOrderStatus(expiraKey, ORDER_INVALID);
// 库存加上1
}
}
}

@RestController
public class MemberController {
@Autowired
private UserMapper userMapper;

/**
*
* @return
*/
@RequestMapping(“/getListMember”)
@Cacheable(cacheNames = “member”, key = “‘getListMember'”)
public List<MemberEntity> getListMember() {
return userMapper.findMemberAll();
}
}

@Data
public class OrderEntity {
private Long id;
private String orderName;
/**
* 0 待支付 1 已经支付
*/
private Integer orderStatus;

private String orderToken;
private String orderId;

public OrderEntity(Long id, String orderName, String orderId, String orderToken) {
this.id = id;
this.orderName = orderName;
this.orderId = orderId;
this.orderToken = orderToken;
}
}

public interface OrderMapper {

@Insert(“insert into order_number values (null,#{orderName},0,#{orderToken},#{orderId})”)
int insertOrder(OrderEntity OrderEntity);

@Select(“SELECT ID AS ID ,order_name AS ORDERNAME ,order_status AS orderstatus,order_token as ordertoken,order_id as orderid FROM order_number\n” +
“where order_token=#{orderToken};”)
OrderEntity getOrderNumber(String orderToken);

@Update(“\n” +
“\n” +
“update order_number set order_status=#{orderStatus} where order_token=#{orderToken};”)
int updateOrderStatus(String orderToken, Integer orderStatus);
}