[Пакеты] Socks4 прокси сервер C#

[Mebius]

Реализация простого сокс4 сервера на c#

Возможности
- быстрый запуск
- многопоточность
- редактирование трафика "на лету"/блокировка пакетов данных от сервера к клиенту и наоборот
- идентификация "хозяина" данных по ip/port

[Ссылки могут видеть только зарегистрированные пользователи. ]

[Ссылки могут видеть только зарегистрированные пользователи. ]

[Yukikaze]

у xkor'a выкладывал, и раз уж пошла такая пьянка то и здесь выложу Socks5 proxy

delegate void PacketHandlerDelegate(ref byte[] packet, int size);
class SocksProxy
{
    public PacketHandlerDelegate ServerPacketHandler;
    public PacketHandlerDelegate ClientPacketHandler;
    public int Port;

    public SocksProxy(int port)
    {
        this.Port = port;
    }

    public void Listen()
    {
        Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        listener.Bind(new IPEndPoint(IPAddress.Any, Port));
        listener.Listen(100);
        listener.BeginAccept(listener_Accept, listener);
    }

    private void listener_Accept(IAsyncResult ar)
    {
        byte[] buffer = new byte[2048];
        Socket listener = (Socket)ar.AsyncState;
        listener.BeginAccept(listener_Accept, listener);

        Socket _in = listener.EndAccept(ar);
        Socket _out = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

        _in.Receive(buffer, 0, buffer.Length, SocketFlags.None);

        if (buffer[0] == 5 && buffer[2] == 0)
        {
            buffer[1] = 0;
            _in.Send(buffer, 0, 2, SocketFlags.None);
            _in.Receive(buffer, 0, buffer.Length, SocketFlags.None);

            IPEndPoint remoteEndPoint = GetAddress(ref buffer);
            switch (buffer[1])
            {
                case 1:
                    _out.Connect(remoteEndPoint);
                    Console.WriteLine("Socket connected to " + remoteEndPoint);
                    break;

                case 2:
                    _out.Bind(remoteEndPoint);
                    Console.WriteLine("Socket binded to " + remoteEndPoint);
                    break;
            }

            buffer[1] = 0;
            _in.Send(buffer, 0, 10, SocketFlags.None);


            NetworkState state = new NetworkState(_in, _out, buffer);
            _out.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, out_Receive, state);
            _in.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, in_Receive, state);
        }
    }

    private IPEndPoint GetAddress(ref byte[] buf)
    {
        switch (buf[3])
        {
            case 1:
                string ip = buf[4] + "." + buf[5] + "." + buf[6] + "." + buf[7];
                int port = buf[8] * 256 + buf[9];
                return new IPEndPoint(IPAddress.Parse(ip), port);

            case 3:
                byte len = buf[8];
                string host = Encoding.ASCII.GetString(buf, 9, len);
                return HostResolve(host);

            default:
                return new IPEndPoint(0, 0);
        }
    }

    private IPEndPoint HostResolve(string hostname)
    {
        IPHostEntry host = Dns.GetHostEntry(hostname);
        foreach (IPAddress ip in host.AddressList)
        {
            if (ip.AddressFamily == AddressFamily.InterNetwork)
            {
                return new IPEndPoint(ip, 80);
            }
        }
        return new IPEndPoint(0, 0);
    }

    private void in_Receive(IAsyncResult ar)
    {
        NetworkState state = (NetworkState)ar.AsyncState;
        int received = state.In.EndReceive(ar);

        if (received > 0)
        {
            Console.WriteLine("{0} -> {1}", state.In.RemoteEndPoint, state.Out.RemoteEndPoint);
            Console.WriteLine(Utils.HexDump(state.Buffer, received));
            if (ClientPacketHandler != null)
                ClientPacketHandler(ref state.Buffer, received);
            state.Out.Send(state.Buffer, 0, received, SocketFlags.None);
            state.In.BeginReceive(state.Buffer, 0, state.Buffer.Length, SocketFlags.None, in_Receive,
                new NetworkState(state.In, state.Out, state.Buffer));
        }
        else
        {
            state.In.Shutdown(SocketShutdown.Both);
            Console.WriteLine("{0} отключен", state.In.RemoteEndPoint);
        }
    }

    private void out_Receive(IAsyncResult ar)
    {
        NetworkState state = (NetworkState)ar.AsyncState;
        int received = state.Out.EndReceive(ar);

        if (received > 0)
        {
            Console.WriteLine("{0} -> {1}", state.Out.RemoteEndPoint, state.In.RemoteEndPoint);
            if (ServerPacketHandler != null)
                ServerPacketHandler(ref state.Buffer, received);
            state.In.Send(state.Buffer, 0, received, SocketFlags.None);
            state.Out.BeginReceive(state.Buffer, 0, state.Buffer.Length, SocketFlags.None, out_Receive,
                new NetworkState(state.In, state.Out, state.Buffer));
        }
        else
        {
            state.Out.Shutdown(SocketShutdown.Both);
            Console.WriteLine("{0} отключен", state.Out.RemoteEndPoint);
        }
    }
    private class NetworkState
    {
        public byte[] Buffer;
        public Socket In;
        public Socket Out;
        public NetworkState(Socket sin, Socket sout, byte[] buff)
        {
            this.Buffer = buff;
            this.In = sin;
            this.Out = sout;
        }
    }
}

Только нужно обработку исключений добавить

[Yukikaze]

Ну ребят, как обычно. Бесполезные посты о инжекторах, или как покрасить кнопку в другой цвет обрастают комментариями за пару часов. Зато хорошие, годные, темы покрываются мхом...

[Sinyss]

Потому что школьники не видят где их можно применить, не говоря уже о том что я на 95% уверен что они даже структуру запомнить не смогут...

