스프링 인티그레이션+MQTT의 환경에서, 토픽에 따라서 별도의 스레드로 돌게 할 수 있나요?

Question

안녕하세요.질문 전에 먼저, JMS와 스프링 인티그레이션에 대한 이해가 다소 부족한 상태에서 질문 드리게 된 점 양해 부탁드립니다.MQTT와 스프링 인티그레이션을 통해서 개발되어 있는 프로젝트를 인계 받았습니다.이 프로젝트는 대충 아래와 같은 프로젝트입니다.1. IoT 프로젝트로써, 이 프로젝트는 스프링 인티그레이션&#43;MQTT로 구성되어 있다.2. IoT 장비는 일정 주기로 자신의 상태를 담은 데이터 프로토콜을 생성해서 MQTT로 발행한다. 이 발행주기는 장비마다 다르다.3. 장비의 구분을 위해, IoT 장비에는 미리 자동 증가값이 부여되어 있으며, MQTT 토픽명에는 이 증가값이 포함된다.(Ex. 1번 장비는 /AwesomePrj/1, 2번 장비는 /AwesomePrj/2 인 식. /AwesomePrj/ 부분은 토픽의 공통부분)4. 프로젝트에서는 MQTT의 /AwesomePrj/ 로 시작하는 토픽을 미리 구독해둔 상태이며, 장비가 MQTT를 통해 발행한 메시지를 수신한다.5. 이 프로젝트는 장비가 발행한 데이터를 분석해서 이상유무를 판단하는데, 장비의 발행주기 내에 상태 데이터가 발행되지 않았을 경우에도 이상으로 판단한다.대충 위와 같은 프로젝트입니다.이게 처음 테스트할때는 별다른 이슈가 없었는데, MQTT로 데이터를 발행하는 간단한 시뮬레이터를 제작한 다음 장비를 수십~수백대를 발행하기 시작했더니 문제가 발생하기 시작했습니다. 간단히 말씀드리면 MQTT에서 발행된 메시지를 처리하는 과정에서 점점 수신이 늦어지는 것이 발견된 것인데요.로그를 찍어보니까 아무래도 MQTT에서 발행된 데이터를 수신했을 때 처리하는 핸들러는 단일 스레드로 도는 것 같았습니다. 핸들러 내부에는 DB 처리도 있고 해서 핸들러가 실행된 후 종료될 때까지 시간이 걸릴 가능성이 다분한데요(1~2초?). 장비가 많아지고 데이터가 동시다발적으로 발행되면 이것들이 쌓이고 쌓여서 뒤로 갈 수록 처리가 늦어지고. 위 5번에서 명시해드린 부분이 오탐으로써 발생하는 것 같았습니다.이 상황에서 질문 드립니다. 제목에도 적혀 있지만, MQTT 토픽명에 따라서 데이터 수신 핸들러가 각각 별도의 스레드로 돌게 할 수 있을까요? 예를 들어서 /AwesomePrj/1 을 통해서 수신된 데이터들은 모두 단일 스레드로 처리되어 그 순서가 보장이 되지만, /AwesomePrj/1 로 수신된 데이터와 /AwesomePrj/2 로 수신된 데이터들은 각각 별개의 스레드로 돌게 하려는 것이 목적입니다. 이게 가능할까요?현재 진행중인 프로젝트라서 굉장히 단순화해서 적기는 했는데, 만약 답변에 필요한 부분을 누락한 부분이 있다면 말씀 주시면 가능한 범위 내에서 답변 드리도록 하겠습니다.길고 두서없는 글 읽어주셔서 대단히 고맙습니다.

스프링 인티그레이션+MQTT의 환경에서, 토픽에 따라서 별도의 스레드로 돌게 할 수 있나요?

0개의 답변

#mqtt 목록