| 1 |
1
클라이언트 노드로부터의 연결 요청을 수신하고, 상기 연결 요청에 응답하여 상기 클라이언트 노드에 특정 MQTT(Message Queuing Telemetry Transport) 브로커를 할당하는 매니저부;적어도 하나 이상의 MQTT(Message Queuing Telemetry Transport) 브로커를 포함하고, 상기 적어도 하나 이상의 MQTT(Message Queuing Telemetry Transport) 브로커 중에서 상기 특정 MQTT(Message Queuing Telemetry Transport) 브로커를 통해 상기 클라이언트 노드로부터 상기 클라이언트 노드의 식별자 정보 및 구독한 토픽 정보를 수신하는 MQTT(Message Queuing Telemetry Transport) 중개부, 및 상기 수신된 식별자 정보와 상기 토픽 정보를 데이터베이스에 저장하여 상기 클라이언트 노드를 신규 연결하는 부하 처리부를 포함하고,상기 MQTT(Message Queuing Telemetry Transport) 중개부는,상기 특정 MQTT(Message Queuing Telemetry Transport) 브로커를 통해 상기 클라이언트 노드로부터 토픽 퍼블리시 메시지를 수신하고, 상기 토픽 퍼블리시 메시지의 수신에 응답하여 매니저부로 토픽 퍼블리시를 요청하며,상기 매니저부는,상기 요청에 응답하여 다른 MQTT(Message Queuing Telemetry Transport) 브로커에 토픽 퍼블리시와 관련된 내용을 브로드캐스팅하는 클라이언트 노드들 그룹화 장치
|
| 2 |
2
제1항에 있어서,상기 매니저부는,상기 적어도 하나 이상의 MQTT(Message Queuing Telemetry Transport) 브로커 중에서 부하를 고려하여 상기 특정 MQTT(Message Queuing Telemetry Transport) 브로커를 할당하는 클라이언트 노드들 그룹화 장치
|
| 3 |
3
삭제
|
| 4 |
4
제1항에 있어서,그룹별 일괄 메시지 전송을 수행하도록 제어하는 대시보드 제어부를 더 포함하고,상기 대시보드 제어부는,데이터베이스로부터 그룹별 클라이언트 노드 식별자 및 상기 적어도 하나 이상의 MQTT(Message Queuing Telemetry Transport) 브로커에 대한 연결정보를 독출하고,상기 독출된 그룹별 클라이언트 노드 식별자 및 상기 연결정보를 이용해서 특정 그룹에 속하는 적어도 하나 이상의 클라이언트 노드로 토픽 구독 상태 및 상기 그룹별 일괄 메시지를 퍼블리시 하도록 매니저부를 제어하는 클라이언트 노드들 그룹화 장치
|
| 5 |
5
제1항에 있어서,상기 특정 MQTT(Message Queuing Telemetry Transport) 브로커에 대한 자원 상태를 모니터링하는 모니터링부를 더 포함하는 클라이언트 노드들 그룹화 장치
|
| 6 |
6
제5항에 있어서,상기 모니터링부는,상기 특정 MQTT(Message Queuing Telemetry Transport) 브로커에 대한 네트워크 사용량 및 중앙처리장치의 사용량 중에서 적어도 하나를 모니터링 하는 클라이언트 노드들 그룹화 장치
|
| 7 |
7
제1항에 있어서,상기 매니저부는,상기 적어도 하나 이상의 MQTT(Message Queuing Telemetry Transport) 브로커에 대한 부하 상태를 모니터링하는 클라이언트 노드들 그룹화 장치
|
| 8 |
8
제1항에 있어서,상기 매니저부는,특정 MQTT(Message Queuing Telemetry Transport) 브로커에 임계치 이상의 부하가 감지되는 경우,새로운 MQTT(Message Queuing Telemetry Transport) 브로커를 생성하고, 상기 특정 MQTT(Message Queuing Telemetry Transport) 브로커에 연결된 클라이언트 노드 중 적어도 일부를 상기 새로운 MQTT(Message Queuing Telemetry Transport) 브로커에 이주시키는 클라이언트 노드들 그룹화 장치
|
| 9 |
9
매니저부에서, 클라이언트 노드로부터의 연결 요청을 수신하고, 상기 연결 요청에 응답하여 상기 클라이언트 노드에 특정 MQTT(Message Queuing Telemetry Transport) 브로커를 할당하는 단계;MQTT(Message Queuing Telemetry Transport) 중개부에서, 적어도 하나 이상의 MQTT(Message Queuing Telemetry Transport) 브로커 중에서 상기 특정 MQTT(Message Queuing Telemetry Transport) 브로커를 통해 상기 클라이언트 노드로부터 상기 클라이언트 노드의 식별자 정보 및 구독한 토픽 정보를 수신하는 단계, 및부하 처리부에서, 상기 수신된 식별자 정보와 상기 토픽 정보를 데이터베이스에 저장하여 상기 클라이언트 노드를 신규 연결하는 단계를 포함하고,상기 MQTT(Message Queuing Telemetry Transport) 중개부에서, 상기 특정 MQTT(Message Queuing Telemetry Transport) 브로커를 통해 상기 클라이언트 노드로부터 토픽 퍼블리시 메시지를 수신하는 단계; 및상기 토픽 퍼블리시 메시지의 수신에 응답하여 매니저부로 토픽 퍼블리시를 요청하는 단계를 더 포함하고,상기 매니저부에서, 상기 요청에 응답하여 다른 MQTT(Message Queuing Telemetry Transport) 브로커에 토픽 퍼블리시와 관련된 내용을 브로드캐스팅하는 단계를 더 포함하는 클라이언트 노드들 그룹화 방법
|
| 10 |
10
삭제
|
| 11 |
11
제9항에 있어서,대시보드 제어부에서, 데이터베이스로부터 그룹별 클라이언트 노드 식별자 및 상기 적어도 하나 이상의 MQTT(Message Queuing Telemetry Transport) 브로커에 대한 연결정보를 독출하는 단계;상기 독출된 그룹별 클라이언트 노드 식별자 및 상기 연결정보를 이용해서 특정 그룹에 속하는 적어도 하나 이상의 클라이언트 노드로 토픽 구독 상태 및 그룹별 일괄 메시지를 퍼블리시 하도록 상기 매니저부를 제어하는 단계를 더 포함하는 클라이언트 노드들 그룹화 방법
|
| 12 |
12
제9항에 있어서,모니터링부에서, 상기 특정 MQTT(Message Queuing Telemetry Transport) 브로커에 대한 자원 상태를 모니터링하는 단계를 더 포함하고,상기 자원 상태는 상기 특정 MQTT(Message Queuing Telemetry Transport) 브로커에 대한 네트워크 사용량 및 중앙처리장치의 사용량 중에서 적어도 하나를 포함하는 클라이언트 노드들 그룹화 방법
|
| 13 |
13
제9항에 있어서,상기 매니저부에서,특정 MQTT(Message Queuing Telemetry Transport) 브로커에 임계치 이상의 부하가 감지되는지 여부를 판단하는 단계;상기 특정 MQTT(Message Queuing Telemetry Transport) 브로커에서 임계치 이상의 부하가 감지되는 경우, 새로운 MQTT(Message Queuing Telemetry Transport) 브로커를 생성하는 단계;상기 특정 MQTT(Message Queuing Telemetry Transport) 브로커에 연결된 클라이언트 노드 중 적어도 일부를 상기 새로운 MQTT(Message Queuing Telemetry Transport) 브로커에 이주시키는 단계를 더 포함하는 클라이언트 노드들 그룹화 방법
|