[warl0ck]

а для чего вы писали прокси сервер? если не секрет. просто мне в голову кроме хацкерских идей больше ничего не лезет.

[Yukikaze]

warl0ck, я трафик ла2 через него пропускал, расшифровывал/читал/зашифровывал

[Буянь]

Цитата: Сообщение от Sinyss Потому что школьники не видят где их можно применить, не говоря уже о том что я на 95% уверен что они даже структуру запомнить не смогут...

Вы так говорите, школьники, как будто это что-то плохое...

[Mebius]

Цитата: Сообщение от warl0ck а для чего вы писали прокси сервер? если не секрет. просто мне в голову кроме хацкерских идей больше ничего не лезет.

кому хацкнуть, кому свой адблок сделать, кто на что горазд )))

[Yukikaze]

Буянь, ну так мы же говорим только про тех школьников которые не знают, что с этим делать.

Mebius, и как, получилось сделать адблок?

[warl0ck]

Цитата: Сообщение от Yukikaze warl0ck, я трафик ла2 через него пропускал, расшифровывал/читал/зашифровывал

интересная задумка. делал что-то похожее, создал вебсервер(на локалхос), добавил вк в хостс и требовал денег

[Yukikaze]

warl0ck, ну так не прокси же D:
Можно было выцеплять http заголовки по типу GET vk.com HTTP/1.1 и добавлять форме авторизации js скрипт, который будет отправлять данные тебе на ресурс

[warl0ck]

Цитата: Сообщение от Yukikaze warl0ck, ну так не прокси же D:

ну почти. неправильный прокси

Цитата: Сообщение от Yukikaze Можно было выцеплять http заголовки по типу GET vk.com HTTP/1.1 и добавлять форме авторизации js скрипт, который будет отправлять данные тебе на ресурс

да... но это довольно таки хлопотно, к тому же подтверждение по телефону надо

[Mebius]

Цитата: Сообщение от Yukikaze Буянь, ну так мы же говорим только про тех школьников которые не знают, что с этим делать. Mebius, и как, получилось сделать адблок?

я не делал, я написал, проверил на хроме и выкинул в паблик

ща занимаюсь другой плюхой большой

[Ginrey]

подниму ка я тему задаваясь собственным вопросом. Разбираясь с Сокет серверами наткнулся на эту тему и позаимствовал пример Yukikaze по созданию Socks5 сервера.
Все работает, перехватывает с обоих сторон, но возникли проблемы, на которые я не могу найти ответ:

1)Бывает при большом кол-ве пакетов(как я понял) выскакивает ошибка:
"сервер принудительно разорвал соединение" (я перехватываю пакеты с игры ArcheAge, может кто слышал, и вот сразу после попытки зайти на перса это вылетает) и вместе с ней
"EndReceive может вызываться только один раз для каждой асинхронной операции"

2)Так же часто вылетает ошибка:
Запрос на отправку или получение данных был запрещен, т.к. сокет уже отключен в данном направлении на основании прежней запроса на его отключение

Вообще не соображу как исправить и с чем они связаны, помогите кто знает. Благодарю


Вот в этих двух процедурах ошибки вылезают . Чаще в исходящих запросах от клиента серверу

private void in_Receive(IAsyncResult ar)//ошибки во входящих(сервер -> клиент)
            {
               
                    NetworkState state = (NetworkState)ar.AsyncState;
                    int received = state.In.EndReceive(ar);
                    if (received > 0)
                    {                    
                        loglist.Invoke((MethodInvoker)delegate() { loglist.Items.Add("C -> S :  " + ByteToHex(state.Buffer, received)); });
                        if (ClientPacketHandler != null)
                            ClientPacketHandler(ref state.Buffer, received);
                        state.Out.Send(state.Buffer, 0, received, SocketFlags.None);//Запрос на отправку или получение данных был запрещен
                        state.In.BeginReceive(state.Buffer, 0, state.Buffer.Length, SocketFlags.None, in_Receive,
                            new NetworkState(state.In, state.Out, state.Buffer)); ara = ar;
                    }
                    else
                    {
                        state.In.Shutdown(SocketShutdown.Both);
                    }            
            }
 
 
            private void out_Receive(IAsyncResult ar)//и здесь (отправка пакетов на сервер)
            {
                
                    NetworkState state = (NetworkState)ar.AsyncState;
                    int received = state.Out.EndReceive(ar);//Удаленный хост принудительно разорвал существующее подключение или EndReceive может вызываться только один раз для каждой асинхронной операции.
                    if (received > 0)
                    {
                          loglist.Invoke((MethodInvoker)delegate() { loglist.Items.Add("S -> C :  " + ByteToHex(state.Buffer, received)); });
                        if (ServerPacketHandler != null)
                            ServerPacketHandler(ref state.Buffer, received);
                        state.In.Send(state.Buffer, 0, received, SocketFlags.None);  // Запрос на отправку или получение данных был запрещен
                        state.Out.BeginReceive(state.Buffer, 0, state.Buffer.Length, SocketFlags.None, out_Receive,
                            new NetworkState(state.In, state.Out, state.Buffer));
                    }
                    else
                    {
                        state.Out.Shutdown(SocketShutdown.Both);
                    }
                             
                }

[Argus_xD]

Ginrey а можешь скинуть свои наработки полностью?

Добавлено через 23 минуты
Дело в том что тебе нужно слушать два а то и три порта. Первый это логин сервер, а когда ты пытаешься зайти на перса то у тебя уже выбирается конкретный игровой сервер и соединение с логин сервером закрывается. Соответственно меняется IP и порт.

Добавлено через 3 часа 30 минут
Не знаю почему но у меня этот код не может перехватить коннект. Может объясните нубу что в него нужно добавить. Порт вроде верный указываю