浅谈云函数的利用面

浅谈云函数的利用面
2021-05-06 10:52:16 Author: xz.aliyun.com(查看原文) 阅读量:136 收藏

最近看到一篇关于利用云函数做免费代理池的文章，觉得蛮有意思的，于是也花时间研究了并实现了云函数的几个有趣的利用方式。

HTTP 代理

原理

这是最为简单的利用方式。主要原理在于：

云函数可利用 API 网关触发器进行触发，接受来自客户端的数据
可以对外发包，类似于一个 SSRF

实现

因此一个 HTTP Proxy 的实现思路就很简单了。客户端挂上代理发送数据包，HTTP 代理服务器拦截数据包，提取 HTTP 报文相关信息，然后将报文以某种形式 POST 到云函数进行解析，云函数根据解析到的信息对目标发起请求，最终将结果一层一层返回。

流程如图所示：

实际效果

开启 HTTP 代理：

测试 IP 数量：

经过多次测试，5 线程 200 次访问 myip.ipip.net，分配 ip 数量在 60-70 左右变动。

SOCKS5 代理

有了 HTTP 代理，就不禁想再往前跨一步，针对 MySQL，RDP 等连接也希望保持匿名的时候，如何利用云函数做 SOCKS5 代理。

原理

云函数能对外发包，自然意味着 socket 可对外发起连接。因此我们完全可以将云函数当作一座桥梁，一侧对 VPS 发起连接，另一侧侧对目标服务器发起连接。

有了这座桥梁，稍微修改一下 SOCKS5 代理我们就可以发车上路了。

实现

正常 SOCKS5 代理请求的流程为服务端监听来自客户端的事件，每当客户端发起一个新的连接，服务端生成一个 socket A，并从数据包中解析出目标服务器的地址和端口，在本地对目标发起一个 socket 连接 B，同步两个 socket 的 IO 操作。

SOCKS5 主要分为 3 个步骤：

认证：对客户端发起的连接进行认证
建立连接：从客户端发起的连接中读取数据，获得目标服务器地址，并建立连接
转发数据：分别将来自客户端、服务器的数据转发给对方

用代码表示为如下：

def socks5_process(client: socket):
    """SocksServer 监听到新连接时的回调函数，将生成的 socket 作为参数 client 传入"""
    socks5_auth(client)
    target = socks5_connect(client)
    socks5_forward(client, target)


def socks5_connect(client: socket):
    # 省略协议细节处理
    address, port = extract_targe_info(client)
    target = socket.create_connection((address, port))

对比 SOCKS5 的流程和云函数建立连接的方式，可发现在 socks5_connect 中，我们需要的不再是对外主动发起连接，而是监听一个端口，等待云函数发起连接。

而为了让云函数发起连接，我们需要主动对云函数的 API 网关发送请求，触发云函数的执行，并将目标服务器信息附在 POST 数据包中。

# socks5.py
def socks5_process(client: socket):
    socks5_auth(client)
    socks5_connect(client)
    # 不在此处进行 forward 了
    # socks5_forward(client, target)

def socks5_connect(client: socket):
    ...
    address, port = client.read()
    requests.post(api_url, json={"host": address, "port": port})

def forward_process(target: socket):
    """ForwardServer(监听来自云函数的连接） 监听到新连接时的回调函数，将生成的 socket 作为参数 target 传入"""
    # 在此处进行 forward
    # 需要注意由该 client 触发产生 target 连接需要与该 client 对应
    socks5_forward(client, target)

服务端接收请求，并发起连接。

# server.py
def main_handler(event, context):
    data = json.loads(event["body"])
    socks5 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 解析出目标主机并发起连接
    socks5.connect((data["host"], data["port"]))

    forward = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 反向连接
    forward.connect((your_vps, forward_port))

    # 同步 socks5 和 forward 的 IO 操作
    ...