悲观锁不工作Spring引导数据JPA

Question

我使用的是Spring Boot 2和Spring数据JPA。

我有一个带有@Transactional annotation的服务，它从存储库中读取记录，如果记录不存在，则添加记录并保存所有记录。我创建了一个测试方法，并行执行服务方法5次。由于我使用的是@Lock（LockModeType.悲观写入），我希望其中一个线程在读取可用性时会得到锁，而其他4个线程必须等待事务（createReservation）完成，但相反，该方法运行了5次，并且没有返回任何记录，因此，所有线程都尝试插入一条新记录，但都失败了（第一条除外），导致唯一索引或主键冲突。对于测试，我使用H2数据库。

预订服务：

@Service
public class ReservationService {

  @Autowired
  private AvailabilityService availabilityService;
  @Autowired
  private ReservationRepository repository;

  @Transactional
  public Reservation createReservation(Reservation r) {
    availabilityService.updateAvailability( r);
    return reservationRepository.save( r);
  }
}

可用性服务：

@Service
public class DayAvailabilityService {

  @Autowired
  private AvailabilityRepository availabilityRepository;

  public List<Availability> updateAvailability(Reservation reservation) {
    List<LocalDate> dates = reservation.getStart().datesUntil(reservation.getEnd()).collect(Collectors.toList());
    List<Availability> availabilities = availabilityRepository.findAllById(dates);
    // check availability, add records to this list if a record does not exist
    /// ...
    return availabilityRepository.saveAll(availabilities);
  }

}

public interface AvailabilityRepository extends JpaRepository<Availability, LocalDate> {

@Override
@Lock(LockModeType.PESSIMISTIC_WRITE)
List<Availability> findAllById(Iterable<LocalDate> iterable);

}

可用性实体：

@Entity
@Table(name = "Availability")
public class Availability {

  @Column(name = "Date")
  @Id
  @NotNull
  private LocalDate date;
  @Column(name = "Availability")
  private int availability;
  @Column(name = "MaxAvailability")
  private int maxAvailability;
}

这是测试类：

@SpringBootTest
@RunWith(SpringRunner.class)
public class ReservationServiceIntegrationTest {

  @Autowired
  private ReservationService service;
  @Autowired
  private ReservationRepository repository;

  @Test
  public void testConcurrentCreateReservation() throws InterruptedException {
    Reservation reservation = new Reservation("John", "Doe", "[e-mail]",
            LocalDate.now().plusDays(4), LocalDate.now().plusDays(6), 30);
    runMultithreaded(() -> {
        try {
            service.createReservation(reservation);
        } catch (NoAvailabilityException e) {
            System.out.println("no availability.");
        }
    }, 5);

    long count = repository.count();
    assertEquals(3, count);

  }

  public static void runMultithreaded(Runnable  runnable, int threadCount) throws InterruptedException {
    List<Thread> threadList = new LinkedList<>();

    for(int i = 0 ; i < threadCount; i++) {
        threadList.add(new Thread(runnable));
    }

    for( Thread t :  threadList) {
        t.start();
    }

    for( Thread t :  threadList) {
        t.join();
    }
  }
}

在日志中，我看到为每个createReservation方法创建了一个事务。

Getting transaction for [com.company.app.service.ReservationService.createReservation]

然后我看到了5个类似这样的日志：

Getting transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.findAllById]

然后我看到select查询执行了5次，最后是“for update”。所以锁应该可以工作，但我没有看到我预期的结果。

我的代码有什么问题？

谢谢

Answer 1

我认为问题是您想在每个线程中插入具有相同ID的记录。

// check availability, add records to this list if a record does not exist

锁对新记录不起作用。你得设法把整张桌子都锁上。如果您完全确定服务器将只运行一个实例，则可以同步您的方法，或者您可以使用“锁定记录”创建一个特殊表，并在实际表中创建新记录之前使用锁读取该记录，然后释放该锁。

第一种方法非常简单，但第二种方法更容易防故障。