云服务器AWD平台搭建

阅读原文时间：2022年05月29日阅读：1

开学后实验室来了几个新同学，在线上CTF方面大家一直在持续学习，但AWD模式的CTF我们练习并不多，所以准备搭建一个AWD平台用于实验室成员的线下赛攻防练习。

最开始的是防灾科技大学的线下AWD靶场：

https://github.com/glzjin/20190511_awd_docker

但是靶场没有计分板和组队显示等功能，又找了一下：

https://github.com/zhl2008/awd-platform

腾讯云服务器没有翻墙，从github上面拉取下来有495MB，本来想从本地电脑上下载后上传到云服务器上使用 unzip 命令进行解压，但 unzip 的速度也很慢，重新寻找解决办法：

https://zhuanlan.zhihu.com/p/112697807

如果只是为了clone加速，完成到第四步就可以了：

我的码云拉取地址在：

https://gitee.com/Cl0udG0d/awd-platform

接着在云服务器上面使用 git clone

现在的速度就很快了：

花三十秒的时间下载完毕。

cd awd-platform/

目录中有AWD线下环境手册文档，但是在搭建的时候还是会有很多不完善的地方，综合网上的多篇博客共同搭建并优化。

AWD环境中的机器按照功能分为几种类型：

Check_Server：

服务检查服务器，用于判定选手维护的服务是否可用，如果不可用，则会扣除相应的分数，不开启任何端口，需要与flag服务器通信

简单来说这台机器的作用就是检查靶机宕机没有
Flag_Server：

选手提交flag的服务器，并存储选手的分数，开启80端口

简单来说这台机器就是获取到flag后的提交对象，用于加分
Web_Server：

选手连接的服务器，选手需要对其进行维护，并尝试攻击其他队伍的机器，通常开启80端口，22端口，并将端口映射到主机。

这个就是我们每个队伍所要操作的机器。

比赛逻辑拓补：

云服务器首先安装docker，有很多师傅写过安装docker的文章，跳过这一步。

接着下载镜像

docker pull zhl2008/web_14.04

接着按照参考文章里面的：

所以我们将镜像的名字修改：

docker tag zhl2008/web_14.04 web_14.04

接着我们按照文档里面来进行操作：

后面的数字是靶机的数量，也就是参赛队伍的数量，我们先复制所有队伍的比赛文件夹和启动比赛（这里启动的是2个参赛队）：

python batch.py web_yunnan_simple 2
python start.py ./ 2

这里使用的靶机是 web_yunnan_simple ，至此，靶机就已经可以访问了，因为是在一个服务器上运行了多个docker，靶机的端口映射规则为：

如图：

各个靶机的ssh密码在目录文件夹下的pass.txt文件中，如图

其ssh端口映射规则为：

但是我们还没有启动 check 脚本，而项目中原来的check脚本是不能用的，我们需要进行一些修改，这个规则要根据自己的环镜自己编写，总体思路就是判断页面是否存在，存在就加一分，不存在就减一分

网上有修改过后的 check 脚本，同时可以看到 flag-server 和 check-server 所映射的端口

使用大佬们的check.py脚本

#!/usr/bin/env python

-- coding:utf8 --

'''

'''
import hashlib
import base64

sleep_time = 300
debug = True
headers = {"User-Agent":"Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/60.0.3112.90 Safari/537.36"}

import time
import httplib
import urllib2
import ssl

my_time = 'AAAA'
__doc__ = 'http(method,host,port,url,data,headers)'
flag_server = '172.17.0.1'
key = '744def038f39652db118a68ab34895dc'
hosts = open('host.lists','r').readlines()
user_id = [host.split(':')[0] for host in hosts]
hosts = [host.split(':')[1] for host in hosts]
port = 80

def http(method,host,port,url,data,headers):
con=httplib.HTTPConnection(host,port,timeout=2)
if method=='post' or method=='POST':
headers['Content-Length']=len(data)
headers['Content-Type']='application/x-www-form-urlencoded'
con.request("POST",url,data,headers=headers)
else:
headers['Content-Length'] = 0
con.request("GET",url,headers=headers)
res = con.getresponse()
if res.getheader('set-cookie'):
#headers['Cookie'] = res.getheader('set-cookie')
pass
if res.getheader('Location'):
print "Your 302 direct is: "+res.getheader('Location')
a = res.read()
con.close()
return a

def https(method,host,port,url,data,headers):
url = 'https://' + host + ":" + str(port) + url
req = urllib2.Request(url,data,headers)
response = urllib2.urlopen(req)
return response.read()

def get_score():
res = http('get',flag_server,8080,'/score.php?key=%s'%key,'',headers)
print res
user_scores = res.split('|')
print "******************************************************************"
res = ''

print res
print "******************************************************************"
return user_scores

def write_score(scores):
scores = '|'.join(scores)
res = http('get',flag_server,8080,'/score.php?key=%s&write=1&score=%s'%(key,scores),'',headers)
if res == "success":
return True
else:
print res
raise ValueError

