TCP, как я могу передать пакеты от моего клиента на сервер

Question

Итак, я работаю над созданием собственного прокси-сервера для моего игрового сервера.Пока что происходит, что я пытаюсь подключиться к своему серверу Terraria, и он говорит: Connecting.. Затем я запускаю серверное приложение, которое принимает входящие запросы на этот конкретный IP-адрес и порт, и выдает сообщение MessageBox с надписью "Connected", после чего игра запускается.с «Соединение ...» на «Соединение с сервером ...», но это застревает там, это, скорее всего, потому что я не перенаправляю трафик с моего прокси-сервера на мой сервер .. Верно?

Я пытался .Write() в поток, но я думаю, что пишу в неправильный поток, я пишу в поток, который принимает соединения, или я создаю новый поток для исходящего трафика?

public partial class MainWindow : Window
    {
        public static IPAddress remoteAddress = IPAddress.Parse("127.0.0.1");
        public TcpListener remoteServer = new TcpListener(remoteAddress, 7777);
        public TcpClient client = default(TcpClient);

        public TcpClient RemoteClient = new TcpClient("terraria.novux.ru", 7777);

        public MainWindow()
        {
            InitializeComponent();
        }

        private void BtnListen_OnClick(object sender, RoutedEventArgs e)
        {
            if (StartServer())
            {
                client = remoteServer.AcceptTcpClient();
                MessageBox.Show("Connected");
                var receivedBuffer = new byte[1024];

                //Should I write to this one instead?
                var clientStream = client.GetStream();

                var stream = RemoteClient.GetStream();

                while (client.Connected)
                    if (client.Connected)
                        if (client.ReceiveBufferSize > 0)
                        {
                            receivedBuffer = new byte[1024];
                            stream.Write(receivedBuffer, 0, receivedBuffer.Length);
                        }
            }
        }

        private bool StartServer()
        {
            try
            {
                remoteServer.Start();
                MessageBox.Show("Server Started...");
                return true;
            }
            catch (Exception exception)
            {
                MessageBox.Show(exception.ToString());
                throw;
            }
        }
    }

Answer 1

Упрощенная реализация может выглядеть следующим образом.

public class Program
{
    public static void Main(string[] args)
    {
        StartTcpListener("localhost", 9000);
    }

    private static byte[] SendReceiveRemoteServer(string host, int port, byte[] data)
    {
        try
        {
            // Create a TcpClient.
            // Note, for this client to work you need to have a TcpServer 
            // connected to the same address as specified by the server, port
            // combination.
            var client = new TcpClient(host, port);

            // Get a client stream for reading and writing.
            //  Stream stream = client.GetStream();

            var stream = client.GetStream();

            // Send the message to the connected TcpServer. 
            stream.Write(data, 0, data.Length);

            Console.WriteLine("Sent to server: {0}", Encoding.ASCII.GetString(data));

            // Receive the TcpServer.response.

            // Read the first batch of the TcpServer response bytes.
            var bytes = new byte[256];
            var allBytes = new List<byte>();
            var i = stream.Read(bytes, 0, bytes.Length);

            // Loop to receive all the data sent by the client.
            while (i != 0)
            {
                allBytes.AddRange(bytes);

                bytes = new Byte[256];
                i = stream.DataAvailable ? stream.Read(bytes, 0, bytes.Length) : 0;
            }

            Console.WriteLine("Received from server: {0}", Encoding.ASCII.GetString(data));

            // Close everything.
            stream.Close();
            client.Close();

            return allBytes.ToArray();
        }
        catch (ArgumentNullException e)
        {
            Console.WriteLine("ArgumentNullException: {0}", e);
        }
        catch (SocketException e)
        {
            Console.WriteLine("SocketException: {0}", e);
        }

        Console.WriteLine("\n Press Enter to continue...");
        return new byte[0];
    }

    private static void StartTcpListener(string host, int port)
    {
        TcpListener server = null;
        try
        {
            var ipHostInfo = Dns.GetHostEntry(host);
            var ipAddress = ipHostInfo.AddressList[0];

            // TcpListener server = new TcpListener(port);
            server = new TcpListener(ipAddress, port);

            // Start listening for client requests.
            server.Start();

            // Enter the listening loop.
            while (true)
            {
                Console.WriteLine("Waiting for a connection... ");

                // Perform a blocking call to accept requests.
                // You could also user server.AcceptSocket() here.
                var client = server.AcceptTcpClient();
                Console.WriteLine("Connected!");

                // Get a stream object for reading and writing
                var stream = client.GetStream();

                // Buffer for reading data
                var bytes = new Byte[256];
                var allBytes = new List<byte>();
                var i = stream.Read(bytes, 0, bytes.Length);

                // Loop to receive all the data sent by the client.
                while (i != 0)
                {
                    allBytes.AddRange(bytes);

                    bytes = new Byte[256];
                    i = stream.DataAvailable ? stream.Read(bytes, 0, bytes.Length) : 0;
                }

                if (allBytes.Count > 0)
                {
                    Console.WriteLine("Received from client: {0}", Encoding.ASCII.GetString(allBytes.ToArray()));

                    var received = SendReceiveRemoteServer("localhost", 11000, allBytes.ToArray());

                    // Send back a response.
                    stream.Write(received, 0, received.Length);
                    Console.WriteLine("Sent to client: {0}", Encoding.ASCII.GetString(received));
                }

                // Shutdown and end connection
                client.Close();
            }
        }
        catch (SocketException e)
        {
            Console.WriteLine("SocketException: {0}", e);
        }
        finally
        {
            // Stop listening for new clients.
            server.Stop();
        }

        Console.WriteLine("\nHit enter to continue...");
    }
}

Хотя необходимо внести улучшения:

• сделать его асинхронным
• заставить его работать с несколькими TcpClientsодновременно