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

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

王林
王林앞으로
2023-05-30 14:40:141649검색

사용 시나리오

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","订单支付超时&#xff0c;自动取消订单", "orderPaymentTimeout"),
    	ORDER_TIMEOUT_NOT_EVALUATED("ORDER_TIMEOUT_NOT_EVALUATED", "订单超时未评价&#xff0c;系统默认好评", "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 클라이언트를 통해 두 개의 지연 대기열이 성공적으로 추가된 것을 확인할 수 있습니다

SpringBoot가 Redisson을 통합하여 지연 대기열을 구현하는 방법IDEA 콘솔 로그를 보면 지연 대기열이 성공적으로 소모되었습니다

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

성명:
이 기사는 yisu.com에서 복제됩니다. 침해가 있는 경우 admin@php.cn으로 문의하시기 바랍니다. 삭제