✨ feat(api): implement redisson lock for item creation to prevent duplication item registration

backend/streetdrop-api/build.gradle

@@ -39,6 +39,8 @@ dependencies {
 
     implementation 'org.springframework.boot:spring-boot-starter-webflux'
     implementation 'io.awspring.cloud:spring-cloud-starter-aws:2.4.4'
+    // redisson
+    implementation group: 'org.redisson', name: 'redisson-spring-boot-starter', version: '3.34.1'
 }
 
 

backend/streetdrop-api/src/main/java/com/depromeet/domains/item/error/ItemErrorCode.java

@@ -11,7 +11,9 @@
 public enum ItemErrorCode implements ErrorCodeInterface {
     ITEM_NOT_FOUND(HttpStatus.NOT_FOUND, "ITEM_NOT_FOUND", "Item Not Found", "Item Not Found"),
     ITEM_ALREADY_LIKED(HttpStatus.CONFLICT, "ITEM_ALREADY_LIKED", "Item Already Liked", "User already item liked"),
-    ITEM_ALREADY_REPORTED(HttpStatus.CONFLICT, " ITEM_ALREADY_REPORTED", "Item Already Reported", "User already item reported");
+    ITEM_ALREADY_REPORTED(HttpStatus.CONFLICT, " ITEM_ALREADY_REPORTED", "Item Already Reported", "User already item reported"),
+    ITEM_CREATE_PROCESSING(HttpStatus.PROCESSING, "ITEM_CREATED_PROCESSING", "Item Created Processing", "Another request is currently being processed. Please try again later"),
+    ITEM_CREATE_FAIL(HttpStatus.INTERNAL_SERVER_ERROR, "ITEM_CREATED_FAIL", "Item Created Fail", "Item Created Fail");
 
     private final HttpStatus status;
     private final String errorResponseCode;

backend/streetdrop-api/src/main/java/com/depromeet/domains/item/service/ItemService.java

@@ -21,15 +21,19 @@
 import com.depromeet.util.GeomUtil;
 import lombok.RequiredArgsConstructor;
 import org.locationtech.jts.geom.Point;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 @Service
 @RequiredArgsConstructor
 public class ItemService {
+	private final RedissonClient redissonClient;
 	private final MusicService musicService;
 	private final ItemRepository itemRepository;
 	private final ItemLocationRepository itemLocationRepository;
@@ -53,30 +57,45 @@ public PoiResponseDto findNearItemsPoints(User user, NearItemPointRequestDto nea
 
 	@Transactional
 	public ItemResponseDto create(User user, ItemCreateRequestDto itemCreateRequestDto) {
-		var song = musicService.getOrCreateMusic(itemCreateRequestDto.getMusic());
-
-		var item = Item.builder()
-				.user(user)
-				.albumCover(song.getAlbum().getAlbumCover())
-				.song(song)
-				.content(itemCreateRequestDto.getContent())
-				.build();
-
-		ItemLocationRequestDto locationRequestDto = itemCreateRequestDto.getLocation();
-		Point point = GeomUtil.createPoint(locationRequestDto.getLongitude(), locationRequestDto.getLatitude());
+		String lockKey = "item:create" + user.getId();
+		RLock lock = redissonClient.getLock(lockKey);
+
+		try {
+			boolean creatable = lock.tryLock(5, 5, TimeUnit.SECONDS);
+			if (!creatable) {
+				throw new BusinessException(ItemErrorCode.ITEM_CREATE_PROCESSING);
+			}
+
+			var song = musicService.getOrCreateMusic(itemCreateRequestDto.getMusic());
+
+			var item = Item.builder()
+					.user(user)
+					.albumCover(song.getAlbum().getAlbumCover())
+					.song(song)
+					.content(itemCreateRequestDto.getContent())
+					.build();
+
+			ItemLocationRequestDto locationRequestDto = itemCreateRequestDto.getLocation();
+			Point point = GeomUtil.createPoint(locationRequestDto.getLongitude(), locationRequestDto.getLatitude());
 		VillageArea villageArea = villageAreaService.getVillageByLocationPoint(point);
 
-		ItemLocation itemLocation = ItemLocation.builder()
-				.name(locationRequestDto.getAddress())
-				.item(item)
+			ItemLocation itemLocation = ItemLocation.builder()
+					.name(locationRequestDto.getAddress())
+					.item(item)
 				.villageArea(villageArea)
-				.point(point)
-				.build();
-
-		item.setItemLocation(itemLocation);
-		var savedItem = itemRepository.save(item);
-
-		return new ItemResponseDto(savedItem);
+					.point(point)
+					.build();
+
+			item.setItemLocation(itemLocation);
+			var savedItem = itemRepository.save(item);
+
+			return new ItemResponseDto(savedItem);
+		} catch (InterruptedException e) {
+			Thread.currentThread().interrupt();
+			throw new BusinessException(ItemErrorCode.ITEM_CREATE_FAIL);
+		} finally {
+			lock.unlock();
+		}
 	}
 
 

backend/streetdrop-api/src/main/java/com/depromeet/external/redisson/RedissonConfig.java

@@ -0,0 +1,20 @@
+package com.depromeet.external.redisson;
+
+import org.redisson.Redisson;
+import org.redisson.api.RedissonClient;
+import org.redisson.config.Config;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RedissonConfig {
+
+    @Bean
+    public RedissonClient redissonClient() {
+        Config config = new Config();
+        config.useSingleServer()
+                .setAddress("redis://localhost:6379");
+
+        return Redisson.create(config);
+    }
+}