浏览代码

redis工具类修改

maxiaoshan 2 年之前
父节点
当前提交
43437de319
共有 2 个文件被更改,包括 5 次插入4 次删除
  1. 4 4
      src/spiderutil/redis.go
  2. 1 0
      src/spiderutil/renderdownload.go

+ 4 - 4
src/spiderutil/redis.go

@@ -48,7 +48,7 @@ func RedisSet(code, key string, val interface{}, timeout int) bool {
 	defer util.Catch()
 	client := redisClientMap[code]
 	if client == nil {
-		fmt.Println("Redis Not Init")
+		fmt.Println("Redis Not Init Set")
 		return false
 	}
 	//err := client.Set(context.Background(), key, val, time.Duration(timeout)*time.Second).Err()
@@ -66,7 +66,7 @@ func RedisExist(code, key string) bool {
 	defer util.Catch()
 	client := redisClientMap[code]
 	if client == nil {
-		fmt.Println("Redis Not Init")
+		fmt.Println("Redis Not Init Exist")
 		return false
 	}
 	result, err := client.Exists(context.Background(), key).Result()
@@ -81,12 +81,12 @@ func RedisGet(code, key string) (string, error) {
 	defer util.Catch()
 	client := redisClientMap[code]
 	if client == nil {
-		fmt.Println("Redis Not Init")
+		fmt.Println("Redis Not Init Get")
 		return "", errors.New("Redis Not Init")
 	}
 	result, err := client.Get(context.Background(), key).Result()
 	if err != nil {
-		fmt.Println("Get Redis Error:", err, result)
+		//fmt.Println("Get Redis Error:", err, result)
 		return "", err
 	}
 	return result, err

+ 1 - 0
src/spiderutil/renderdownload.go

@@ -32,6 +32,7 @@ func DownloadByRender(href string) (contenthtml string) {
 	}
 	for i := 1; i <= 3; i++ {
 		if i != 1 {
+			time.Sleep(1 * time.Second)
 			param["proxy"] = GetProxyAddr(Config.ProxyAddr, Config.ProxyAuthor) //获取代理地址
 		}
 		resp, err := client.R().SetQueryParams(param).Get(Config.RenderAddr)