NAT traversal
一个点对点通信工具库
对于对称网络，会启动一组UDP尝试打洞
fn main() {
// 参数一：对称网络类型时，指定用于打洞的端口数量，根据需要设置，较大的相对打洞速度越快，太大会导致网络压力从而引发丢包和限流
// 参数二：路由表记录的路由读超时时间
// 参数三：路由表记录的路由写超时时间
let (mut channel, mut punch, idle) = p2p_channel::boot::Boot::new::<String>(100, 9000, 0).unwrap();
// 设置本地网络类型，设置正确类型增加打洞成功概率
//channel.set_nat_type(NatType::Cone).unwrap();
{
// 空闲处理，添加的路由空闲时触发
std::thread::spawn(move || {
loop {
let (idle_status, id, route) = idle.next_idle().unwrap();
// channel.send_to_route()
// channel.remove_route(&id)
println!("{:?}", idle_status);
}
});
}
{
// 打洞处理
// 对方是锥形网络的打洞
std::thread::spawn(move || {
let buf = b"hello";
loop {
// 取出打洞的请求
let (id, nat_info) = punch.next_cone(None).unwrap();
// 尝试对nat_info记录的远端打洞
punch.punch(buf, id, nat_info).unwrap();
}
});
// 对方是对称型网络打洞
std::thread::spawn(move || {
let buf = b"hello";
loop {
let (id, nat_info) = punch.next_symmetric(None).unwrap();
punch.punch(buf, id, nat_info).unwrap();
}
});
}
// 与中继服务器沟通对端信息
//channel.send_to_addr(b"hello", "remote_server_ip".parse();
// 读取中继服务器的消息
//channel.recv_from(&mut buf, None).unwrap();
// 触发打洞
/* channel
.punch(
"peer_id".to_string(), //为对端设定的ID
vec![public_ip], //对端公网IP
public_port, //对端公网端口
0, //公共端口区间
local_ip, //对端本地IP
local_port, //对端本地端口
NatType::Symmetric, //对端的Nat网络类型
); */
// 接收数据处理
loop {
let mut buf = [0; 10240];
// 接受远端发过来的消息
let (len, route_key) = channel.recv_from(&mut buf, None).unwrap();
// Do something...
// 如果是对端发送过来的信息，那么加入路由，后续可以通过ID发送消息给对端
// channel.add_route("peer_id".to_string(),Route::from(route_key, 10, 64)) //加入路由，超时触发空闲
}
}