Merge pull request #63 from stulzq/master

.gitignore

@@ -17,4 +17,6 @@
 # vendor/
 
 .vscode
-.idea
+.idea
+
+vendor

client/security_util.go

@@ -0,0 +1,34 @@
+package client
+
+import (
+	"crypto/sha1"
+	"encoding/hex"
+)
+
+func Scramble411(data *[]byte,seed *[]byte) []byte {
+	crypt := sha1.New()
+
+	//stage1
+	crypt.Write(*data)
+	stage1 := crypt.Sum(nil)
+
+	//stage2
+	crypt.Reset()
+	crypt.Write(stage1)
+	stage2 := crypt.Sum(nil)
+
+	//stage3
+	crypt.Reset()
+	crypt.Write(*seed)
+	crypt.Write(stage2)
+	stage3 := crypt.Sum(nil)
+	for i := range stage3 {
+		stage3[i] ^= stage1[i]
+	}
+
+	return stage3
+}
+
+func ByteSliceToHexString(data []byte) string {
+	return hex.EncodeToString(data)
+}

client/simple_canal_connector.go

@@ -147,11 +147,13 @@ func (c SimpleCanalConnector) doConnect() error {
 		}
 
 		handshake := &pb.Handshake{}
+		seed := &handshake.Seeds
 		err = proto.Unmarshal(p.GetBody(), handshake)
 		if err != nil {
 			return err
 		}
-		pas := []byte(c.PassWord)
+		bytePas :=[]byte(c.PassWord)
+		pas := []byte(ByteSliceToHexString(Scramble411(&bytePas,seed)))
 		ca := &pb.ClientAuth{
 			Username:               c.UserName,
 			Password:               pas,