@Data
public class OrderProductEvent extends ApplicationEvent {
  /** 該類型事件攜帶的信息 */
  private String orderId;
  public OrderProductEvent(Object source, String orderId) {
    super(source);
    this.orderId = orderId;
  }
}

/**
 * 實現(xiàn) ApplicationListener 接口，并指定監(jiān)聽的事件類型
 */
@Slf4j
@Component
public class OrderProductListener implements ApplicationListener<OrderProductEvent> {
  /**
   *  使用 onApplicationEvent 方法對消息進行接收處理
   *  
   * */
  @SneakyThrows
  @Override
  public void onApplicationEvent(OrderProductEvent event) {
    String orderId = event.getOrderId();
    long start = System.currentTimeMillis();
    Thread.sleep(2000);
    long end = System.currentTimeMillis();
    log.info("{}：校驗訂單商品價格耗時：({})毫秒", orderId, (end - start));
  }
}

@Slf4j
@Service
@RequiredArgsConstructor
public class OrderService {
  /** 注入ApplicationContext用來發(fā)布事件 */
  private final ApplicationContext applicationContext;
  /**
   * 下單
   *
   * @param orderId 訂單ID
   */
  public String buyOrder(String orderId) {
    long start = System.currentTimeMillis();
    // 1.查詢訂單詳情
    // 2.檢驗訂單價格 （同步處理）
    applicationContext.publishEvent(new OrderProductEvent(this, orderId));
    long end = System.currentTimeMillis();
    log.info("任務(wù)全部完成，總耗時：({})毫秒", end - start);
    return "購買成功";
  }
}

@SpringBootTest
public class OrderServiceTest {
  @Autowired
  private OrderService orderService;
  @Test
  public void buyOrderTest() {
    orderService.buyOrder("732171109");
  }
}

import lombok.AllArgsConstructor;
import lombok.Data;
@Data
@AllArgsConstructor
public class MsgEvent {
  /** 該類型事件攜帶的信息 */
  public String orderId;
}

@Slf4j
@Component
public class MsgListener {
  @Async
  @SneakyThrows
  @EventListener(MsgEvent.class)
  public void sendMsg(MsgEvent event) {
    String orderId = event.getOrderId();
    long start = System.currentTimeMillis();
    log.info("開發(fā)發(fā)送短信");
    log.info("開發(fā)發(fā)送郵件");
    Thread.sleep(4000);
    long end = System.currentTimeMillis();
    log.info("{}：發(fā)送短信、郵件耗時：({})毫秒", orderId, (end - start));
  }
}

@Slf4j
@Service
@RequiredArgsConstructor
public class OrderService {
  /** 注入ApplicationContext用來發(fā)布事件 */
  private final ApplicationContext applicationContext;
  /**
   * 下單
   *
   * @param orderId 訂單ID
   */
  public String buyOrder(String orderId) {
    long start = System.currentTimeMillis();
    // 1.查詢訂單詳情
    // 2.檢驗訂單價格 （同步處理）
//    applicationContext.publishEvent(new OrderProductEvent(this, orderId));
    // 3.短信通知（異步處理） 新開線程執(zhí)行監(jiān)聽得業(yè)務(wù)
    applicationContext.publishEvent(new MsgEvent(orderId));
    long end = System.currentTimeMillis();
    log.info("任務(wù)全部完成，總耗時：({})毫秒", end - start);
    return "購買成功";
  }
}

@EnableAsync
@EnableRetry
@SpringBootApplication
public class LlpSpringRetryApplication {
    public static void main(String[] args) {
        SpringApplication.run(LlpSpringRetryApplication.class, args);
    }
}