SpringBoot가 Redisson을 통합하여 지연 대기열을 구현하는 방법

사용 시나리오

1. 주문이 성공적으로 이루어졌고 30분 이내에 결제가 이루어지지 않았습니다. 결제 시간 초과，주문이 자동으로 취소됩니다

2. 주문 서명，서명 후 7일 이내에는 평가가 수행되지 않습니다. 주문 시간이 초과되어 평가되지 않음

3. 주문이 성공적으로 완료되었습니다. 판매자가 5분 동안 주문을 수락하지 않았습니다. 주문이 취소되었습니다

4. SMS 알림

… ...

지연이 길고 실시간 성능이 낮은 시나리오의 경우 작업 예약을 사용하여 정기적으로 폴링을 처리할 수 있습니다. 예를 들어, xxl-job

오늘 우리는 처리를 위해 Redis의 지연 대기열을 사용하는 비교적 간단하고 가벼운 방법을 사용합니다. 물론 더 나은 솔루션도 있습니다. 회사의 기술 선택과 비즈니스 시스템을 기반으로 최적의 솔루션을 선택할 수 있습니다. 예를 들어 메시지 미들웨어 Kafka와 RabbitMQ의 지연 대기열을 사용하는 경우

지금은 구현 원리에 대해 논의하지 않겠습니다. Redis 기반 지연 대기열을 구현하는 실제 코드로 직접 가보겠습니다

1. Redisson 종속성을 소개합니다

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.10.5</version>
</dependency>

. 2. Nacos 구성 Redis 연결

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    password: 123456
    database: 12
    timeout: 3000

3. Redis 지연 대기열 도구 클래스 캡슐화

/**
 * Created by LPB on 2020/04/20.
 */
@Configuration
public class RedissonConfig {

	@Value("${spring.redis.host}")
	private String host;
	@Value("${spring.redis.port}")
	private int port;
	@Value("${spring.redis.database}")
	private int database;
	@Value("${spring.redis.password}")
	private String password;

	@Bean
	public RedissonClient redissonClient() {
		Config config = new Config();
		config.useSingleServer()
			.setAddress("redis://" + host + ":" + port)
			.setDatabase(database)
			.setPassword(password);
		return Redisson.create(config);
	}

}

5. 지연 대기열 실행기 정의

/**
 * redis延迟队列工具
 * Created by LPB on 2021/04/20.
 */
@Slf4j
@Component
public class RedisDelayQueueUtil {

    @Autowired
	private RedissonClient redissonClient;

    /**
     * 添加延迟队列
     * @param value 队列值
     * @param delay 延迟时间
     * @param timeUnit 时间单位
     * @param queueCode 队列键
     * @param <T>
     */
    public <T> void addDelayQueue(T value, long delay, TimeUnit timeUnit, String queueCode){
        try {
            RBlockingDeque<Object> blockingDeque = redissonClient.getBlockingDeque(queueCode);
            RDelayedQueue<Object> delayedQueue = redissonClient.getDelayedQueue(blockingDeque);
            delayedQueue.offer(value, delay, timeUnit);
			log.info("(添加延时队列成功) 队列键&#xff1a;{}&#xff0c;队列值&#xff1a;{}&#xff0c;延迟时间&#xff1a;{}", queueCode, value, timeUnit.toSeconds(delay) + "秒");
        } catch (Exception e) {
            log.error("(添加延时队列失败) {}", e.getMessage());
            throw new RuntimeException("(添加延时队列失败)");
        }
    }

	/**
	 * 获取延迟队列
	 * @param queueCode
	 * @param <T>
	 * @return
	 * @throws InterruptedException
	 */
    public <T> T getDelayQueue(String queueCode) throws InterruptedException {
        RBlockingDeque<Map> blockingDeque = redissonClient.getBlockingDeque(queueCode);
        T value  = (T) blockingDeque.take();
        return value;
	}
}

7. 지연 대기열 실행기

OrderPaymentTimeout： 주문 결제 시간 초과 지연 대기열 처리 클래스

• /**
   * 延迟队列业务枚举
   * Created by LPB on 2021/04/20.
   */
  @Getter
  @NoArgsConstructor
  @AllArgsConstructor
  public enum RedisDelayQueueEnum {
  
  	ORDER_PAYMENT_TIMEOUT("ORDER_PAYMENT_TIMEOUT","订单支付超时，自动取消订单", "orderPaymentTimeout"),
  	ORDER_TIMEOUT_NOT_EVALUATED("ORDER_TIMEOUT_NOT_EVALUATED", "订单超时未评价，系统默认好评", "orderTimeoutNotEvaluated");
  
  	/**
  	 * 延迟队列 Redis Key
  	 */
  	private String code;
  
  	/**
  	 * 中文描述
  	 */
  	private String name;
  
  	/**
  	 * 延迟队列具体业务实现的 Bean
  	 * 可通过 Spring 的上下文获取
  	 */
  	private String beanId;
  
  }

DelayQueueProcessorForUnevaluatedOrders에 정의된 Bean을 열거하고 구현합니다. 평가되지 않은 주문을 처리하기 위한 지연 대기열 처리 클래스를 사용합니다. 시간 초과 및 평가 없음

• /**
   * 延迟队列执行器
   * Created by LPB on 2021/04/20.
   */
  public interface RedisDelayQueueHandle<T> {
  
  	void execute(T t);
  
  }

  8. 지연 대기열 소비 스레드 생성，프로젝트 시작 후 열기

  /**
   * 订单支付超时处理类
   * Created by LPB on 2021/04/20.
   */
  @Component
  @Slf4j
  public class OrderPaymentTimeout implements RedisDelayQueueHandle<Map> {
  	@Override
  	public void execute(Map map) {
  		log.info("(收到订单支付超时延迟消息) {}", map);
  		// TODO 订单支付超时&#xff0c;自动取消订单处理业务...
  
  	}
  }

위 단계，Redis 지연 대기열 핵심 코드 완료，다음 테스트 인터페이스를 작성하고

9. 테스트 인터페이스를 생성하고

/**
 * 订单超时未评价处理类
 * Created by LPB on 2021/04/20.
 */
@Component
@Slf4j
public class OrderTimeoutNotEvaluated implements RedisDelayQueueHandle<Map> {
	@Override
	public void execute(Map map) {
		log.info("(收到订单超时未评价延迟消息) {}", map);
		// TODO 订单超时未评价&#xff0c;系统默认好评处理业务...

	}
}

10. PostMan을 사용하여 호출하세요. 지연 대기열을 추가하는 인터페이스

Redis 클라이언트를 통해 두 개의 지연 대기열이 성공적으로 추가된 것을 확인할 수 있습니다

IDEA 콘솔 로그를 보면 지연 대기열이 성공적으로 소모되었습니다

위 내용은 SpringBoot가 Redisson을 통합하여 지연 대기열을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!