用GO实现IP门禁优化网络流量管理
作者：南丞 PFinalClub
这篇文章主要为大家介绍了用GO实现IP门禁优化网络流量管理,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
背景
最近在处理数据时，发现线上某个接口的访问量异常高。在初次设计时，并未对流量和访问量进行限制，因此对具体情况并不太清楚。为了解决这一问题，搞了一个简单的IP过滤脚本，并进行了记录。
之前搞IP过滤的时候, 使用了 PHP 的 workerman 来搞的 其实思路差不多一样:
$worker = new Worker('tcp:0.0.0.0:8080');
// 监听一个端口
$worker->count = 2;
// 设置多进程
$worker->onConnect = function (TcpConnection $connection) {
$list_ip = []; // ip 白名单
$remote_ip = $connection->getRemoteIp();
// 拦截IP
if (!in_array($remote_ip, $list_ip)) {
$connection->close();
}
// 放行连接，连接内部目标端口
$to_connection = new AsyncTcpConnection('tcp:127.0.0.1:80');
// 互相转发流量
$connection->pipe($to_connection);
$to_connection->pipe($connection);
$to_connection->connect();
}以上PHP代码创建了一个TCP监听器，在连接时进行IP过滤，并将流量转发到目标端口。
Go实现客户端
func main() {
listener, err := net.Listen("tcp", "127.0.0.1:8080")
if err != nil {
fmt.Println("Listen() failed, err: ", err)
return
}
defer func(listener net.Listener) {
_ = listener.Close()
}(listener)
for {
conn, err := listener.Accept()
if err != nil {
fmt.Println("Accept() failed, err: ", err)
continue
}
ip, _, _ := net.SplitHostPort(conn.RemoteAddr().String())
if !isIPAllowed(ip) {
fmt.Println("IP: ", ip, " is not allowed")
_ = conn.Close()
// TODO 对非白名单IP的连接，应该进行一些处理，比如记录日志
continue
}
fmt.Println("IP: ", ip, " is allowed")
go handleConn(conn) // 转发到固定的目标端口
}
}
func handleConn(conn net.Conn) {
defer func(conn net.Conn) {
_ = conn.Close()
}(conn)
target, err := net.Dial("tcp", "127.0.0.1:80")
if err != nil {
fmt.Println("Dial() failed, err: ", err)
return
}
defer func(target net.Conn) {
_ = target.Close()
}(target)
// 使用 copyAndCount 的并发执行版本（同时处理流向）
go copyAndCount(target, conn, &inTraffic)
copyAndCount(conn, target, &outTraffic) // Block until this copy is done
}代码流程
启动一个 TCP 监听器，等待客户端的连接请求。
当收到连接请求时，检查连接的 IP 是否在白名单中。
如果 IP 在白名单中，则开始处理连接，将连接的流量从输入流量和输出流量分别计入相应的计数器中。
处理连接时，使用 copyAndCount 函数并发地处理两个方向的流量。
处理完成后，关闭连接。
循环等待新的连接请求。
Go 实现管理面板
刚开始准备写这个IP过滤的时候,没有考虑太多,直接就写了,后来发现,这个东西,其实可以写一个管理面板,这样就方便管理了. 然后就 使用 Gin 来整了个面板
主要功能如下:
IP 白名单管理, 并且提供了一个接口, 给上面的 转发客户端来用
拦截统计,提供了一个接口, 给上面的客户端来上报拦截日志
流量统计, 包括输入流量和输出流量
流量限制, 包括输入流量限制和输出流量限制
后续完善
目前这个脚本只支持了一个端口的转发,没有实现多个端口的同时绑定转发
目前这个脚本没有实现对客户端的流量进行限制, 也没有实现对服务器的流量进行限制
总结
最后的最后,我也不知道我这玩意儿该叫啥, 因为, 其实, 它就是一个转发代理, 只不过, 它对流量进行了限制, 并且对流量进行了统计, 并且提供了管理面板.
以上就是用GO实现IP门禁优化网络流量管理的详细内容，更多关于GO IP门禁的资料请关注脚本之家其它相关文章！