VB.NET模块级myMQTTclient定义为何会抛出异常？

我原本以为自己已经熟练掌握VB.NET了，但这个问题把我难住了。代码大致如下，目前运行完全正常。代码设计意图如下：

• 在模块级创建对象myMQTTclient，使其在整个模块中具备作用域
• 运行StartMQTT()——该方法仍能访问该对象
• 在主程序中多次调用MQTT_Publish——我仍能访问该对象

现在问题出现了……一切都很顺利，直到访问www.myserv.c……（推测为目标MQTT服务器）时，模块级的myMQTTclient对象出现了访问异常。

作为常年跟VB.NET和MQTT打交道的开发者，我帮你梳理几个最可能踩的坑，毕竟模块级对象看似全局可用，但MQTT客户端是有状态的，和特定服务器交互时很容易出状况：

1. 服务器连接中断导致对象失效 #

模块级对象的作用域没问题，但如果www.myserv.c...服务器因为网络波动、认证失败、限流等原因断开连接，myMQTTclient会直接进入异常状态，后续调用MQTT_Publish自然会报错。

解决思路： #

• 在发布前先检查连接状态，断开则自动重连
• 注册Disconnected事件，监听连接断开并触发重连逻辑

' 模块级对象定义
Private myMQTTclient As MqttClient

Sub StartMQTT()
    myMQTTclient = New MqttClient("www.myserv.c...")
    ' 注册连接断开事件
    AddHandler myMQTTclient.Disconnected, AddressOf OnMqttDisconnected
    ' 执行初始连接逻辑（省略认证、订阅等步骤）
    myMQTTclient.Connect()
End Sub

Private Sub OnMqttDisconnected(sender As Object, e As EventArgs)
    ' 延迟重连，避免频繁请求服务器
    Task.Delay(5000).ContinueWith(Sub()
                                      Try
                                          myMQTTclient.Connect()
                                      Catch ex As Exception
                                          ' 这里建议打日志记录重连失败原因
                                          Console.WriteLine($"重连失败: {ex.Message}")
                                      End Try
                                  End Sub)
End Sub

Sub MQTT_Publish(topic As String, payload As String)
    ' 发布前检查连接状态
    If Not myMQTTclient.IsConnected Then
        Try
            myMQTTclient.Connect()
        Catch ex As Exception
            Throw New InvalidOperationException("无法连接MQTT服务器", ex)
        End Try
    End If
    ' 执行发布操作
    myMQTTclient.Publish(topic, Encoding.UTF8.GetBytes(payload))
End Sub

2. 多线程访问引发的线程安全问题 #

如果StartMQTT和MQTT_Publish在不同线程调用（比如UI线程和后台任务线程），模块级对象很可能因为线程竞争出现访问异常，尤其是在连接服务器的过程中。

解决思路： #

用SyncLock给对象访问加锁，保证同一时间只有一个线程操作myMQTTclient：

Private myMQTTclient As MqttClient
Private ReadOnly mqttSyncLock As New Object ' 锁对象

Sub MQTT_Publish(topic As String, payload As String)
    SyncLock mqttSyncLock
        If Not myMQTTclient.IsConnected Then
            myMQTTclient.Connect()
        End If
        myMQTTclient.Publish(topic, Encoding.UTF8.GetBytes(payload))
    End SyncLock
End Sub

3. 服务器配置不兼容问题 #

有些MQTT服务器对协议版本、认证方式、QoS等级有严格要求，你的myMQTTclient初始化配置可能和服务器不匹配，导致访问时对象状态异常。

解决思路： #

• 查阅目标服务器的MQTT配置文档，确认协议版本（比如MQTT 3.1.1/5.0）、认证信息、QoS要求
• 初始化客户端时严格按照服务器要求设置参数：

' 以MQTTnet库为例的配置方式
Dim clientOptions = New MqttClientOptionsBuilder() _
    .WithTcpServer("www.myserv.c...") _
    .WithCredentials("your_username", "your_password") ' 如果服务器需要认证
    .WithProtocolVersion(MqttProtocolVersion.V311) ' 匹配服务器协议版本
    .WithCleanSession(False) ' 根据服务器要求设置
    .Build()

myMQTTclient = New MqttFactory().CreateMqttClient()
Await myMQTTclient.ConnectAsync(clientOptions)

最后提醒一句：一定要在异常处加详细的捕获和日志输出，比如记录异常类型、消息、堆栈跟踪，很多时候看似是对象访问问题，实际是服务器返回的具体错误导致的状态异常，日志能帮你快速定位根源。

内容的提问来源于stack exchange，提问作者CWDev