标签：asp-net-core-2-1 asp-net-core c mqtt

我想检查MQTT服务器中MQTT客户端的用户名和密码,然后允许其连接.我实现了服务器并从设备发送数据.我获取了数据,但问题是身份验证无法正常工作,因为我需要根据客户端发送的主题从数据库获取客户端信息.到目前为止,我所做的如下：

public async Task Received()
{
  var options = new MqttServerOptions();                
  var mqttServer = new MqttFactory().CreateMqttServer();
  mqttServer.ApplicationMessageReceived += (sender, eventArgs) =>
  {    
    var path = eventArgs.ApplicationMessage.Topic;
    var device= GetDevice(path);   

    options.ConnectionValidator = p =>
    {    
      if (p.Username != device.username || p.Password != device.password)
      {
        p.ReturnCode = MqttConnectReturnCode.ConnectionRefusedBadUsernameOrPassword;
      }
    };
  };

  mqttServer.ClientConnected += (s, e) => { };

  mqttServer.ClientDisconnected += (s, e) => { };

  mqttServer.ClientSubscribedTopic += (s, e) => { };

  mqttServer.ClientUnsubscribedTopic += (s, e) => { };

  mqttServer.Started += (s, e) => { };

  mqttServer.Stopped += (s, e) => { };

  await mqttServer.StartAsync(options);
}

这段代码在我的启动中

app.UseMqttServer(server =>
{
  server.Started += async (sender, args) => await myClass.Received();
});

我可以用我的方法获得请求,但是我很难检查用户名和密码.

解决方法:

您可以通过在客户端尝试发布/订阅无效主题时断开客户端连接来实现此目的.

这意味着使用授权而不是身份验证来执行策略.只能使用MQTT连接消息中可用的参数来完成身份验证.客户端ID,密码.

为此,服务器启动时需要设置ConnectionValidator事件处理程序.它可以记录客户端尝试连接的客户端ID和密码,并始终允许连接继续进行.

当客户端发布/订阅主题时,将调用ApplicationMessageReceived事件处理程序.此事件处理程序可以验证客户端与数据库中的客户端连接时传入的客户端ID和密码(根据需要使用主题).如果路径,客户端ID和密码无效,则需要显式断开客户端连接.

通过使用mqttServer.GetClientSessionsStatus()在服务器上所有会话的列表中找到客户端,可以显式断开客户端的连接.然后在客户端会话上调用DisconnectAsync().

标签：asp-net-core-2-1,asp-net-core,c,mqtt
来源： https://codeday.me/bug/20191108/2007090.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。