|
|
@@ -61,95 +61,4 @@ This library is used in the following projects: |
|
|
|
If you use this library and want to see your project here please let me know. |
|
|
|
|
|
|
|
# Examples |
|
|
|
## MqttClient |
|
|
|
|
|
|
|
```csharp |
|
|
|
var options = new MqttClientOptions |
|
|
|
{ |
|
|
|
Server = "localhost" |
|
|
|
}; |
|
|
|
|
|
|
|
var client = new MqttClientFactory().CreateMqttClient(options); |
|
|
|
client.ApplicationMessageReceived += (s, e) => |
|
|
|
{ |
|
|
|
Console.WriteLine("### RECEIVED APPLICATION MESSAGE ###"); |
|
|
|
Console.WriteLine($"+ Topic = {e.ApplicationMessage.Topic}"); |
|
|
|
Console.WriteLine($"+ Payload = {Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}"); |
|
|
|
Console.WriteLine($"+ QoS = {e.ApplicationMessage.QualityOfServiceLevel}"); |
|
|
|
Console.WriteLine($"+ Retain = {e.ApplicationMessage.Retain}"); |
|
|
|
Console.WriteLine(); |
|
|
|
}; |
|
|
|
|
|
|
|
client.Connected += async (s, e) => |
|
|
|
{ |
|
|
|
Console.WriteLine("### CONNECTED WITH SERVER, SUBSCRIBING ###"); |
|
|
|
|
|
|
|
await client.SubscribeAsync(new List<TopicFilter> |
|
|
|
{ |
|
|
|
new TopicFilter("#", MqttQualityOfServiceLevel.AtMostOnce) |
|
|
|
}); |
|
|
|
}; |
|
|
|
|
|
|
|
client.Disconnected += async (s, e) => |
|
|
|
{ |
|
|
|
Console.WriteLine("### DISCONNECTED FROM SERVER ###"); |
|
|
|
await Task.Delay(TimeSpan.FromSeconds(5)); |
|
|
|
|
|
|
|
try |
|
|
|
{ |
|
|
|
await client.ConnectAsync(); |
|
|
|
} |
|
|
|
catch |
|
|
|
{ |
|
|
|
Console.WriteLine("### RECONNECTING FAILED ###"); |
|
|
|
} |
|
|
|
}; |
|
|
|
|
|
|
|
try |
|
|
|
{ |
|
|
|
await client.ConnectAsync(); |
|
|
|
} |
|
|
|
catch |
|
|
|
{ |
|
|
|
Console.WriteLine("### CONNECTING FAILED ###"); |
|
|
|
} |
|
|
|
|
|
|
|
Console.WriteLine("### WAITING FOR APPLICATION MESSAGES ###"); |
|
|
|
|
|
|
|
var messageFactory = new MqttApplicationMessageFactory(); |
|
|
|
while (true) |
|
|
|
{ |
|
|
|
Console.ReadLine(); |
|
|
|
|
|
|
|
var applicationMessage = messageFactory.CreateApplicationMessage("myTopic", "Hello World", MqttQualityOfServiceLevel.AtLeastOnce); |
|
|
|
await client.PublishAsync(applicationMessage); |
|
|
|
} |
|
|
|
``` |
|
|
|
|
|
|
|
## MqttServer |
|
|
|
|
|
|
|
```csharp |
|
|
|
var options = new MqttServerOptions |
|
|
|
{ |
|
|
|
ConnectionValidator = p => |
|
|
|
{ |
|
|
|
if (p.ClientId == "SpecialClient") |
|
|
|
{ |
|
|
|
if (p.Username != "USER" || p.Password != "PASS") |
|
|
|
{ |
|
|
|
return MqttConnectReturnCode.ConnectionRefusedBadUsernameOrPassword; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
return MqttConnectReturnCode.ConnectionAccepted; |
|
|
|
} |
|
|
|
}; |
|
|
|
|
|
|
|
var mqttServer = new MqttServerFactory().CreateMqttServer(options); |
|
|
|
mqttServer.Start(); |
|
|
|
|
|
|
|
Console.WriteLine("Press any key to exit."); |
|
|
|
Console.ReadLine(); |
|
|
|
|
|
|
|
mqttServer.Stop(); |
|
|
|
``` |
|
|
|
Please find examples and the documentation at the Wiki of this repository (https://github.com/chkr1011/MQTTnet/wiki). |