diff --git a/py/IP更新.py b/py/IP更新.py index 3b4e4dc..3686cda 100644 --- a/py/IP更新.py +++ b/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地址和端口号。")