change config

config/config.go

@@ -11,8 +11,10 @@ const (
 	FORBIDDEN_MSG         = "FORBIDDEN"
 	SYSTEM_ERROR          = 123
 	SYSTEM_ERROR_MSG      = "SYSTEM ERROR"
-	GET_TIMEOUT           = 125
+	GET_TIMEOUT           = 124
 	GET_TIMEOUT_MSG       = "GET TIMEOUT"
+	CONNECT_NO_MATCH      = 125
+	CONNECT_NO_MATCH_MSG  = "CONNECT NO MATCH"
 	CONNECT_END           = 126
 	CONNECT_END_MSG       = "CONNECT END"
 	NO_MATCH              = 127

conn/util/compress.go

@@ -31,7 +31,6 @@ func CompressData(data []byte) (out []byte, ok bool) {
 
 // 解压缩
 func UncompressData(compressedData []byte) (data []byte, ok bool) {
-	// 没有压缩，直接返回
 	if compressedData[0]&0x01 != 0 {
 		zr, err := gzip.NewReader(bytes.NewReader(compressedData[1:]))
 		if err != nil {

hub.go

@@ -419,8 +419,8 @@ func (h *Hub) GetOne(channel *regexp.Regexp, cmd string, data []byte) (response
 	}, 1, 0)
 	if response == nil {
 		response = &ResponseData{
-			State: config.NO_MATCH,
-			Data:  []byte(config.NO_MATCH_MSG),
+			State: config.CONNECT_NO_MATCH,
+			Data:  []byte(config.CONNECT_NO_MATCH_MSG),
 		}
 	}
 	return
@@ -435,8 +435,8 @@ func (h *Hub) GetOneWithTimeout(channel *regexp.Regexp, cmd string, data []byte,
 	}, 1, timeout)
 	if response == nil {
 		response = &ResponseData{
-			State: config.NO_MATCH,
-			Data:  []byte(config.NO_MATCH_MSG),
+			State: config.CONNECT_NO_MATCH,
+			Data:  []byte(config.CONNECT_NO_MATCH_MSG),
 		}
 	}
 	return