feat: upgrade go mod 1.21

Author: royee

.gitignore

@@ -17,3 +17,8 @@
 
 ### IDE
 .idea
+
+.claude/*.local.json
+.claude/docs
+.superpowers
+docs/superpowers

README.md

@@ -2,7 +2,13 @@
 
 HTTPSQS 队列客户端
 
-[基于HTTP协议的轻量级开源简单队列服务：HTTPSQS@张宴](http://blog.zyan.cc/httpsqs/)
+基于HTTP协议的轻量级开源简单队列服务：
+
+- HTTPSQS 说明：[HTTPSQS@张宴](http://blog.zyan.cc/httpsqs/)
+- Docker Hub: 
+    ```shell
+    docker pull save95/httpsqs:1.7.1
+    ```
 
 ```golang
 
@@ -58,6 +64,22 @@ import "github.com/gomooth/httpsqs"
 
 ```
 
+### Docker Compose
+
+```shell
+services:
+
+  httpsqs:
+    image: save95/httpsqs:1.7.1
+    ports:
+      - "1218:1218"
+    volumes:
+      - /etc/localtime:/etc/localtime
+      - ~/.local/databases/httpsqs:/opt/httpsqs/data
+    networks:
+      - local_net
+```
+
 ## Basic Examples
 
 ```golang

client.go

@@ -11,15 +11,29 @@ import (
 	"strings"
 	"time"
 
-	"github.com/save95/xerror"
+	"github.com/gomooth/xerror"
 )
 
 type client struct {
-	config *Config
+	config     *Config
+	httpClient *http.Client
 }
 
 func NewClient(config *Config) IClient {
-	return &client{config: config}
+	timeout := config.Timeout
+	if timeout <= 0 {
+		timeout = 5 * time.Second
+	}
+	return &client{
+		config: config,
+		httpClient: &http.Client{
+			Timeout: timeout,
+			Transport: &http.Transport{
+				MaxIdleConnsPerHost: 2,
+				IdleConnTimeout:     90 * time.Second,
+			},
+		},
+	}
 }
 
 func (c *client) Put(ctx context.Context, name, data string) (int64, error) {
@@ -168,30 +182,40 @@ func (c *client) SetSyncTime(ctx context.Context, name string, duration time.Dur
 
 func (c *client) httpGet(ctx context.Context, values url.Values, parseHeaders []string) (string, map[string]string, error) {
 	furl := fmt.Sprintf("http://%s/", c.config.Addr)
-	req, err := http.NewRequestWithContext(ctx, http.MethodGet, furl, nil)
-	if nil != err {
-		return "", nil, err
-	}
 
 	if len(c.config.Password) > 0 {
 		values.Set("auth", c.config.Password)
 	}
-	req.URL.RawQuery = values.Encode()
 
-	httpClient := http.DefaultClient
-	if c.config.Timeout > 0 {
-		httpClient.Timeout = c.config.Timeout
-	} else {
-		httpClient.Timeout = 5 * time.Second
-	}
-	resp, err := httpClient.Do(req)
-	if nil != err {
-		return "", nil, err
+	var lastErr error
+	maxAttempts := c.config.MaxRetries + 1
+	for attempt := 0; attempt < maxAttempts; attempt++ {
+		if attempt > 0 {
+			if err := c.waitBackoff(ctx, attempt); err != nil {
+				return "", nil, err
+			}
+		}
+
+		req, err := http.NewRequestWithContext(ctx, http.MethodGet, furl, nil)
+		if err != nil {
+			return "", nil, err
+		}
+		req.URL.RawQuery = values.Encode()
+
+		resp, err := c.httpClient.Do(req)
+		if err != nil {
+			lastErr = err
+			continue
+		}
+
+		return c.processResponse(resp, parseHeaders)
 	}
 
-	defer func() {
-		_ = resp.Body.Close()
-	}()
+	return "", nil, xerror.Wrap(lastErr, "httpsqs request failed after retries")
+}
+
+func (c *client) processResponse(resp *http.Response, parseHeaders []string) (string, map[string]string, error) {
+	defer resp.Body.Close()
 
 	bodyBytes, err := io.ReadAll(resp.Body)
 	if err != nil {
@@ -212,3 +236,16 @@ func (c *client) httpGet(ctx context.Context, values url.Values, parseHeaders []
 		return body, headerResult, nil
 	}
 }
+
+func (c *client) waitBackoff(ctx context.Context, attempt int) error {
+	backoff := time.Duration(1<<uint(min(attempt-1, 24))) * 200 * time.Millisecond
+	if backoff > 5*time.Second {
+		backoff = 5 * time.Second
+	}
+	select {
+	case <-ctx.Done():
+		return ctx.Err()
+	case <-time.After(backoff):
+		return nil
+	}
+}