我正在嘗試動(dòng)態(tài)更改 mqtt 客戶端處理程序和證書(shū)，當(dāng)訂閱者和發(fā)布者連接時(shí)，這會(huì)導(dǎo)致訂閱者 EOF這就是我正在嘗試做的，1] 我正在初始化訂閱者/發(fā)布者（使用 firstPubHandler、firstConnectHandler 和默認(rèn)證書(shū)）2] 使用發(fā)布者在服務(wù)器上發(fā)送注冊(cè)消息以獲取新證書(shū)詳細(xì)信息3] 服務(wù)器將返回證書(shū)詳細(xì)信息，該響應(yīng)將由 firstConnectHandler 在主題.../id/Certificate上處理以下載證書(shū)。4] firstPubHandler 將處理服務(wù)器的響應(yīng)并重新初始化發(fā)布者/訂閱者（使用 messagePubHandler、connectHandler 和新下載的證書(shū)），connectHandler 將偵聽(tīng)所有主題/id/+一切正常，除了當(dāng)我重新初始化訂閱者/發(fā)布者時(shí)，訂閱者不斷斷開(kāi)連接并出現(xiàn)錯(cuò)誤“EOF”我在這里做錯(cuò)什么了嗎？或者有沒(méi)有更好的方法來(lái)做到這一點(diǎn)？任何幫助表示贊賞- 主功能var opt Paramsvar publisher mqtt.Clientvar subscriber mqtt.Clientfunc main() {    InitializeBroker(firstPubHandler, firstConnectHandler)    //Ultimately it will trigger message on ".../id/Certificate" topic which will be handled byfirstConnectHandler     PublishRegistrationMessage(publisher)    c := make(chan os.Signal, 1)    signal.Notify(c, os.Interrupt, syscall.SIGTERM)    done := make(chan os.Signal, 1)    signal.Notify(done, os.Interrupt, syscall.SIGTERM)    go func() {        for {        }    }()    <-done    <-c    DisconnectBrocker()}-- 處理程序// First handlersvar firstPubHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {    DownloadCertificates(msg.Payload())    InitializeBroker(messagePubHandler, connectHandler)}var firstConnectHandler mqtt.OnConnectHandler = func(c mqtt.Client) {    if token := c.Subscribe(opt.SubClientId+"/id/Certificate", 0, firstPubHandler); token.Wait() && token.Error() != nil {        log.Error(token.Error())    }}// Second handlersvar messagePubHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {    ProcessMessage(msg.Payload())}var connectHandler mqtt.OnConnectHandler = func(c mqtt.Client) {    if token := c.Subscribe(opt.SubClientId+"/id/+", 0, messagePubHandler); token.Wait() && token.Error() != nil {        log.Error(token.Error())    }}// Common handlervar connectLostHandler mqtt.ConnectionLostHandler = func(client mqtt.Client, err error) {    log.Info(err)}