def ping_ip(ip):
"""
检查域名IP是否能Ping通
:param ip: 要ping的IP地址或域名
:return: 布尔值，表示是否可ping通
"""
try:
# 根据不同系统设置ping参数
param = "-n" if platform.system().lower() == "windows" else "-c"
command = ["ping", param, "4", ip]  # 发送4个ping包

output = subprocess.run(
command, 
stdout=subprocess.PIPE, 
stderr=subprocess.PIPE, 
text=True
)

if output.returncode == 0:
print(f"IP {ip} 可以Ping通")
return True
else:
print(f"IP {ip} 无法Ping通")
return False
except Exception as e:
print(f"Ping {ip} 时发生错误: {e}")
return False

def check_port(ip, port):
"""
检查域名IP的指定端口是否开放
:param ip: 要检查的IP地址或域名
:param port: 要检查的端口号
:return: 布尔值，表示端口是否开放
"""
try:
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.settimeout(5)  # 设置超时时间
result = sock.connect_ex((ip, port))

if result == 0:
print(f"IP {ip} 的端口 {port} 已开放")
return True
else:
print(f"IP {ip} 的端口 {port} 未开放")
return False
except Exception as e:
print(f"检查端口 {port} 时发生错误: {e}")
return False
finally:
sock.close()

def comprehensive_check(url, port=80):
"""
综合检测网址可用性
:param url: 要检测的网址
:param port: 要检查的端口号
:return: 字典，包含各项检测结果
"""
results = {
'url': url,
'port': port,
'website_accessible': False,
'ip_address': None,
'pingable': False,
'port_open': False
}

# 提取域名
domain = url.split("//")[-1].split("/")[0]

# 解析域名IP
try:
ip = socket.gethostbyname(domain)
results['ip_address'] = ip
print(f"域名 {domain} 的IP地址是: {ip}")
except socket.gaierror as e:
print(f"无法解析域名 {domain} 的IP地址，错误: {e}")
return results

# 检查网站访问
results['website_accessible'] = check_website(url)

# 检查Ping
results['pingable'] = ping_ip(ip)

# 检查端口
results['port_open'] = check_port(ip, port)

return results

def batch_check_urls(urls, delay=1):
"""
批量检测多个网址的可用性
:param urls: 网址列表
:param delay: 每个请求之间的延迟（秒）
:return: 结果列表
"""
results = []

for url in urls:
try:
start_time = time.time()
response = requests.get(url, timeout=5)
end_time = time.time()

response_time = round((end_time - start_time) * 1000, 2)  # 毫秒

if response.status_code == 200:
status = "可访问"
result_text = f"状态码: {response.status_code}, 响应时间: {response_time}ms"
else:
status = "不可访问"
result_text = f"异常状态码: {response.status_code}"

results.append([url, status, result_text])

except requests.RequestException as e:
results.append([url, "不可访问", f"错误: {str(e)}"])

time.sleep(delay)  # 延迟，防止请求过于频繁

# 以表格形式输出结果
print(tabulate(results, headers=['网址', '状态', '详细信息'], tablefmt='grid'))

return results

class WebsiteMonitor:
def init(self, urls, check_interval=300):
self.urls = urls
self.check_interval = check_interval
self.failure_reports = {}

def check_website(self, url):
"""检查单个网站"""
try:
response = requests.get(url, timeout=10)
return response.status_code == 200
except:
return False

def send_alert(self, url, is_recovery=False):
"""发送警报邮件（需要配置SMTP服务器）"""
if is_recovery:
subject = f"网站恢复通知: {url}"
body = f"网站 {url} 已于 {datetime.now()} 恢复访问"
else:
subject = f"网站宕机警报: {url}"
body = f"网站 {url} 于 {datetime.now()} 无法访问"

# 这里需要配置真实的SMTP服务器信息
msg = MIMEText(body)
msg['Subject'] = subject
msg['From'] = '[email protected]'
msg['To'] = '[email protected]'

try:
# 示例代码，实际使用时需要配置真实SMTP服务器
# with smtplib.SMTP('smtp.example.com', 587) as server:
#     server.login('username', 'password')
#     server.send_message(msg)
print(f"发送警报: {subject}")
except Exception as e:
print(f"发送邮件失败: {e}")

def monitor_loop(self):
"""监控循环"""
while True:
for url in self.urls:
is_accessible = self.check_website(url)
current_time = datetime.now()

# 检查状态变化
if url in self.failure_reports:
if is_accessible:
# 之前失败但现在恢复了
self.send_alert(url, is_recovery=True)
del self.failure_reports[url]
else:
if not is_accessible:
# 新出现的失败
self.failure_reports[url] = current_time
self.send_alert(url, is_recovery=False)

status = "可访问" if is_accessible else "不可访问"
print(f"{current_time} - {url} - {status}")

print(f"下一次检查将在 {self.check_interval} 秒后进行...")
time.sleep(self.check_interval)