Communications.Mqtt
네임스페이스 Going.Basis.Communications.Mqtt — MQTT 브로커 Publish/Subscribe 클라이언트
public enum MQQos : byte
MQTT QoS(Quality of Service) 수준
Values
LeastOnce (최소 1회 전달)
MostOnce (최대 1회 전달, 기본)
ExactlyOnce (정확히 1회 전달)
GrantedFailure (구독 실패)
public class MQSubscribe
MQTT 토픽 구독 정보를 담는 데이터 클래스
Constructor
| MQSubscribe | (string topic, MQQos qos = MQQos.MostOnce) |
Properties
| string | Topic get | 구독할 MQTT 토픽 |
| MQQos | Qos get | QoS 수준 |
public class MQReceiveArgs : EventArgs
메시지 수신 이벤트 인수
Constructor
| MQReceiveArgs | (string Topic, byte[] Datas) |
Properties
| string | Topic get | 수신된 메시지의 토픽 |
| byte[] | Datas get | 수신된 페이로드 바이트 배열 |
public class MQClient
MQTT 브로커에 연결하여 메시지를 발행(Publish)하고 구독(Subscribe)하는 클라이언트.
Properties
| string | BrokerHostName get set | 브로커 호스트명 또는 IP. 기본값: "127.0.0.1" |
| bool | IsStart get | 클라이언트 시작 여부 |
| bool | IsConnected get | 브로커 연결 여부 |
| string? | ClientID get | MQTT 클라이언트 ID |
| string? | UserName get | 인증 사용자명 |
| string? | Password get | 인증 비밀번호 |
| List<MQSubscribe> | Subscribes get | 현재 구독 목록 |
| object? | Tag get set | 사용자 정의 데이터 |
Methods — 연결
| void | Start | () | 브로커 연결 시작 (익명) |
| void | Start | (string? clientID) | 클라이언트 ID 지정 후 연결 |
| void | Start | (string? clientID, string? userName, string? password) | 인증 정보 지정 후 연결 |
| void | Stop | () | 연결 종료 |
| static bool | Test | (string BrokerIP, string ClientID) | 브로커 연결 가능 여부 테스트 |
Methods — Publish / Subscribe
| void | Publish | (string Topic, byte[] Data, MQQos qos = MostOnce, bool retain = false) | 바이트 페이로드 발행 |
| void | Publish | (string Topic, string Data, MQQos qos = MostOnce, bool retain = false) | 문자열 페이로드 발행 |
| void | Subscribe | (MQSubscribe sub) | MQSubscribe 객체로 구독 |
| void | Subscribe | (string Topic) | 토픽 문자열로 구독 (기본 QoS) |
| void | Subscribe | (string Topic, MQQos Qos) | QoS 지정 구독 |
| void | Unsubscribe | (string Topic) | 토픽 구독 해제 |
| void | UnsubscribeClear | () | 모든 구독 해제 |
Events
| EventHandler | Connected | 브로커 연결 성공 시 |
| EventHandler | Disconnected | 브로커 연결 해제 시 |
| EventHandler<MQReceiveArgs> | Received | 구독 메시지 수신 시. MQReceiveArgs.Topic, MQReceiveArgs.Datas |
검색 결과가 없습니다.