perf: Removed the check for message body size to allow for larger messages.

Author: Kayne666

CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ## 1.0.6
 - Added an example of HTTP endpoint subscription in `topic_example.go`.
+- Added an example of HTTP authorization in `http_authorization.go`.
+- Removed the check for message body size to allow for larger messages.
 
 ## 1.0.5
 - update the minimum Go version declared in go.mod to fix build failures.

README-CN.md

@@ -1,6 +1,6 @@
 # Aliyun MNS Go SDK
 
-[![Github version](https://badgen.net/badge/color/1.0.5/green?label=version)](https://badgen.net/badge/color/1.0.5/green?label=version)
+[![Github version](https://badgen.net/badge/color/1.0.6/green?label=version)](https://badgen.net/badge/color/1.0.6/green?label=version)
 
 Aliyun MNS Go SDK 是 MNS 在 Go 编译语言的官方 SDK
 

errors.go

@@ -72,7 +72,7 @@ var (
 	ERR_MNS_MAX_MESSAGE_SIZE_RANGE_ERROR           = errors.TN(ALI_MNS_ERR_NS, 128, "max message size is not in range of (1024~65536)")
 	ERR_MNS_MSG_RETENTION_PERIOD_RANGE_ERROR       = errors.TN(ALI_MNS_ERR_NS, 129, "message retention period is not in range of (60~129600)")
 	ERR_MNS_MSG_VISIBILITY_TIMEOUT_RANGE_ERROR     = errors.TN(ALI_MNS_ERR_NS, 130, "message visibility timeout is not in range of (1~43200)")
-	ERR_MNS_MSG_POOLLING_WAIT_SECONDS_RANGE_ERROR  = errors.TN(ALI_MNS_ERR_NS, 131, "message poolling wait seconds is not in range of (0~30)")
+	ERR_MNS_MSG_POOLLING_WAIT_SECONDS_RANGE_ERROR  = errors.TN(ALI_MNS_ERR_NS, 131, "message polling wait seconds is not in range of (0~30)")
 	ERR_MNS_RET_NUMBER_RANGE_ERROR                 = errors.TN(ALI_MNS_ERR_NS, 132, "list param of ret number is not in range of (1~1000)")
 	ERR_MNS_QUEUE_ALREADY_EXIST_AND_HAVE_SAME_ATTR = errors.TN(ALI_MNS_ERR_NS, 133, "mns queue already exist, and the attribute is the same, queue name: {{.name}}")
 	ERR_MNS_BATCH_OP_FAIL                          = errors.TN(ALI_MNS_ERR_NS, 136, "mns queue batch operation fail")

example/http_authorization.go

@@ -38,14 +38,19 @@ func main() {
 
 	method := "POST"
 	path := "/api/test"
-	if authenticate(method, path, headers) {
+	if authenticateWithHeaderMap(method, path, toLowercaseKeys(headers)) {
 		fmt.Println("Signature verification succeeded")
 	} else {
 		fmt.Println("Signature verification failed")
 	}
 }
 
-func authenticate(method, path string, headers map[string]string) bool {
+func authenticateWithResponse(method, path string, resp *http.Response) bool {
+	headersMap := headersToMap(resp)
+	return authenticateWithHeaderMap(method, path, headersMap)
+}
+
+func authenticateWithHeaderMap(method, path string, headers map[string]string) bool {
 	// Get string to sign
 	var serviceHeaders []string
 	for k, v := range headers {
@@ -57,7 +62,7 @@ func authenticate(method, path string, headers map[string]string) bool {
 	sort.Strings(serviceHeaders)
 	serviceStr := strings.Join(serviceHeaders, "\n")
 	var signHeaderList []string
-	for _, key := range []string{"Content-md5", "Content-Type", "Date"} {
+	for _, key := range []string{"content-md5", "content-type", "date"} {
 		if val, ok := headers[key]; ok {
 			signHeaderList = append(signHeaderList, val)
 		} else {
@@ -119,7 +124,7 @@ func authenticate(method, path string, headers map[string]string) bool {
 	}
 
 	// 对Authorization字段做Base64解码
-	signatureBase64, ok := headers["Authorization"]
+	signatureBase64, ok := headers["authorization"]
 	if !ok {
 		fmt.Println("Authorization Header not found")
 		return false
@@ -143,3 +148,24 @@ func authenticate(method, path string, headers map[string]string) bool {
 
 	return true
 }
+
+func headersToMap(resp *http.Response) map[string]string {
+	headersMap := make(map[string]string)
+	for key, values := range resp.Header {
+		// 连接多个值为一个字符串，使用逗号分隔
+		// map 键值全小写
+		lowercaseKey := strings.ToLower(key)
+		headersMap[lowercaseKey] = strings.Join(values, ",")
+	}
+	return headersMap
+}
+
+// HTTP header 不区分大小写，将 map 的 keys 转换为全小写
+func toLowercaseKeys(input map[string]string) map[string]string {
+	output := make(map[string]string)
+	for k, v := range input {
+		lowercaseKey := strings.ToLower(k)
+		output[lowercaseKey] = v
+	}
+	return output
+}

queue_manager.go

@@ -40,14 +40,6 @@ func checkDelaySeconds(seconds int32) (err error) {
 	return
 }
 
-func checkMaxMessageSize(maxSize int32) (err error) {
-	if maxSize < 1024 || maxSize > 262144 {
-		err = ERR_MNS_MAX_MESSAGE_SIZE_RANGE_ERROR.New()
-		return
-	}
-	return
-}
-
 func checkMessageRetentionPeriod(retentionPeriod int32) (err error) {
 	if retentionPeriod < 60 || retentionPeriod > 1296000 {
 		err = ERR_MNS_MSG_RETENTION_PERIOD_RANGE_ERROR.New()
@@ -79,13 +71,10 @@ func NewMNSQueueManager(client MNSClient) AliQueueManager {
 	}
 }
 
-func checkAttributes(delaySeconds int32, maxMessageSize int32, messageRetentionPeriod int32, visibilityTimeout int32, pollingWaitSeconds int32) (err error) {
+func checkAttributes(delaySeconds int32, messageRetentionPeriod int32, visibilityTimeout int32, pollingWaitSeconds int32) (err error) {
 	if err = checkDelaySeconds(delaySeconds); err != nil {
 		return
 	}
-	if err = checkMaxMessageSize(maxMessageSize); err != nil {
-		return
-	}
 	if err = checkMessageRetentionPeriod(messageRetentionPeriod); err != nil {
 		return
 	}
@@ -110,7 +99,6 @@ func (p *MNSQueueManager) CreateQueue(queueName string, delaySeconds int32, maxM
 	}
 
 	if err = checkAttributes(delaySeconds,
-		maxMessageSize,
 		messageRetentionPeriod,
 		visibilityTimeout,
 		pollingWaitSeconds); err != nil {
@@ -144,7 +132,6 @@ func (p *MNSQueueManager) SetQueueAttributes(queueName string, delaySeconds int3
 	}
 
 	if err = checkAttributes(delaySeconds,
-		maxMessageSize,
 		messageRetentionPeriod,
 		visibilityTimeout,
 		pollingWaitSeconds); err != nil {

topic_manager.go

@@ -50,10 +50,6 @@ func (p *MNSTopicManager) CreateTopic(topicName string, maxMessageSize int32, lo
 		return
 	}
 
-	if err = checkMaxMessageSize(maxMessageSize); err != nil {
-		return
-	}
-
 	message := CreateTopicRequest{
 		MaxMessageSize: maxMessageSize,
 		LoggingEnabled: loggingEnabled,
@@ -77,10 +73,6 @@ func (p *MNSTopicManager) SetTopicAttributes(topicName string, maxMessageSize in
 		return
 	}
 
-	if err = checkMaxMessageSize(maxMessageSize); err != nil {
-		return
-	}
-
 	message := CreateTopicRequest{
 		MaxMessageSize: maxMessageSize,
 		LoggingEnabled: loggingEnabled,