Update IP更新.py

py/IP更新.py

@@ -6,9 +6,9 @@ import cv2  # 导入OpenCV库
 #本段代码更新文件方式-----追加写入
 #同省份多城市查询IP
 
-# 更新广东组播定义fofa链接列表
+# 更新广东组播定义fofa链接列表   #///////////////////////////////////////
 fofa_urls = [
-    'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJmb3NoYW4i',   # 佛山市
+    'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJmb3NoYW4i',   # 佛山市   #///////////////////////////////////////
     'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJHdWFuZ3pob3Ui',   # 广州市
     'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJzaGFudG91IiA%3D',  # 广东汕头
     'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJ6aGFvcWluZyI%3D',  # 广东肇庆
@@ -71,7 +71,7 @@ def update_and_write_ips(file_path, valid_ips_ports):
     except Exception as e:
         print(f"更新文件 {file_path} 时发生错误: {e}")
 # 定义组播地址和端口
-urls_udp = "/rtp/239.77.1.19:5146"
+urls_udp = "/rtp/239.77.1.19:5146"   #///////////////////////////////////////
 # 提取唯一的IP地址和端口号
 unique_ips_ports = extract_unique_ip_ports(fofa_urls)
 # 存储所有有效的IP地址和端口号
@@ -81,7 +81,7 @@ if valid_ips_ports:
     for valid_ip_port in valid_ips_ports:
         print(valid_ip_port)
     # 指定需要更新的本地文件路径
-    local_file_path = 'playlist/广东电信.txt'
+    local_file_path = 'playlist/广东电信.txt'   #///////////////////////////////////////
     # 更新文件中的IP地址并将每个IP写入新行
     update_and_write_ips(local_file_path, valid_ips_ports)
 else:
@@ -90,9 +90,9 @@ else:
 
 
 
-# 更新四川电信组播定义fofa链接列表
+# 更新四川电信组播定义fofa链接列表   #///////////////////////////////////////
 fofa_urls = [
-    'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJjaGVuZ2R1Ig%3D%3D',   # 成都
+    'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJjaGVuZ2R1Ig%3D%3D',   # 成都   #///////////////////////////////////////
     'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJYaWNoYW5nIg%3D%3D',   # 西昌
     'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJtaWFueWFuZyI%3D',  # 绵阳
     'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJsdXpob3Ui',  # 泸州
@@ -153,7 +153,7 @@ def update_and_write_ips(file_path, valid_ips_ports):
     except Exception as e:
         print(f"更新文件 {file_path} 时发生错误: {e}")
 # 定义组播地址和端口
-urls_udp = "/rtp/239.93.0.58:5140"
+urls_udp = "/rtp/239.93.0.58:5140"   #///////////////////////////////////////
 # 提取唯一的IP地址和端口号
 unique_ips_ports = extract_unique_ip_ports(fofa_urls)
 # 存储所有有效的IP地址和端口号
@@ -163,7 +163,7 @@ if valid_ips_ports:
     for valid_ip_port in valid_ips_ports:
         print(valid_ip_port)
     # 指定需要更新的本地文件路径
-    local_file_path = 'playlist/四川电信.txt'
+    local_file_path = 'playlist/四川电信.txt'   #///////////////////////////////////////
     # 更新文件中的IP地址并将每个IP写入新行
     update_and_write_ips(local_file_path, valid_ips_ports)
 else:
@@ -172,9 +172,9 @@ else:
 
 
 
-# 更新湖北电信组播定义fofa链接列表
+# 更新湖北电信组播定义fofa链接列表   #///////////////////////////////////////
 fofa_urls = [
-    'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJ3dWhhbiI%3D',   # 武汉
+    'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJ3dWhhbiI%3D',   # 武汉   #///////////////////////////////////////
     'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJodWFuZ3NoaSI%3D',   # 黄石
     'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJ4aWFuZ3lhbmci',  # 襄阳
     'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJqaW5nemhvdSI%3D',  # 荆州
@@ -237,7 +237,7 @@ def update_and_write_ips(file_path, valid_ips_ports):
     except Exception as e:
         print(f"更新文件 {file_path} 时发生错误: {e}")
 # 定义组播地址和端口
-urls_udp = "/rtp/239.254.96.96:8550"
+urls_udp = "/rtp/239.254.96.96:8550"   #///////////////////////////////////////
 # 提取唯一的IP地址和端口号
 unique_ips_ports = extract_unique_ip_ports(fofa_urls)
 # 存储所有有效的IP地址和端口号
@@ -247,7 +247,7 @@ if valid_ips_ports:
     for valid_ip_port in valid_ips_ports:
         print(valid_ip_port)
     # 指定需要更新的本地文件路径
-    local_file_path = 'playlist/湖北电信.txt'
+    local_file_path = 'playlist/湖北电信.txt'   #///////////////////////////////////////
     # 更新文件中的IP地址并将每个IP写入新行
     update_and_write_ips(local_file_path, valid_ips_ports)
 else:
@@ -255,4 +255,76 @@ else:
 
 
 
+# 更新北京联通组播定义fofa链接列表//////////////////////////////////////////////////////////////
+fofa_urls = [
+    'https://fofa.info/result?qbase64=InVkcHh5IiAmJiByZWdpb249ImJlaWppbmci'   # 北京
+]
 
+# 尝试从fofa链接提取IP地址和端口号，并去除重复项
+def extract_unique_ip_ports(fofa_urls):
+    all_unique_ips_ports = set()
+    for fofa_url in fofa_urls:
+        try:
+            response = requests.get(fofa_url, timeout=10)
+            html_content = response.text
+            # 使用正则表达式匹配IP地址和端口号
+            ips_ports = re.findall(r'(\d+\.\d+\.\d+\.\d+:\d+)', html_content)
+            all_unique_ips_ports.update(ips_ports)  # 将IP和端口号添加到集合中
+        except requests.RequestException as e:
+            print(f"请求 {fofa_url} 时发生错误: {e}")
+    return list(all_unique_ips_ports)
+# 检查视频流的可达性
+def check_video_stream_connectivity(ip_port, urls_udp):
+    video_url = f"http://{ip_port}{urls_udp}"
+    cap = cv2.VideoCapture(video_url)
+    if cap.isOpened():
+        cap.release()
+        return ip_port  # 如果打开成功，返回IP和端口号
+    else:
+        cap.release()
+        return None
+# 从本地文件读取内容
+def read_file_content(file_path):
+    try:
+        with open(file_path, 'r', encoding='utf-8') as file:
+            return file.read()
+    except FileNotFoundError:
+        print(f"文件 {file_path} 未找到。")
+    return None
+# 更新文件中的IP地址并将每个IP追加写入
+def update_and_write_ips(file_path, valid_ips_ports):
+    try:
+        original_content = read_file_content(file_path)
+        if original_content:
+            # 假设原文件中的IP地址格式为 http://IP:PORT
+            ip_port_pattern = r'http://(\d+\.\d+\.\d+:\d+)'
+            new_lines = []
+            for line in original_content.splitlines():
+                match = re.search(ip_port_pattern, line)
+                if match:
+                    # 找到一个IP地址，替换为有效的IP地址列表
+                    for valid_ip_port in valid_ips_ports:
+                        new_line = re.sub(ip_port_pattern, f'http://{valid_ip_port}', line)
+                        new_lines.append(new_line)
+            # 将更新后的内容追加到文件末尾
+            with open(file_path, 'a', encoding='utf-8') as file:
+                file.write("\n".join(new_lines) + "\n")
+            print(f"文件 {file_path} 已更新并追加保存。")
+    except Exception as e:
+        print(f"更新文件 {file_path} 时发生错误: {e}")
+# 定义组播地址和端口
+urls_udp = "/rtp/239.3.1.129:8008"   #/////////////////////////////////////////////////////////
+# 提取唯一的IP地址和端口号
+unique_ips_ports = extract_unique_ip_ports(fofa_urls)
+# 存储所有有效的IP地址和端口号
+valid_ips_ports = [ip_port for ip_port in unique_ips_ports if check_video_stream_connectivity(ip_port, urls_udp)]
+if valid_ips_ports:
+    print("找到的可访问视频流服务的IP地址和端口号：")
+    for valid_ip_port in valid_ips_ports:
+        print(valid_ip_port)
+    # 指定需要更新的本地文件路径
+    local_file_path = 'playlist/北京联通.txt'   #///////////////////////////////////////
+    # 更新文件中的IP地址并将每个IP写入新行
+    update_and_write_ips(local_file_path, valid_ips_ports)
+else:
+    print("没有找到可访问的视频流服务或者没有提取到IP地址和端口号。")