개발/spring, spring boot

[Spring integration] TCP 연결 끊김 처리, connectionId

TCP 연결이 끊겼을때 특정 로직을 실행하고 싶으면 아래와 같이 TCP config 파일에 TcpConnectionCloseEvent 이벤트의 리스너를 정의하면 됩니다.@Beanfun closed(): ApplicationListener { return ApplicationListener { e: TcpConnectionCloseEvent -> logger.info {"Connection closed: ${e.getConnectionId()}"} }}closed 함수는 아래와 같은 일을 합니다.이벤트 리스닝: TCP 연결이 닫힐 때 발생하는 TcpConnectionCloseEvent를 리스닝합니다.로그 기록: logger.info를 사용하여 연결이 닫혔다는 정보를 로그로 남깁니다...

[Spring Integration] [tcp server] 역직렬화 처리 시 주의사항

Spring Integration을 이용해서 개발한 tcp server에서 아래와 같이 역직렬화 처리를 했습니다.class TcpSerializer: AbstractPooledBufferByteArraySerializer() { override fun doDeserialize(inputStream: InputStream?, buffer: ByteArray?): ByteArray? { val data = inputStream?.readAllBytes() data ?: return null return data } override fun serialize(bytes: ByteArray, outputStream: OutputStream) { o..

[JPA] MariaDB에서 PK를 날짜+sequence의 nextval의 조합으로 insert하는 방법

1. 데이터베이스 설정먼저, MariaDB에서 시퀀스를 생성합니다.CREATE SEQUENCE seq_idSTART WITH 1INCREMENT BY 1; 2. application.yml 설정spring: datasource: url: jdbc:mariadb://localhost:3306/yourdatabase username: yourusername password: yourpassword driver-class-name: org.mariadb.jdbc.Driver jpa: hibernate: ddl-auto: update show-sql: true properties: hibernate.dialect: org.hibernate.dialect..

[WebSocket] [STOMP] client 테스트 방법

WebSocket 통신에서 STOMP을 사용할때 client 테스트 방법에 대해서 정리해보았습니다. server의 config 파일은 아래와 같이 되어 있습니다.@Configuration@EnableWebSocketMessageBroker // 웹 소켓을 사용함class WebSocketConfig : WebSocketMessageBrokerConfigurer { override fun configureMessageBroker(registry: MessageBrokerRegistry) { // 해당 경로로 들어오는것을 구독하는것으로 정한다. registry.enableSimpleBroker("/topic") //registry.setApplicationDesti..