class check():

def index\_check(self):  
    res = http('get',host,port,'/index.php?file=%s'%str(my\_time),'',headers)  
    if 'perspi' in res:  
        return True  
    if debug:  
        print "\[fail!\] index\_fail"  
    return False

def server_check():
try:
a = check()
if not a.index_check():
return False
return True
except Exception,e:
print e
return False

game_round = 0
while True:

scores = get\_score()  
scores = \[\]  
print "--------------------------- round %d -------------------------------"%game\_round  
for host in hosts:  
    print "---------------------------------------------------------------"  
    host = host\[:-1\]  
    if server\_check():  
        print "Host: "+host+" seems ok"  
        scores.append("0")  
    else:  
        print "Host: "+host+" seems down"  
        scores.append("-10")  
game\_round += 1  
write\_score(scores)  
time.sleep(sleep\_time)

按照文档启动check服务

docker attach check_server/

python check.py

使用的腾讯云服务器，这一步的时候出错了

连接超时，查看 check.py 源代码

game_round = 0
while True:

scores = get\_score()  
scores = \[\]  
print "--------------------------- round %d -------------------------------"%game\_round  
for host in hosts:  
    print "---------------------------------------------------------------"  
    host = host\[:-1\]  
    if server\_check():  
        print "Host: "+host+" seems ok"  
        scores.append("0")  
    else:  
        print "Host: "+host+" seems down"  
        scores.append("-10")  
game\_round += 1  
write\_score(scores)  
time.sleep(sleep\_time)

运行的是这一段

while循环调用，一段时间延迟后进行服务可用性的检查，延迟时间由sleep_time决定

get_score() 函数报错，查看报错行：

res = http('get',flag_server,8080,'/score.php?key=%s'%key,'',headers)

调用了自写页面请求函数 http

而 flag_server 为全局变量：

my_time = 'AAAA'
__doc__ = 'http(method,host,port,url,data,headers)'
flag_server = '172.17.0.1'
key = '744def038f39652db118a68ab34895dc'
hosts = open('host.lists','r').readlines()
user_id = [host.split(':')[0] for host in hosts]
hosts = [host.split(':')[1] for host in hosts]
port = 80

为：

flag_server = '172.17.0.1'

其靶机IP在host.lists文件中，ssh链接，查看其中一台靶机的IP

可以看到云服务器上靶机的内网IP实际上为 172.18.0.2，所以才会报错超时。

修改 flag_server

修改host.lists文件

重新启动并进入容器：

可以看到现在 check已经正常了，但是host.lists文件是自动生成的，为了避免每次都修改，我们需要修改其自动化生成的脚本

简单寻找了一下，初始化文件在start.py里面

如图，host.lists文件写入的IP根据我们的情况修改为 172.18.0

使用

python stop_clean.py

命令清理环境重新启动服务，查看是否正常启动

python batch.py web_yunnan_simple 3//复制3个web_yunnan_simple的靶机，数值可改
python start.py ./ 3 //启动三个docker靶机和check服务器、flag_server服务器。数值可改

docker attach check_server //链接裁判机，检查是否正常
python check.py

现在check裁判机就正常了

此外需要注意的是：

检测页面是否存活是在check.py中的 check类中，对于不同的环境，我们需要编写不同的类方法来进行检测服务是否宕机

这里面只写了index_check函数，有python功底的朋友对于不同的CMS可以进行每个页面的check。

该AWD平台另一个问题是可以无限交flag，即一个flag可以无限刷分，详情和修改方法参考：

https://www.cnblogs.com/Triangle-security/p/11332223.html#

个人感觉修改方法不是很优雅hhh，因为需要自己提前去运行该脚本，这段时间有空想想其他的解决办法，脚本如下：

#!/usr/bin/env python

#coding:UTF-8

import time

import os

print int(time.time())

Unix_time = int(time.time())

print time.ctime(Unix_time)

while True:

time_his = []

time_list = ["00","05","10","15","20","25","30"]

for i in time_list:

dt = "2019-04-28 10:"+str(i)+":00"

time_his.append(dt)

a = time_his[0]

b = time_his[1]

c = time_his[2]

d = time_his[3]

e = time_his[4]

f = time_his[5]

g = time_his[6]

time_stamp = [a,b,c,d,e,f,g]

for k in time_stamp:

h = open("time.txt", 'w+')

timeArray = time.strptime(k, "%Y-%m-%d %H:%M:%S")

timestamp = time.mktime(timeArray)

print (int(timestamp))

data = (int(timestamp))

separated = '|'

zero = '0'

print >>h,(zero),(separated),(data),(separated),(zero),(separated),(data),(separated),(zero),(separated),(zero),(separated),(data),(separated),(zero),(separated),(zero),

# 0|data|0|data|0|0|data|0|0

h.close()

time.sleep(300)