Update 酒店源.py

py/酒店源.py

@@ -28,50 +28,115 @@ from translate import Translator  # 导入Translator类,用于文本翻译
 ######################################################################################################################
 ######################################################################################################################
 ###########################################################ZHGX采集####################################################
-# 创建一个会话对象
+######################################################################################################################
-session = requests.Session()
+######################################################################################################################
-def is_url_accessible(url):
+import requests
-    try:
+
-        # 使用会话对象发送GET请求，设置超时时间为3秒
-        response = session.get(url, timeout=3)
-        if 200 <= response.status_code <= 401:
-            return url
-    except requests.exceptions.RequestException:
-        pass
-    return None
-# 异步检查URL是否可访问
-def check_urls(url_list, fixed_string):
-    valid_urls = []
-    with concurrent.futures.ThreadPoolExecutor(max_workers=10) as executor:
-        futures = {executor.submit(is_url_accessible, url + fixed_string): url for url in url_list}
-        for future in concurrent.futures.as_completed(futures):
-            result = future.result()
-            if result:
-                valid_urls.append(result)
-    return valid_urls
 urls = [
     "https://fofa.info/result?qbase64=IlpIR1hUViIgJiYgcmVnaW9uPSJndWFuZ2Rvbmci",  #广东
     "https://fofa.info/result?qbase64=IlpIR1hUViIgJiYgcmVnaW9uPSJoZW5hbiI%3D",  #河南
     "https://fofa.info/result?qbase64=IlpIR1hUViIgJiYgcmVnaW9uPSJoZW5hbiIgJiYgcG9ydD0iODA5MCI=",  #河南8090
     "https://fofa.info/result?qbase64=IlpIR1hUViIgJiYgcmVnaW9uPSJoZWJlaSI%3D", #河北
 ]
-# 固定的字符串
-fixed_string = "/ZHGXTV/Public/json/live_interface.txt"
 
-# 获取所有有效URL
+def modify_urls(url):
+    # 创建一个空列表用于存储修改后的 URL
+    modified_urls = []
+    # 找到 URL 中 IP 地址开始的索引位置，"//" 后两个字符开始为 IP 地址起始位置
+    ip_start_index = url.find("//") + 2
+    # 找到 URL 中 IP 地址结束的索引位置，从 ip_start_index 开始查找第一个 ":" 的位置
+    ip_end_index = url.find(":", ip_start_index)
+    # 找到 URL 中 IP 地址结束的索引位置，从 ip_start_index 开始查找第一个 ":" 的位置
+    base_url = url[:ip_start_index]
+    # 获取 URL 中的 IP 地址部分
+    ip_address = url[ip_start_index:ip_end_index]
+    # 获取 URL 中的端口部分
+    port = url[ip_end_index:]
+    # 定义一个字符串，表示 IP 地址的结尾部分
+    ip_end = "/ZHGXTV/Public/json/live_interface.txt"
+    # 遍历 1 到 255 的数字
+    for i in range(1, 256):
+        # 修改 IP 地址的最后一位数字
+        modified_ip = f"{ip_address[:-1]}{i}"
+        # 组合成新的 URL
+        modified_url = f"{base_url}{ip_address}{port}{ip_end}"
+        # 将新的 URL 添加到列表中
+        modified_urls.append(modified_url)
+    # 返回修改后的 URL 列表
+    return modified_urls
+
+def is_url_accessible(url):
+    try:
+        # 发送 GET 请求，设置超时时间为 3 秒
+        response = requests.get(url, timeout=3)
+        # 如果响应状态码在 200 到 401 之间（包括 200 和 401），则认为 URL 可访问
+        if 200 <= response.status_code <= 401:
+            return url
+    except requests.exceptions.RequestException:
+        # 如果请求过程中出现异常，不做任何处理，直接跳过
+        pass
+    return None
+
+# 创建一个空列表用于存储结果
 results = []
 for url in urls:
