Merge pull request #7 from aws-cloud-clubs/test/6-load-testing

Load Testing 페이로드 spec에 맞게 수정

.gitignore

@@ -1 +1,2 @@
 **/.DS_Store
+.idea

chat/Dockerfile

@@ -0,0 +1,31 @@
+# SOURCE
+FROM alpine as source
+RUN ln -snf /usr/share/zoneinfo/Asia/Seoul /etc/localtime
+RUN echo Asia/Seoul > /etc/timezone
+
+WORKDIR /project
+COPY . .
+
+
+# BUILD (INCLUDE TEST)
+FROM azul/zulu-openjdk-alpine:17-latest AS build
+RUN ln -snf /usr/share/zoneinfo/Asia/Seoul /etc/localtime
+RUN echo Asia/Seoul > /etc/timezone
+
+WORKDIR /project
+COPY --from=source project .
+
+ENTRYPOINT ["./gradlew", "build"]
+
+
+# RUNNER
+FROM azul/zulu-openjdk-alpine:17-jre-latest AS runner
+RUN ln -snf /usr/share/zoneinfo/Asia/Seoul /etc/localtime
+RUN echo Asia/Seoul > /etc/timezone
+
+WORKDIR /project
+
+ARG JAR_FILE=project/build/libs/*.jar
+COPY ${JAR_FILE} app.jar
+
+ENTRYPOINT ["java", "-jar", "app.jar"]

performance_test/src/load/locustfile.py

@@ -1,4 +1,6 @@
 import time
+import json
+from datetime import datetime
 from locust import User, task, between
 
 from src.common.stomp import StompClient
@@ -25,7 +27,7 @@ def on_start(self):
         for i in range(self.vuser):
             self.__stomp_clients.append(StompClient(self.host, self.port, self.endpoint))
             self.__stomp_clients[i].connect()
-            self.__stomp_clients[i].subscribe(f"/topic/chat/{self.room_id}")
+            self.__stomp_clients[i].subscribe(f"/topic/chat/{self.room_id}", f"user{i}")
 
     def on_stop(self):
         for i in range(self.vuser):
@@ -35,7 +37,14 @@ def on_stop(self):
     def send_receive_hello(self):
         start_time = time.time()
 
-        self.__stomp_clients[0].send("/topic/chat", "Hello, world!")
+        payload = json.dumps({
+            "chatRoomId": self.room_id,
+            "type": "MESSAGE",
+            "createdBy": "user0",
+            "text": "Hello, world!",
+            "createdAt": datetime.now().strftime("%Y-%m-%dT%H:%M:%S")
+        })
+        self.__stomp_clients[0].send("/topic/chat", payload)
 
         for i in range(1, self.vuser):
             msg = self.__stomp_clients[i].receive()