diff --git a/server/client_resp.go b/server/client_resp.go
index 1b50bc3..078a02c 100644
--- a/server/client_resp.go
+++ b/server/client_resp.go
@@ -55,6 +55,11 @@ func (c *respClient) run() {
 			c.conn.Close()
 		}
 
+		if c.tx != nil {
+			c.tx.Rollback()
+			c.tx = nil
+		}
+
 		c.app.removeSlave(c.client)
 	}()