-    response = session.get(url)
+    # 发送 GET 请求获取 URL 的内容
+    response = requests.get(url)
+    # 获取响应的文本内容
     page_content = response.text
-    urls_all = re.findall(r"http://\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}:\d+", page_content)
+
-    unique_urls = set(urls_all)
+    # 查找所有符合指定格式的网址
-    valid_urls = check_urls(unique_urls, fixed_string)
+    pattern = r"http://\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}:\d+"   # 设置匹配的格式,如 http://8.8.8.8:8888
-    results.extend(valid_urls)
+    # 使用正则表达式在页面内容中查找所有符合格式的 URL
-# 关闭会话对象
+    urls_all = re.findall(pattern, page_content)
-session.close()
+    # urls = list(set(urls_all))  # 去重得到唯一的URL列表
-# 打印所有有效的URL
+    urls = set(urls_all)  # 去重得到唯一的URL列表
-for url in results:
+    x_urls = []
-    print(url)
+    for url in urls:  # 对urls进行处理,ip第四位修改为1,并去重
+        url = url.strip()
+        # 找到 URL 中 IP 地址开始的索引位置，"//" 后两个字符开始为 IP 地址起始位置
+        ip_start_index = url.find("//") + 2
+        # 找到 URL 中 IP 地址结束的索引位置，从 ip_start_index 开始查找第一个 ":" 的位置
+        ip_end_index = url.find(":", ip_start_index)
+        # 找到 IP 地址中第一个 "." 的位置
+        ip_dot_start = url.find(".") + 1
+        # 找到 IP 地址中第二个 "." 的位置
+        ip_dot_second = url.find(".", ip_dot_start) + 1
+        # 找到 IP 地址中第三个 "." 的位置
+        ip_dot_three = url.find(".", ip_dot_second) + 1
+        # 获取 URL 的基础部分，即从开头到 IP 地址开始的部分
+        base_url = url[:ip_start_index]  # http:// or https://
+        # 获取 URL 中的 IP 地址部分，截取到第三个 "." 的位置
+        ip_address = url[ip_start_index:ip_dot_three]
+        # 获取 URL 中的端口部分
+        port = url[ip_end_index:]
+        # 定义一个字符串，表示 IP 地址的结尾部分为 "1"
+        ip_end = "1"
+        # 修改 IP 地址的最后一位为 "1"
+        modified_ip = f"{ip_address}{ip_end}"
+        # 组合成新的 URL
+        x_url = f"{base_url}{modified_ip}{port}"
+        # 将新的 URL 添加到列表中
+        x_urls.append(x_url)
+    urls = set(x_urls)  # 去重得到唯一的URL列表
+    valid_urls = []
+    #   多线程获取可用url
+    with concurrent.futures.ThreadPoolExecutor(max_workers=100) as executor:
+        futures = []
+        for url in urls:
+            url = url.strip()
+            # 获取修改后的 URL 列表
+            modified_urls = modify_urls(url)
+            for modified_url in modified_urls:
+                # 提交任务，检查每个修改后的 URL 是否可访问
+                futures.append(executor.submit(is_url_accessible, modified_url))
+        for future in concurrent.futures.as_completed(futures):
+            result = future.result()
+            if result:
+                # 如果 URL 可访问，将其添加到有效 URL 列表中
+                valid_urls.append(result)
+    for url in valid_urls:
+        print(url)
     # 遍历网址列表,获取JSON文件并解析
     for url in valid_urls:
         try:
@@ -257,57 +322,69 @@ urls = [
     #"https://fofa.info/result?qbase64=ImlwdHYvbGl2ZS96aF9jbi5qcyIgJiYgY291bnRyeT0iQ04iICYmIGNpdHk9Imd1aWdhbmci",  #贵港
     #"https://fofa.info/result?qbase64=ImlwdHYvbGl2ZS96aF9jbi5qcyIgJiYgY291bnRyeT0iQ04iICYmIHBvcnQ9IjgxODEii",#8181
 ]
