设置MQTT缓存 大小

Question

1.使用的库MQTTNET
2.求设置服务端 消息队列大小的方法

Answer 1

引自免费微信小程序：皆我百晓生

在C#中，使用MQTTNET库配置服务端消息队列的大小，你需要直接修改MqttServerOptions对象中的相关属性。首先确保已经安装了MQTTNET库，如果没有，请通过NuGet包管理器安装它：

Install-Package MQTTnet.Server

然后，在创建服务器实例时，可以设置消息队列的相关选项。这里是一个示例代码，展示了如何设置最大连接数、消息队列的最大长度以及客户端离线存储的消息数量：

using MQTTnet;
using MQTTnet.Server;

// 创建MQTT服务器配置
var options = new MqttServerOptionsBuilder()
    .WithDefaultEndpoint() // 使用默认的TCP端口1883
    .WithDefaultApplicationMessageHandler(async context => { /* 在此处处理接收到的消息 */ })
    .WithMaxClients(50) // 设置最大连接数为50
    .WithClientSessionExpiryTimeout(TimeSpan.FromMinutes(10)) // 设置客户端会话过期时间
    .WithApplicationMessageLimitation(maximumQueueSize: 1000, maximumInflightMessagesPerClient: 100) // 设置消息队列最大长度和每个客户端允许同时发送的消息数
    .Build();

// 创建并启动MQTT服务器
var mqttServer = new MqttFactory().CreateMqttServer(options);
await mqttServer.StartAsync();

在这个例子中，我们设置了消息队列的最大长度（maximumQueueSize）为1000条消息，并且限制每个客户端最多可以有100条消息同时处于发送状态（maximumInflightMessagesPerClient）。这些设置可以根据实际需求进行调整。

注意：WithApplicationMessageLimitation方法是设置应用级别的消息限制，而不是操作系统级别的。这意味着即使达到这个限制，系统仍然可能会接收更多消息，但它们将不会被放入队列中，而是会被丢弃。如果你希望在操作系统级别限制队列大小，可能需要在操作系统层面进行额外的配置。