Troubleshooting:Lock Time Out - takeoff-26/logistics-service GitHub Wiki

@Lock(LockModeType.PESSIMISTIC_WRITE)
	@QueryHints({
		@QueryHint(name = "jakarta.persistence.lock.timeout", value = "1000"),
		@QueryHint(name = "org.hibernate.dialect.lock.timeout", value = "1000")
	})
	@Query("SELECT s FROM Stock s WHERE s.id = :id AND s.deletedAt is null")
	Optional<Stock> findByIdWithLock(@Param("id") StockId id);
	@Override
	@Transactional
	public void prepareStock(PrepareStockRequestDto requestDto) {
		try {
			getSortedStocks(requestDto.stocks())
				.forEach(stockItem ->
					getStockWithLock(stockItem.stockId()).decreaseStock(stockItem.quantity()));
			sleep(3000);
		} catch (InterruptedException e) {
			throw new RuntimeException(e);
		}
	}

@Inherited
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface LockTimeout {
	int timeout() default 3000;
}

public interface LockManager {

	void setLockTimeout(int timeout);
}

h2 구현체
@Slf4j
@Profile("Test")
@Component
@RequiredArgsConstructor
public class H2LockManager implements LockManager {

	@Override
	public void setLockTimeout(int timeout) {
		log.info("테스트 환경에서는 락 타임아웃 설정이 무시됩니다: {}ms", timeout);
	}
}
postgres 구현체
@Profile("!Test")
@Component
@RequiredArgsConstructor
public class PostgresLockManager implements LockManager {

	private final EntityManager em;

	public void setLockTimeout(int timeout) {
		Query query = em.createNativeQuery("SET LOCAL lock_timeout = '" + timeout + "ms'");
		query.executeUpdate();
	}

}

@Aspect 
@Component
@RequiredArgsConstructor
public class LockTimeoutAspect {

	private final LockManager lockManager;

	@Before("@annotation(takeoff.logistics_service.msa.product.stock.infrastructure.persistence"
		+ ".aspect.LockTimeout)")
	public void beforeLockTimeout(JoinPoint joinPoint) {
		MethodSignature signature = (MethodSignature) joinPoint.getSignature();
		LockTimeout annotation = signature.getMethod().getAnnotation(LockTimeout.class);
		lockManager.setLockTimeout(annotation.timeout());
	}
}

	@LockTimeout(timeout = 1000)
	@Lock(LockModeType.PESSIMISTIC_WRITE)
	@Query("SELECT s FROM Stock s WHERE s.id = :id AND s.deletedAt is null")
	Optional<Stock> findByIdWithLock(@Param("id") StockId id);