-    # 定义一个函数来检查URL是否可访问
+def modify_urls(url):
+    modified_urls = []
+    ip_start_index = url.find("//") + 2
+    ip_end_index = url.find(":", ip_start_index)
+    base_url = url[:ip_start_index]
+    ip_address = url[ip_start_index:ip_end_index]
+    port = url[ip_end_index:]
+    ip_end = "/iptv/live/1000.json?key=txiptv"
+    for i in range(1, 256):
+        modified_ip = f"{ip_address[:-1]}{i}"
+        modified_url = f"{base_url}{modified_ip}{port}{ip_end}"
+        modified_urls.append(modified_url)
+    return modified_urls
+
 def is_url_accessible(url):
     try:
-        # 发送GET请求，设置超时时间为3秒
         response = requests.get(url, timeout=3)
-        # 如果响应状态码在200到401之间（包括200和401），则认为URL可访问
         if 200 <= response.status_code <= 401:
             return url
     except requests.exceptions.RequestException:
-        # 如果请求过程中出现异常，不做任何处理，直接跳过
         pass
     return None
 
-# 创建一个空列表用于存储结果
 results = []
-
-# 固定的字符串，你希望添加到每个URL的末尾
-fixed_string = "/iptv/live/1000.json?key=txiptv"
-
 for url in urls:
-    # 发送GET请求获取URL的内容
     response = requests.get(url)
-    # 获取响应的文本内容
     page_content = response.text
-
     # 查找所有符合指定格式的网址
-    pattern = r"http://\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}:\d+"  # 设置匹配的格式，如http://8.8.8.8:8888
+    pattern = r"http://\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}:\d+"  # 设置匹配的格式,如http://8.8.8.8:8888
-    # 使用正则表达式在页面内容中查找所有符合格式的URL
     urls_all = re.findall(pattern, page_content)
-    # 去重得到唯一的URL列表
+    # urls = list(set(urls_all))  # 去重得到唯一的URL列表
-    unique_urls = set(urls_all)
+    urls = set(urls_all)  # 去重得到唯一的URL列表
-
+    x_urls = []
+    for url in urls:  # 对urls进行处理,ip第四位修改为1,并去重
+        url = url.strip()
+        ip_start_index = url.find("//") + 2
+        ip_end_index = url.find(":", ip_start_index)
+        ip_dot_start = url.find(".") + 1
+        ip_dot_second = url.find(".", ip_dot_start) + 1
+        ip_dot_three = url.find(".", ip_dot_second) + 1
+        base_url = url[:ip_start_index]  # http:// or https://
+        ip_address = url[ip_start_index:ip_dot_three]
+        port = url[ip_end_index:]
+        ip_end = "1"
+        modified_ip = f"{ip_address}{ip_end}"
+        x_url = f"{base_url}{modified_ip}{port}"
+        x_urls.append(x_url)
+    urls = set(x_urls)  # 去重得到唯一的URL列表
     valid_urls = []
-    # 多线程获取可用url
+    #   多线程获取可用url
     with concurrent.futures.ThreadPoolExecutor(max_workers=100) as executor:
         futures = []
-        for original_url in unique_urls:
+        for url in urls:
-            # 在原始URL后面添加固定字符串
+            url = url.strip()
-            new_url = original_url + fixed_string
+            modified_urls = modify_urls(url)
-            # 提交任务，检查每个新构造的URL是否可访问
+            for modified_url in modified_urls:
-            futures.append(executor.submit(is_url_accessible, new_url))
+                futures.append(executor.submit(is_url_accessible, modified_url))
         for future in concurrent.futures.as_completed(futures):
             result = future.result()
             if result:
-                # 如果URL可访问，将其添加到有效URL列表中
                 valid_urls.append(result)
-    # 将找到的有效URL添加到结果列表中
+    for url in valid_urls:
-    results.extend(valid_urls)
+        print(url)
-# 打印所有有效的URL
-for url in results:
-    print(url)
 
     # 遍历网址列表,获取JSON文件并解析
     for url in valid_urls: