From 94ef15dd7256a7f27dee9aa2fdc379e1f41fea14 Mon Sep 17 00:00:00 2001 From: frxz751113 <156018267+frxz751113@users.noreply.github.com> Date: Thu, 29 Aug 2024 17:35:55 +0800 Subject: [PATCH] =?UTF-8?q?Update=20=E9=85=92=E5=BA=97=E6=BA=90.py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- py/酒店源.py | 96 ++++++++++++++++++++++++++++++++++------------------ 1 file changed, 63 insertions(+), 33 deletions(-) diff --git a/py/酒店源.py b/py/酒店源.py index 2a594b4..c808b44 100644 --- a/py/酒店源.py +++ b/py/酒店源.py @@ -85,27 +85,60 @@ for url in urls: # urls = list(set(urls_all)) # 去重得到唯一的URL列表 urls = set(urls_all) # 去重得到唯一的URL列表 x_urls = [] - -# 遍历网址列表，获取JSON文件并解析 -results = [] -for url in urls: - try: - response = requests.get(url, timeout=1) - json_data = response.content.decode('utf-8') - - lines = json_data.split('\n') - for line in lines: - line = line.strip() - if not line or ('udp' in line and 'rtp' in line): - continue - if 'hls' in line: - name, channel_url = line.split(',') - # 使用modify_urls函数替换IP地址和端口 - for modified_url in modify_urls(channel_url): - if is_url_accessible(modified_url): - # 替换频道名称中的特定文本 - if name: - name = name.replace("高清电影", "影迷电影") + 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 + with concurrent.futures.ThreadPoolExecutor(max_workers=100) as executor: + futures = [] + for url in urls: + url = url.strip() + modified_urls = modify_urls(url) + for modified_url in modified_urls: + futures.append(executor.submit(is_url_accessible, modified_url)) + for future in concurrent.futures.as_completed(futures): + result = future.result() + if result: + valid_urls.append(result) + for url in valid_urls: + print(url) + # 遍历网址列表,获取JSON文件并解析 + for url in valid_urls: + try: + # 发送GET请求获取JSON文件,设置超时时间为0.5秒 + json_url = f"{url}" + response = requests.get(json_url, timeout=1)################################ + json_data = response.content.decode('utf-8') + try: + # 按行分割数据 + lines = json_data.split('\n') + for line in lines: + if 'hls' in line and ('udp' not in line or 'rtp' not in line): #行中需包含m3u,但排除udp和trp + line = line.strip() + if line: + name, channel_url = line.split(',') + urls = channel_url.split('/', 3) + url_data = json_url.split('/', 3) + if len(urls) >= 3: + urld = (f"http://{urls[1]/{urls[2]/{urls[3]}") + else: + urld = (f"{urls[0]}//{url_data[2]}") + print(f"{name},{urld}") + if name and urld: + name = name.replace("高清电影", "影迷电影") name = name.replace("中央", "CCTV") name = name.replace("高清", "") name = name.replace("HD", "") @@ -208,24 +241,21 @@ for url in urls: name = name.replace("影视剧", "影视") name = name.replace("电视剧", "影视") name = name.replace("奥运匹克", "") - results.append(f"{name},{modified_url}") - break # 找到可访问的URL后跳出循环 - - except requests.exceptions.RequestException as e: - print(f"请求URL {url} 时发生错误: {e}") - -# 以下是处理results列表并写入文件的代码 + results.append(f"{name},{urld}") + except: + continue + except: + continue channels = [] for result in results: + line = result.strip() if result: channel_name, channel_url = result.split(',') channels.append((channel_name, channel_url)) - with open("iptv.txt", 'w', encoding='utf-8') as file: - for channel_name, channel_url in channels: - file.write(f"{channel_name},{channel_url}\n") - print(f"{channel_name},{channel_url}") - + for result in results: + file.write(result + "\n") + print(result) print("频道列表文件iptv.txt获取完成！")