add retry

Author: 施凯伦

client.go

@@ -3,6 +3,7 @@ package xiaomipush
 import (
 	"encoding/json"
 	"errors"
+	"fmt"
 	"io/ioutil"
 	"net/http"
 	"net/url"
@@ -617,8 +618,15 @@ func (m *MiPush) doPost(url string, form url.Values) ([]byte, error) {
 	req.Header.Set("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8")
 	req.Header.Set("Authorization", "key="+m.appSecret)
 	client := &http.Client{}
+	tryTime := 0
+tryAgain:
 	resp, err = client.Do(req)
 	if err != nil {
+		fmt.Println("xiaomi push post err", err, tryTime)
+		tryTime += 1
+		if tryTime < PostRetryTimes {
+			goto tryAgain
+		}
 		return nil, err
 	}
 	result, err = m.handleResponse(resp)

constants.go

@@ -45,6 +45,10 @@ const (
 	TopicsAllURL = "/v1/topic/all" // 获取一个应用的某个用户的目前订阅的所有Topic
 )
 
+var (
+	PostRetryTimes = 3
+)
+
 // for future targeted push
 var (
 	BrandsMap = map[string]string{