Server start !!!

[sefaa-dev]

what's my wrong with my code ?

var options = new MqttServerOptionsBuilder(); var mqttFactory = new MqttFactory(); mqttServer = mqttFactory.CreateMqttServer(options.WithDefaultEndpointPort(1800).Build());

C:\Users\DELL_05>netstat -na | find "1800"

C:\Users\DELL_05>

[CZEMacLeod]

Almost in your issue title: You created your server, but didn't start it.

See line 82 below.

MQTTnet/Samples/Server/Server_Simple_Samples.cs

Lines 61 to 90 in 6fdee9e

	public static async Task Run_Minimal_Server()
	{
	/*
	* This sample starts a simple MQTT server which will accept any TCP connection.
	*/
	var mqttFactory = new MqttFactory();
	// The port for the default endpoint is 1883.
	// The default endpoint is NOT encrypted!
	// Use the builder classes where possible.
	var mqttServerOptions = new MqttServerOptionsBuilder().WithDefaultEndpoint().Build();
	// The port can be changed using the following API (not used in this example).
	// new MqttServerOptionsBuilder()
	// .WithDefaultEndpoint()
	// .WithDefaultEndpointPort(1234)
	// .Build();
	using (var mqttServer = mqttFactory.CreateMqttServer(mqttServerOptions))
	{
	await mqttServer.StartAsync();
	Console.WriteLine("Press Enter to exit.");
	Console.ReadLine();
	// Stop and dispose the MQTT server if it is no longer needed!
	await mqttServer.StopAsync();
	}
	}

Also remember to Dispose your server when you are finished with it. (Implicit with the using in the code example above.)

[sefaa-dev]

Actually I started it but it doesn't work

`
static void Main(string[] args)
{
var optionBuilder = new MqttServerOptionsBuilder()
.WithDefaultEndpointPort(1800)
.WithDefaultCommunicationTimeout(TimeSpan.FromMilliseconds(30*1000));
var option = optionBuilder.Build();

 using (var mqttServer = new MqttFactory().CreateMqttServer(option))
 {
     mqttServer.StartAsync().Wait();

     Console.WriteLine("Press Enter to exit.");
     Console.ReadLine();
     mqttServer.StopAsync().Wait();
 }

}
`

[CZEMacLeod]

@sefaa-dev You need to call the WithDefaultEndpoint() method as well, to actually enable the default endpoint in addition to configuring the ipaddress and/or port (actually - both of these are technically optional as they default to 0.0.0.0:1883)

using MQTTnet;
using MQTTnet.Server;

public class Program
{
    static async Task Main(string[] args)
    {
        var logger = new MQTTnet.Diagnostics.MqttNetEventLogger();
        logger.LogMessagePublished += Logger_LogMessagePublished;
        var optionBuilder = new MqttServerOptionsBuilder()
            .WithDefaultEndpoint()
            .WithDefaultEndpointBoundIPAddress(System.Net.IPAddress.Loopback)
            .WithDefaultEndpointPort(18883);
        var option = optionBuilder.Build();
        var factory = new MqttFactory(logger);
        using var mqttServer = factory.CreateMqttServer(option);
        await mqttServer.StartAsync();

        Console.WriteLine("Press Enter to exit.");
        Console.ReadLine();
        await mqttServer.StopAsync();
    }

    private static void Logger_LogMessagePublished(object? sender, MQTTnet.Diagnostics.MqttNetLogMessagePublishedEventArgs e)
    {
        Console.WriteLine(e.LogMessage);
    }
}

netstat -na | find "883"