WilliamSun的小窝

1.导入

最近看itdog的测速挺帅的，想着自己先做个类似的功能出来，搓了一份源码分享给大家

需求：

需要主服务器放行9090端口，节点服务器放行8080端口

操作系统Centos

需要有Python环境，没有的可以看Centos部署Python代码

Python需要安装requests，flask，json，subprocess这几个库

2.代码

1.主服务端代码

# -*- coding:utf-8 -*-
import requests
import subprocess
from flask import Flask, make_response, jsonify
import json
<p>app = Flask(<strong>name</strong>)</p>
<p>server=['1.1.1.1','2.2.2.2']#添加节点ip
serverch={'1.1.1.1':'香港','2.2.2.2':"美国"}#添加节点ip对应翻译，留空默认直接显示ip</p>
<p>@app.route('/ip=<ip>')
def hello_world(ip):  # put application's code here
def get_ping_result_check(ip):</p>
<pre><code>    command = 'fping -e '+ip
    p = subprocess.Popen([command],
                         stdin=subprocess.PIPE,
                         stdout=subprocess.PIPE,
                         stderr=subprocess.PIPE, shell=True)

    out = p.stdout.read().decode('utf-8')
    if out.find("unreachable") == -1:
        return True
    else:
        return False
reslist = dict.fromkeys(server)
for i in range(0,len(server)):
    if get_ping_result_check(server[i]):
        try:
            res=requests.get('http://'+server[i]+':9090/ip='+ip)
            if str(res).find('500')!=-1:
                reslist[server[i]]='连接超时'
            else:
                res=res.text
                reslist[server[i]]=res.replace('\n','')
        except Exception as e:
            reslist[server[i]] = '节点异常'
    else:
        reslist[server[i]]='节点异常'

reslist=str(reslist)
for i in range(len(server)):
    reslist=reslist.replace(server[i],serverch[server[i]])
reslist=eval(reslist)
response = make_response(json.dumps(reslist,ensure_ascii=False))
response.headers["Content-Type"] = "application/json;charset=UTF-8"
return response

if name == 'main': app.config['JSON_AS_ASCII'] = False app.run(host="0.0.0.0",port=8080)

server列表是添加服务器节点的IP

serverch字典是添加服务器节点翻译的

2.节点代码

import os
import subprocess
import re
from flask import Flask</p>
<p>app = Flask(<strong>name</strong>)</p>
<p>@app.route('/ip=<ip>')
def hello_world(ip):  # put application's code here
ping_results = []</p>
<pre><code>def get_ping_result(count,ip):

    command = 'fping -e '+ip
    p = subprocess.Popen([command],
                         stdin=subprocess.PIPE,
                         stdout=subprocess.PIPE,
                         stderr=subprocess.PIPE, shell=True)

    out = p.stdout.read().decode('utf-8')
    return out
back=get_ping_result('10000', ip)
back=back.split('(')[1]
back=back.replace(')','')
return back

if name == 'main': app.run(host="0.0.0.0",port=9090)

注意！节点端端口请不要改变，不然服务端会连不上

3.安装fping

fping节点服和主服都要安装

wget http://www.fping.org/dist/fping-3.13.tar.gz
tar xzvf fping-3.13.tar.gz
cd fping-3.13
./configure
make
make install

这段过程中可能会报错，没关系，不会有影响，在ssh一行一行输入进入就行了

安装好后输入fping -h出现

就代表成功安装了。

3.运行

运行主服务端和节点服务端代码，然后输入：http://主服务端ip:8080/ip=你要ping的ip或者域名

最后祝大家新年快乐，身体健康，万事如意