💫 MQTT란?
MQTT(메시지 큐잉 텔레메트리 트랜스포트, Message Queuing Telemetry Transport)는 ISO 표준(ISO/IEC PRF 20922) 발행-구독 기반의 메시징 프로토콜이다.
TCP/IP 프로토콜 위에서 동작한다. "작은 코드 공간"(small code footprint)이 필요하거나 네트워크 대역폭이 제한되는 원격 위치와의 연결을 위해 설계되어 있다. 발행-구독 메시징 패턴은 메시지 브로커가 필요하다.
💫 예제 설명
클라이언트 프로그램 두개를 생성해서 각자 클라이언트에서 보내는 메세지를 상대 클라이언트에 뜨도록 하는 프로젝트이다 .
💫 실행 전 다운받아야하는 것들
1. 브로커는 Mosquitto를 다운받아 사용
2. NuGet 패키지 M2Mqtt 설치
💫 Mosquitto 시작
1. cmd창에서 Mosquitto가 설치된 경로로 이동
cd C:\Program Files\mosquitto
2. 이동한뒤 Mosquitto broker 실행(-v : 모든 통신과정을 보여주는 옵션)
mosquitto -v
💫 클라이언트 form 형태
💫 클라이언트 시작
1. Start 버튼을 누르면 클라이언트-broker 연결 시작
💫 전송 및 종료
1. 메세지 전송
전송버튼을 누르면 수신 클라이언트의 수신메세지 label에 메세지표시
2. 클라이언트가 종료되었을때
💫 클라이언트 소스 코드
클라이언트 소스 코드는 수신/발신 토픽만 다름!!
1. Client 1
using System;
using System.Net;
using System.Reflection.Emit;
using System.Text;
using System.Windows.Forms;
using uPLibrary.Networking.M2Mqtt;
using uPLibrary.Networking.M2Mqtt.Messages;
namespace Client
{
public partial class Form1 : Form
{
private MqttClient client;
public Form1()
{
InitializeComponent();
//폼 닫기 이벤트 선언
this.FormClosed += Form1_FormClosing;
}
/// <summary>
/// 폼 닫기 이벤트 핸들러 선언
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void Form1_FormClosing(object sender, FormClosedEventArgs e)
{
if (client != null && client.IsConnected)
{
client.Disconnect();
}
}
/// <summary>
/// 수신 메세지 표시
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void Client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
{
// 수신된 메시지를 변수에 저장
string receivedMessage = Encoding.UTF8.GetString(e.Message);
// UI 업데이트를 위해 UI 스레드로 전달
Invoke(new Action(() =>
{
// receivedMessage를 Form label ReceivedText에 표시
ReceivedText.Text = receivedMessage;
}));
}
/// <summary>
/// start 버튼 클릭했을때 실행
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void Startbutton_Click(object sender, EventArgs e)
{
// MQTT 브로커 주소
string MQTT_BROKER_ADDRESS = "127.0.0.1";
// 클라이언트 인스턴스 생성
client = new MqttClient(IPAddress.Parse(MQTT_BROKER_ADDRESS));
// 메시지 수신 시 이벤트 핸들러 등록
client.MqttMsgPublishReceived += Client_MqttMsgPublishReceived;
// 고유한 클라이언트 ID 생성
string clientId = "COOKIE";
try
{
client.Connect(clientId);
//연결이 성공하면 Serverconnect에 성공 메세지출력
if (client.IsConnected) Serverconnect.Text = "SERVER " + MQTT_BROKER_ADDRESS + "와 연결 성공!";
}
catch (Exception ex)
{
//연결이 실패하면 Serverconnect에 실패 메세지, 오류메세지 출력
Serverconnect.Text = "브로커에 연결할 수 없습니다.\n" + ex.Message + "연결 오류";
}
// 수신 토픽 "coorong" 구독
client.Subscribe(new string[] { "coorong" }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
}
/// <summary>
/// Send버튼 클릭했을때 실행
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void Sendbutton_Click(object sender, EventArgs e)
{
// 보낼 메시지
string messageToSend = SendText.Text;
// 발신 토픽 "cookie", 메세지 발송
client.Publish("cookie", Encoding.UTF8.GetBytes(messageToSend), MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, false);
//메세지박스 초기화
SendText.Text = "";
}
}
}
2. Client 2
using System;
using System.Net;
using System.Reflection.Emit;
using System.Text;
using System.Windows.Forms;
using uPLibrary.Networking.M2Mqtt;
using uPLibrary.Networking.M2Mqtt.Messages;
namespace Client
{
public partial class Form1 : Form
{
private MqttClient client;
public Form1()
{
InitializeComponent();
//폼 닫기 이벤트 선언
this.FormClosed += Form1_FormClosing;
}
/// <summary>
/// 폼 닫기 이벤트 핸들러 선언
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void Form1_FormClosing(object sender, FormClosedEventArgs e)
{
if (client != null && client.IsConnected)
{
client.Disconnect();
}
}
/// <summary>
/// 수신 메세지 표시
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void Client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
{
// 수신된 메시지를 변수에 저장
string receivedMessage = Encoding.UTF8.GetString(e.Message);
// UI 업데이트를 위해 UI 스레드로 전달
Invoke(new Action(() =>
{
// receivedMessage를 Form label ReceivedText에 표시
ReceivedText.Text = receivedMessage;
}));
}
/// <summary>
/// start 버튼 클릭했을때 실행
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void Startbutton_Click(object sender, EventArgs e)
{
// MQTT 브로커 주소
string MQTT_BROKER_ADDRESS = "127.0.0.1";
// 클라이언트 인스턴스 생성
client = new MqttClient(IPAddress.Parse(MQTT_BROKER_ADDRESS));
// 메시지 수신 시 이벤트 핸들러 등록
client.MqttMsgPublishReceived += Client_MqttMsgPublishReceived;
// 고유한 클라이언트 ID 생성
string clientId = "COORONG";
try
{
client.Connect(clientId);
//연결이 성공하면 Serverconnect에 성공 메세지출력
if (client.IsConnected) Serverconnect.Text = "SERVER " + MQTT_BROKER_ADDRESS + "와 연결 성공!";
}
catch (Exception ex)
{
//연결이 실패하면 Serverconnect에 실패 메세지, 오류메세지 출력
Serverconnect.Text = "브로커에 연결할 수 없습니다.\n" + ex.Message + "연결 오류";
}
// 수신 토픽 "cookie" 구독
client.Subscribe(new string[] { "cookie" }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
}
/// <summary>
/// Send버튼 클릭했을때 실행
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void Sendbutton_Click(object sender, EventArgs e)
{
// 보낼 메시지
string messageToSend = SendText.Text;
// 발신 토픽 "coorong", 메세지 발송
client.Publish("coorong", Encoding.UTF8.GetBytes(messageToSend), MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, false);
//메세지박스 초기화
SendText.Text = "";
}
}
}