데이터베이스 예약 폴링 방법, 구현 아이디어는 비교적 간단합니다. 예약된 작업을 시작하고, 특정 시간에 주문 테이블을 스캔하고, 쿼리한 후 타임아웃 주문을 취소합니다.
장점: 구현이 간단합니다.
단점: 폴링 간격을 결정하기가 어렵고, 서버 리소스를 차지하고 데이터베이스 성능에 영향을 미칩니다.
주문 정보 조회 시에는 주문 시간이 초과되었는지 먼저 확인하고, 시간이 초과되면 먼저 취소해 주세요.
장점: 구현이 간단합니다.
단점: 쿼리 이외의 비즈니스(예: 통계, 인벤토리)에 영향을 미치고 쿼리 효율성에 영향을 미칩니다.
JDK 지연 대기열 DelayQueue는 지연이 만료될 때만 요소를 얻을 수 있는 무제한 차단 대기열입니다.
간단한 구현 코드 데모는 다음과 같습니다. 실제 제작 과정에는 메시지 대기열 추가 및 소비를 담당하는 전용 스레드가 있습니다.
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;
/**
* @author 向振华
* @date 2022/08/16 15:55
*/
public class OrderDelayed implements Delayed {
/**
* 延迟时间
*/
private final Long time;
/**
* 订单编号
*/
public String orderNo;
public OrderDelayed(String orderNo, long time, TimeUnit unit) {
this.orderNo = orderNo;
this.time = System.currentTimeMillis() + (time > 0 ? unit.toMillis(time) : 0);
}
@Override
public long getDelay(TimeUnit unit) {
return time - System.currentTimeMillis();
}
@Override
public int compareTo(Delayed o) {
OrderDelayed orderDelayed = (OrderDelayed) o;
long diff = this.time - orderDelayed.time;
if (diff <= 0) {
return -1;
} else {
return 1;
}
}
}import java.util.concurrent.DelayQueue;
import java.util.concurrent.TimeUnit;
/**
* @author 向振华
* @date 2022/08/16 16:02
*/
public class Test {
public static void main(String[] args) {
DelayQueue<OrderDelayed> delayQueue = new DelayQueue<>();
delayQueue.put(new OrderDelayed("220101001", 8, TimeUnit.SECONDS));
delayQueue.put(new OrderDelayed("220101002", 4, TimeUnit.SECONDS));
System.out.println("订单延迟队列开始执行");
while (true) {
// 取队列头部元素是否过期
OrderDelayed task = delayQueue.poll();
if (task != null) {
// 取消订单业务逻辑
System.out.println("订单 ---> " + task.orderNo + " 已过期准备取消");
}
}
}
}장점: 높은 효율성, 낮은 작업 트리거 시간 지연.
단점: 예외 복구의 어려움, 번거로운 클러스터 확장, 메모리 사용량.
시간 휠 알고리즘은 시계와 유사하며 고정된 주파수로 특정 방향으로 회전합니다. Netty의 HashedWheelTimer를 사용하여 시간 휠 방법을 구현할 수 있습니다.
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.1.78.Final</version>
</dependency>import io.netty.util.HashedWheelTimer;
import io.netty.util.Timeout;
import io.netty.util.Timer;
import io.netty.util.TimerTask;
import java.util.concurrent.TimeUnit;
/**
* @author 向振华
* @date 2022/08/16 16:02
*/
public class Test {
public static void main(String[] args) {
// 初始化时间轮
Timer timer = new HashedWheelTimer();
// 定时任务
TimerTask task1 = new TimerTask() {
public void run(Timeout timeout) throws Exception {
// 取消订单业务逻辑
System.out.println("订单1已过期准备取消");
}
};
// 注册此定时任务（延迟时间为5秒，也就是说5秒后订单过期）
timer.newTimeout(task1, 5, TimeUnit.SECONDS);
// 定时任务
TimerTask task2 = new TimerTask() {
public void run(Timeout timeout) throws Exception {
// 取消订单业务逻辑
System.out.println("订单2已过期准备取消");
}
};
// 注册此定时任务（延迟时间为3秒，也就是说3秒后订单过期）
timer.newTimeout(task2, 3, TimeUnit.SECONDS);
}
}장점: 효율성이 높고 작업 트리거 시간 지연이 낮습니다.
단점: 예외 복구의 어려움, 번거로운 클러스터 확장, 메모리 사용량.
Redis의 키 만료 콜백 이벤트는 대기열을 지연시키는 효과도 얻을 수 있습니다.
redis.conf에 구성 추가:
notify-keyspace-events Ex
Listening 구성
@Configuration
public class RedisListenerConfig {
@Bean
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
return container;
}
}Redis 만료 콜백 수신 방법
@Component
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
super(listenerContainer);
}
@Override
public void onMessage(Message message, byte[] pattern) {
// 过期key，可以设置成订单号
String expiredKey = message.toString();
// 取消订单业务逻辑
System.out.println("订单 ---> " + expiredKey + " 已过期准备取消");
}
}장점: 데이터가 쉽게 손실되지 않으며 클러스터 확장이 쉽습니다.
단점: Redis의 추가 유지 관리가 필요합니다.
Redis의 데이터 구조 Zset은 주로 점수 속성을 사용하여 지연된 대기열 효과를 얻을 수도 있습니다. zadd 명령을 통해 대기열 지연 대기열에 요소를 추가하고 요소의 만료 시간을 나타내도록 점수 값을 설정합니다.
소비자는 대기열 지연 대기열을 폴링하고 요소를 정렬한 후 최소 시간을 현재 시간과 비교합니다. 현재 시간보다 작으면 키가 만료되어 제거되었음을 의미합니다.
public void pollOrderQueue() {
while (true) {
Set<Tuple> set = jedis.zrangeWithScores(delayqueue, 0, 0);
String value = ((Tuple) set.toArray()[0]).getElement();
int score = (int) ((Tuple) set.toArray()[0]).getScore();
int nowSecond = System.currentTimeMillis() / 1000);
if (nowSecond >= score) {
jedis.zrem(delayqueue, value);
System.out.println(sdf.format(new Date()) + " removed key:" + value);
}
if (jedis.zcard(delayqueue) <= 0) {
System.out.println(sdf.format(new Date()) + " zset empty ");
return;
}
Thread.sleep(1000);
}
}장점: 데이터가 쉽게 손실되지 않으며 클러스터 확장이 쉽습니다.
단점: 동일한 키가 반복적으로 소모될 수 있습니다.
작업 예약 미들웨어 xxl-job, ScheduleX, Elastic-Job 등을 사용하여 예약 시간 cron을 설정합니다. 주문 만료의 예약 시간에 도달하면 작업 실행이 취소됩니다. 주문 비즈니스 로직.
예를 들어 xxl-job 구현을 사용하면 주문이 생성되면 만료된 작업이 xxl-job 서버에 제출됩니다. 실행자 방법은 다음과 같습니다.
import com.xxl.job.core.handler.annotation.XxlJob;
import org.springframework.stereotype.Component;
/**
* @author 向振华
* @date 2022/08/16 15:55
*/
@Component
public class JobHandler {
@XxlJob("payExpireJobHandler")
public void payExpireJobHandler(String executorParam) {
// 取消订单业务逻辑
System.out.println("订单 ---> " + executorParam + " 已过期准备取消");
}
}장점: 강력한 적시성 및 배포 지원.
단점: 구현이 복잡하고 유지 관리 비용이 높습니다.
RocketMQ, RabbitMQ, Kafka의 지연된 메시지를 사용합니다. 메시지가 메시지 대기열 서버로 전송된 후 즉시 전달되지 않고 일정 시간 지연을 기준으로 소비자에게 전달됩니다. 메시지의 속성에 대해.
RocketMQ가 지연된 메시지를 보내는 샘플 코드는 다음과 같습니다.
import com.aliyun.openservices.ons.api.Message;
import com.aliyun.openservices.ons.api.ONSFactory;
import com.aliyun.openservices.ons.api.Producer;
import com.aliyun.openservices.ons.api.PropertyKeyConst;
import com.aliyun.openservices.ons.api.SendResult;
import java.util.Properties;
public class Test {
public static void main(String[] args) {
Properties properties = new Properties();
// AccessKey ID阿里云身份验证，在阿里云RAM控制台创建。
properties.put(PropertyKeyConst.AccessKey, "XXX");
// AccessKey Secret阿里云身份验证，在阿里云RAM控制台创建。
properties.put(PropertyKeyConst.SecretKey, "XXX");
// 设置TCP接入域名，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看。
properties.put(PropertyKeyConst.NAMESRV_ADDR,
"XXX");
Producer producer = ONSFactory.createProducer(properties);
// 在发送消息前，必须调用start方法来启动Producer，只需调用一次即可。
producer.start();
Message msg = new Message(
// 您在消息队列RocketMQ版控制台创建的Topic。
"Topic",
// Message Tag,可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在消息队列RocketMQ版服务器过滤。
"tag",
// Message Body可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。
"Hello MQ".getBytes());
// 设置代表消息的业务关键属性，请尽可能全局唯一。
// 以方便您在无法正常收到消息情况下，可通过控制台查询消息并补发。
// 注意：不设置也不会影响消息正常收发。
msg.setKey("ORDERID_100");
try {
// 延时消息，在指定延迟时间（当前时间之后）进行投递。最大可设置延迟40天投递，单位毫秒（ms）。
// 以下示例表示消息在3秒后投递。
long delayTime = System.currentTimeMillis() + 3000;
// 设置消息需要被投递的时间。
msg.setStartDeliverTime(delayTime);
SendResult sendResult = producer.send(msg);
// 同步发送消息，只要不抛异常就是成功。
if (sendResult != null) {
System.out.println(new Date() + " Send mq message success. Topic is:" + msg.getTopic() + " msgId is: " + sendResult.getMessageId());
}
} catch (Exception e) {
// 消息发送失败，需要进行重试处理，可重新发送这条消息或持久化这条数据进行补偿处理。
System.out.println(new Date() + " Send mq message failed. Topic is:" + msg.getTopic());
e.printStackTrace();
}
// 在应用退出前，销毁Producer对象。
// 注意：如果不销毁也没有问题。
producer.shutdown();
}
}RocketMQ 지연된 메시지 구독은 일반 메시지 구독과 동일합니다.
장점: 효율적이고 확장이 용이하며 배포를 지원합니다.
단점: 구현이 복잡하고 유지 관리 비용이 높습니다.
위 내용은 Java를 사용하여 미결제 주문을 자동으로 취소하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
