Scénarios d'utilisation

1. La commande a été passée avec succès et aucun paiement n'a été effectué dans les 30 minutes. Délai de paiement & #xff0c; La commande sera automatiquement annulée

2. Signature de la commande & #xff0c; Aucune évaluation ne sera effectuée dans les 7 jours suivant la signature. Commande expirée et non évaluée?; Le système affiche par défaut des avis positifs?

3. Commande passée avec succès?; Le commer?ant n'a pas accepté la commande pendant 5?minutes?， Commande annulée?

4. La livraison a expiré?，Push. Rappel SMS

… …

Pour les scénarios avec de longs délais et de faibles performances en temps réel, nous pouvons utiliser la planification des taches pour traiter les interrogations à intervalles réguliers. Par exemple, xxl-job

Aujourd'hui, nous utilisons une méthode relativement simple et légère : utiliser la file d'attente différée de Redis pour le traitement. Bien s?r, il existe de meilleures solutions : vous pouvez choisir la solution optimale en fonction de la sélection technologique et du système commercial de l'entreprise. Par exemple, en utilisant le middleware de messages Kafka et la file d'attente de retard de RabbitMQ

Je ne discuterai pas de son principe d'implémentation pour l'instant. Passons directement au code réel pour implémenter la file d'attente de retard basée sur Redis

1. Introduisons la dépendance Redisson

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

. 2. Configuration de Nacos Connexion Redis

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

3. Créer une configuration RedissonConfig

/**
 * 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);
	}

}

4. Encapsuler la classe d'outil de file d'attente de retard

/**
 * redis延遲隊(duì)列工具
 * Created by LPB on 2021/04/20.
 */
@Slf4j
@Component
public class RedisDelayQueueUtil {

    @Autowired
	private RedissonClient redissonClient;

    /**
     * 添加延遲隊(duì)列
     * @param value 隊(duì)列值
     * @param delay 延遲時(shí)間
     * @param timeUnit 時(shí)間單位
     * @param queueCode 隊(duì)列鍵
     * @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("(添加延時(shí)隊(duì)列成功) 隊(duì)列鍵&#xff1a;{}&#xff0c;隊(duì)列值&#xff1a;{}&#xff0c;延遲時(shí)間&#xff1a;{}", queueCode, value, timeUnit.toSeconds(delay) + "秒");
        } catch (Exception e) {
            log.error("(添加延時(shí)隊(duì)列失敗) {}", e.getMessage());
            throw new RuntimeException("(添加延時(shí)隊(duì)列失敗)");
        }
    }

	/**
	 * 獲取延遲隊(duì)列
	 * @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;
	}
}

5. Créer une énumération d'entreprise de file d'attente de retard

/**
 * 延遲隊(duì)列業(yè)務(wù)枚舉
 * Created by LPB on 2021/04/20.
 */
@Getter
@NoArgsConstructor
@AllArgsConstructor
public enum RedisDelayQueueEnum {

	ORDER_PAYMENT_TIMEOUT("ORDER_PAYMENT_TIMEOUT","訂單支付超時(shí)，自動(dòng)取消訂單", "orderPaymentTimeout"),
	ORDER_TIMEOUT_NOT_EVALUATED("ORDER_TIMEOUT_NOT_EVALUATED", "訂單超時(shí)未評(píng)價(jià)，系統(tǒng)默認(rèn)好評(píng)", "orderTimeoutNotEvaluated");

	/**
	 * 延遲隊(duì)列 Redis Key
	 */
	private String code;

	/**
	 * 中文描述
	 */
	private String name;

	/**
	 * 延遲隊(duì)列具體業(yè)務(wù)實(shí)現(xiàn)的 Bean
	 * 可通過 Spring 的上下文獲取
	 */
	private String beanId;

}

6. énumérez les beans définis et implémentez l'exécuteur de file d'attente de retard

OrderPaymentTimeout： classe de traitement de file d'attente de retard de paiement de commande

• /**
   * 延遲隊(duì)列執(zhí)行器
   * Created by LPB on 2021/04/20.
   */
  public interface RedisDelayQueueHandle<T> {
  
  	void execute(T t);
  
  }

DelayQueueProcessorForUnevaluatedOrders?: classe de traitement de file d'attente de retard pour le traitement des commandes non évaluées, à utiliser dans le cas d'une commande délai d'attente et aucune évaluation

• /**
   * 訂單支付超時(shí)處理類
   * Created by LPB on 2021/04/20.
   */
  @Component
  @Slf4j
  public class OrderPaymentTimeout implements RedisDelayQueueHandle<Map> {
  	@Override
  	public void execute(Map map) {
  		log.info("(收到訂單支付超時(shí)延遲消息) {}", map);
  		// TODO 訂單支付超時(shí)&#xff0c;自動(dòng)取消訂單處理業(yè)務(wù)...
  
  	}
  }

8. Créez un thread de consommation de file d'attente de retard，Ouvrez-le après le démarrage du projet

/**
 * 訂單超時(shí)未評(píng)價(jià)處理類
 * Created by LPB on 2021/04/20.
 */
@Component
@Slf4j
public class OrderTimeoutNotEvaluated implements RedisDelayQueueHandle<Map> {
	@Override
	public void execute(Map map) {
		log.info("(收到訂單超時(shí)未評(píng)價(jià)延遲消息) {}", map);
		// TODO 訂單超時(shí)未評(píng)價(jià)&#xff0c;系統(tǒng)默認(rèn)好評(píng)處理業(yè)務(wù)...

	}
}

9. Créez une interface de test ， simulez l'ajout d'une file d'attente de retard

/**
 * 啟動(dòng)延遲隊(duì)列
 * Created by LPB on 2021/04/20.
 */
@Slf4j
@Component
public class RedisDelayQueueRunner implements CommandLineRunner {

	@Autowired
	private RedisDelayQueueUtil redisDelayQueueUtil;

	@Override
	public void run(String... args) {
		new Thread(() -> {
			while (true){
				try {
					RedisDelayQueueEnum[] queueEnums = RedisDelayQueueEnum.values();
					for (RedisDelayQueueEnum queueEnum : queueEnums) {
						Object value = redisDelayQueueUtil.getDelayQueue(queueEnum.getCode());
						if (value != null) {
							RedisDelayQueueHandle redisDelayQueueHandle = SpringUtil.getBean(queueEnum.getBeanId());
							redisDelayQueueHandle.execute(value);
						}
					}
				} catch (InterruptedException e) {
					log.error("(Redis延遲隊(duì)列異常中斷) {}", e.getMessage());
				}
			}
		}).start();
		log.info("(Redis延遲隊(duì)列啟動(dòng)成功)");
	}
}

10. appelez l'interface pour ajouter une file d'attente de retard

Grace au client Redis, vous pouvez voir que les deux files d'attente de retard ont été ajoutées avec succès

Affichez le journal de la console IDEA et vous pouvez voir que le retard la file d'attente a été consommée avec succès

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!