weiai/linker
1
0
Fork 0
mirror of https://github.com/snltty/linker.git synced 2025-12-20 02:16:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

sync

Browse Source
This commit is contained in:
snltty
2024-08-05 11:23:09 +08:00
parent 961414e194
commit e4fff0dad7
2 changed files with 38 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
linker.tun.test/Program.cs
View File

@@ -1,6 +1,7 @@
using System.Buffers.Binary;
using System.Net;
using System.Runtime.InteropServices;
using System.Text;
namespace linker.tun.test
{
@@ -10,7 +11,7 @@ namespace linker.tun.test
static void Main(string[] args)
{
linkerTunDeviceAdapter = new LinkerTunDeviceAdapter();
linkerTunDeviceAdapter.Initialize("linker111", new LinkerTunDeviceCallback());
linkerTunDeviceAdapter.Initialize("linker0", new LinkerTunDeviceCallbackTCPUDP());
linkerTunDeviceAdapter.Setup(IPAddress.Parse("192.168.55.2"), 24, 1416);
if (string.IsNullOrWhiteSpace(linkerTunDeviceAdapter.Error))
@@ -21,7 +22,38 @@ namespace linker.tun.test
}
}
public sealed class LinkerTunDeviceCallback : ILinkerTunDeviceCallback
public sealed class LinkerTunDeviceCallbackTCPUDP : ILinkerTunDeviceCallback
{
public async Task Callback(LinkerTunDevicPacket packet)
{
TCPUDPRead(packet);
await Task.CompletedTask;
}
private unsafe void TCPUDPRead(LinkerTunDevicPacket packet)
{
if (packet.Version != 4) return;
Memory<byte> writableMemory = MemoryMarshal.AsMemory(packet.IPPacket);
fixed (byte* ptr = writableMemory.Span)
{
Console.WriteLine($"IPv{packet.Version} {ptr[9]}");
//6tcp 17udp
if (ptr[9] == 6 || ptr[9] == 17)
{
IPAddress sourceIP = new IPAddress(packet.SourceIPAddress.Span);
IPAddress distIP = new IPAddress(packet.DistIPAddress.Span);
ushort sourcePort = *(ushort*)(ptr + 20);
ushort distPort = *(ushort*)(ptr + 22);
Console.WriteLine($"IPv{packet.Version}:[{(ptr[9] == 6 ? "TCP" : "UDP")}] {new IPEndPoint(sourceIP, sourcePort)}->{new IPEndPoint(distIP, distPort)}");
//Program.linkerTunDeviceAdapter.Write(writableMemory);
}
}
}
}
public sealed class LinkerTunDeviceCallbackICMP : ILinkerTunDeviceCallback
{
public async Task Callback(LinkerTunDevicPacket packet)
{
@@ -33,6 +65,7 @@ namespace linker.tun.test
Memory<byte> writableMemory = MemoryMarshal.AsMemory(packet.IPPacket);
fixed (byte* ptr = writableMemory.Span)
{
//icmp && request
if (ptr[9] == 1 && ptr[20] == 8)
{

3
linker/plugins/sforward/SForwardStartup.cs
View File

@@ -7,6 +7,7 @@ using Microsoft.Extensions.DependencyInjection;
using System.Reflection;
using linker.plugins.sforward.proxy;
using linker.libs;
using linker.tun;
namespace linker.plugins.sforward
{
@@ -63,6 +64,8 @@ namespace linker.plugins.sforward
LoggerHelper.Instance.Info($"listen server forward web in {config.Data.Server.SForward.WebPort}");
}
LoggerHelper.Instance.Info($"listen server forward tunnel in {string.Join("-", config.Data.Server.SForward.TunnelPortRange)}");
}
}
}