본문 바로가기

👩🏻‍💻 🌮 💬

👩🏻‍💻/mqtt8

[MQTT] presence detection 에서 qos 와 retain 설정 최근 진행한 것 중에 유용하게 잘 사용한 paho-mqtt option이 있어서 기록한다. 아래와 같은 mqtt 를 개발하고 있었다mqtt 통신의 신뢰성을 높이기 위해서 main client 에서 sub client 의 연결 상태(online/offline)를 실시간으로 확인하고 싶었다. 그래서 qos, retain을 설정하고, will_set도 등록했다아래 예시를 보며 어떻게 사용했는지 확인해보자! ✨ 여기서 새로 알게된 용어 : presence detection→ IoT, MQTT, 채팅 시스템에 많이 쓰이는 개념이다.→ 현재 누가 연결되었는지(online), 누가 연결이 끊어졌는지(offline)에 대한 상태를 시스템이 실시간으로 파악하는 기능이다.→ "클라이언트의 접속 상태 감지" 라고 생각하면 .. 2025. 5. 8.

[MQTT] Keep Alive 최근에 MQTT 통신 개발을 진행하면서 Keep Alive 설정에 관련한 문제를 겪었다. Status Update 하는 mqtt 클라이언트를 아래와 같이 생성하고send_status 라는 함수를 호출해서 사용하려고 했다. import paho.mqtt.client as mqttimport uuidimport timeclass RobotStatusUpdater: def __init__(self, broker_ip, topic="robot/status"): self.client = mqtt.Client(f"Robot_Status_Updater_{uuid.uuid4()}") self.client.connect(broker_ip, 1883) self.topic = to.. 2025. 3. 12.

[MQTT] pc 2개 통신 (python, 양방향 통신) 개요PC 2개가 있다.하나는 User가 업무를 요청하고, 나머지 하나는 Robot이 그 업무를 받아서 실시간 상태를 User가 알 수 있도록 업데이트를 해줄 것이다.전 프로젝트에서는 Robot이 하나 뿐이라서 socket으로 연결을 했다.이번에는 Robot이 추가로 더 늘어날 가능성을 염두해서 MQTT를 활용하려고 한다. 편히 PC, Robot이라고 칭하겠다.PC → Robot : 수행할 작업 (텍스트 형식) 전달Robot → PC : 작업 상태 (실시간 업데이트) 전달 구조PC는 작업지시를 발행하고, 로봇은 이를 구독로봇은 상태를 발행하고, PC는 이를 구독하여 실시간으로 상태를 확인Topic 설계PC → Robot: "robot/task"Robot → PC: "robot/status" 간단한 코드 구.. 2025. 2. 25.

[MQTT] Mac mosquitto 설치 / 실행 / 중지 1. mosquitto 설치brew install mosquitto 2. mosquitto 서비스 실행brew services start mosquitto 3. mosquitto 서비스 중지brew services stop mosquitto 메세지 확인은 MQTT Explorer 사용했다. 연결 잘됨 ~ 2025. 2. 25.

[MQTT] python 으로 sub / pub 구현하기 MQTT와 Kakfa 비교개요최근에 진행한 프로젝트 중에 socket 통신으로 데이터를 보내고, responce를 받는 기능을 개발했는데네트워크가 불안정한 환경에서 진행하니까 socket 연결 불안정, 연결 지연 등등 이슈들이 발bonory.tistory.comkafka와 mqtt에 대해서 찾아보고 정리했다.그리고는 mqtt를 한번 사용해 보려고 한다. 진행1. python으로 topic에 message를 전송한다.2. MQTT Explorer로 message를 잘 받는지 확인한다.3. python으로 topic을 subscribe하고 message를 확인한다. (0) pip 설치pip install paho-mqtt (1) python - message 전송import paho.mqtt.client a.. 2024. 10. 28.

MQTT와 Kakfa 비교 개요최근에 진행한 프로젝트 중에 socket 통신으로 데이터를 보내고, responce를 받는 기능을 개발했는데네트워크가 불안정한 환경에서 진행하니까 socket 연결 불안정, 연결 지연 등등 이슈들이 발생해서다음에는 mqtt 혹은 kafka를 사용해봐야겠다 싶어서 서치해보았다.간단한 비교· MQTT : 경량 메시징, 낮은 대기 시간 및 낮은 데이터 트래픽에 적합하다. IoT나 간단한 애플리케이션에 유리하다.· Kafka : 높은 데이터 트래픽 및 메시지 유지 관리가 필요한 대규모 애플리케이션에 적합하다. 안정성과 성능이 중요할 때 유리하다. 좀 더 자세하게 정리✅ MQTT· Message Queuing Telemetry Transport· 제한된 리소스를 가진 장치나 IoT(사물인터넷) 장치 사이에 통.. 2024. 10. 23.

[MQTT] message를 안보내는데 계속 message가 쌓이는 issue 사실 이건 문제까지는 아니고, 좀 더 자세하게 알고 싶었다.저번 포스팅에서는 mqtt explorer 에 연결을 했다. [MQTT] mqtt client에 connect 안되는 문제ec2 instance를 생성하고 mosquitto를 실행시켰다. 그리고 mqtt connection tool를 사용하여 연결을 시도하니, 연결이 불가능했다 Starting in local only mode. Connections will only possible from clients running on this machine.bonory.tistory.com 연결을 하고 보니,나 연결만 하고 아무 것도 안했는데 ?! 자꾸 몇초 간격으로 message가 쌓이는 것 처럼 숫자가 계속 늘어났다.뭐지 ??????? 한번 확인해보.. 2024. 3. 7.

[MQTT] mqtt client에 connect 안되는 문제 ec2 instance를 생성하고 mosquitto를 실행시켰다.그리고 mqtt connection tool를 사용하여 연결을 시도하니, 연결이 불가능했다 Starting in local only mode. Connections will only possible from clients running on this machine.로컬 모드에서만 가능하며Create a configuration file which defines a listener to allow remote access.원격 엑세스를 config를 create 하라고 하는 것 같다 첫번째, mosquitto config를 수정한다.linux라면 /etc/mosquitto/mosquitto.conf 에 위치한다. 이렇게 설정되어있는데, 아.. 2024. 3. 6.

이전 1 다음

티스토리툴바