MQTT5 메시지 큐(Message Queue)란? 메시지 큐의 기본 개념을 간단히 소개*자세한 설명 생략 ▷ 메시지 큐(Message Queue)란? - 메시지 지향 미들웨어(MOM : Message Oriented Middleware)를 구현한 시스템 *미들웨어 : Application들을 연결해 서로 데이터를 교환할 수 있게 해주는 소프트웨어 *메시지 지향 시스템 : 메시지 API를 통해 각 분산되어 있는 Application 간 데이터를 교환할 수 있도록 하는 시스템 *비동기방식, Publisher/Subscribe 로 구성 - 프로세스(프로그램) 간 데이터를 교환할 때 사용하는 기술 - 대용량 데이터를 처리하기 위한 배치 작업이나, 채팅 서비스, 비동기 데이터를 처리할 때 활용 *모든 요청을 메시지 큐에.. 2023. 2. 6. SpringBoot에서 MQTT Client + WebFlux 구축 WebFlux를 적용한 MQTT Client를 구축하고Topic 메시지 도착 시 Callback으로 Bean을 통해 서비스 구분*Mqtt Broker(mosqitto) 아래 관련 글 참고*자세한 설명 생략 ▷ Project 전체 구조*파일 이름으로 검색 가능 ▷ build.gradle ▷ application.properties ▷ MqttApplication.java*아무 작업하지 않음 ▷ MqttPublishVO.java*MqttController 발행 요청 VO ▷ MqttSubscribeVO.java*MqttController 구독 요청 VO ▷ MqttController.java ▷ UserController.java ▷ MqttService.java ▷ A/B.. 2022. 12. 2. Sinks.many() 란? EmitterProcessor가 @Deprecated 돼서 Sinks.many()로 대체 사용*EmitterProcessor 내부에서 Sinks를 사용하고 있음*Processor : 처리 단계를 나타내며 발행자 인터페이스와 구독자 인터페이스를 모두 상속*자세한 설명 생략 ▷ Sinks.many() - 데이터를 구독 받고, 구독한 데이터를 다시 발행할 때 사용- 여러 subscriber가 사용할 수 있는 구독과 발행이 동시에 일어나는 프로세서- 내부 queue를 가지고 있어 subscriber가 없더라도 해당 데이터를 큐에 쌓음 종류설명unicast()하나의 Subscriber만 허용(즉, 하나의 Client 만 연결)multicast()여러 Subscriber를 허용multicast().onBackpr.. 2022. 11. 29. MQTT Broker(mosqitto) 설치 및 설정 Docker를 이용해 MQTT Broker를 간단하게 설치할 수 있다.*자세한 설명 생략 ① docker-compose.yml 생성*docker-compose.yml 설명 아래 관련 글 참고 version: "3.7"services: mqtt: container_name: mqtt-broker image: eclipse-mosquitto volumes: - mosquitto_conf:/mosquitto/config - mosquitto_data:/mosquitto/data - mosquitto_log:/mosquitto/log networks: - mqttnet .. 2022. 11. 16. MQTT 란? MQTT ( Message Queueing Telemetry Transport )* 자세한 설명 생략 ▷ MQTT 란? - IoT와 같이 제한되거나 대규모 트래픽 전송을 위해 만들어진 발행/구독 기반의 메시징 프로토콜 - 브로커와 클라이언트는 TCP/IP 소켓 연결을 한 후 상태 유지(연결 지향적) *TCP/IP : 데이터가 의도된 목적지로 전송 될 수 있도록 보장해 주는 하나의 약속 ▷ MQTT 주요 구성 명칭설명MessageMQTT를 통해 교환되는 모든 정보Publisher ( 발행자 )Message 송신Subscriber ( 구독자 )Message 구독 및 수신 Topic ( 주제 )Message 이름 ( 채널 )Broker ( 중개인 )발행자로 부터 모든 Message를 받고, 특정 Topo.. 2022. 11. 7. 이전 1 다음 728x90 728x90
