Allow Broker DisConnect connections by ClientId (#135)

* Allow Broker DisConnect connections by ClientId

* Allow Broker DisConnect connections by ClientId

broker/broker.go

@@ -255,6 +255,18 @@ func (b *Broker) StartClusterListening() {
 	}
 }
 
+func (b *Broker) DisConnClientByClientId(clientId string) {
+	cli, loaded := b.clients.LoadAndDelete(clientId)
+	if !loaded {
+		return
+	}
+	conn, success := cli.(*client)
+	if !success {
+		return
+	}
+	conn.Close()
+}
+
 func (b *Broker) handleConnection(typ int, conn net.Conn) {
 	//process connect packet
 	packet, err := packets.ReadPacket(conn)

broker/http.go

@@ -11,8 +11,8 @@ func InitHTTPMoniter(b *Broker) {
 		clientid := c.Param("clientid")
 		cli, ok := b.clients.Load(clientid)
 		if ok {
-			conn, succss := cli.(*client)
-			if succss {
+			conn, success := cli.(*client)
+			if success {
 				conn.Close()
 			}
 		}