diff --git a/broker/client.go b/broker/client.go index 0eb17b5..46a51e7 100644 --- a/broker/client.go +++ b/broker/client.go @@ -109,6 +109,8 @@ func (c *client) readLoop() { //add read timeout if err := nc.SetReadDeadline(time.Now().Add(timeOut)); err != nil { log.Error("set read timeout error: ", zap.Error(err), zap.String("ClientID", c.info.clientID)) + msg := &Message{client: c, packet: DisconnectdPacket} + b.SubmitWork(c.info.clientID, msg) return } diff --git a/plugins/authhttp/authhttp.go b/plugins/authhttp/authhttp.go index 78b3cda..cf488e5 100644 --- a/plugins/authhttp/authhttp.go +++ b/plugins/authhttp/authhttp.go @@ -2,6 +2,7 @@ package authhttp import ( "encoding/json" + "fmt" "io/ioutil" "net/http" "net/url" @@ -43,6 +44,7 @@ func Init() { if err != nil { log.Fatal("Unmarshal config file error: ", zap.Error(err)) } + fmt.Println("http: config: ", config) httpClient = &http.Client{ Transport: &http.Transport{