C#TCP应用程序将无法正常工作

问题描述 投票:2回答:1

我正在使用来自TcpClientTcpServerSystem.Net进行简单的聊天应用程序。

我把所有东西都放在我的电脑上,服务器与客户端通信,反之亦然。但是,当我尝试使用另一台PC连接到同一台服务器应用程序时(即使在与我的PC相同的子网上),该东西也无法正常工作。

我尝试通过我的路由器,防火墙进行端口转发,但仍然没有。

Can you see me website说连接被拒绝了。虽然!!有时它表示连接完全超时。

我不确定我的代码或我的电脑有什么问题,我真的很感谢那些在这方面比我更有经验的人的帮助。

以下是我的路由器中端口转发的配置:Here is the configuration for the port forwarding thing in my rounter

如果您需要客户端和服务器的代码,这里它们是:

附:我在底部的BeginConnect()部分对客户端进行了更改,以便更改我正在连接的IP地址

客户:

using System;
using System.Text;
using System.Windows.Forms;
using System.Net.Sockets;
using System.Net;

namespace TcpTest_Client_
{
    public partial class Form1 : Form
    {
        TcpClient client;
        IPAddress localIP = null;
        bool connected = false;

        public Form1()
        {
            InitializeComponent();
        }

        public void clientConnectCallback(IAsyncResult result)
        {
            try
            {
                client.EndConnect(result);
                Log("Connected to " + client.Client.RemoteEndPoint);
                connected = true;

                NetworkStream clientStream = client.GetStream();

                byte[] message = new byte[4096];
                int bytesRead;

                while (true)
                {
                    bytesRead = 0;
                    try
                    {
                        //blocks until a client sends a message
                        bytesRead = clientStream.Read(message, 0, 4096);
                    }
                    catch (Exception ex)
                    {
                        //a socket error has occured
                        Log(ex.Message);
                        break;
                    }
                    if (bytesRead == 0)
                    {
                        //the client has disconnected from the server
                        Log("Server on has disconnected");
                        break;
                    }

                    //message has successfully been received
                    UTF8Encoding encoder = new UTF8Encoding();
                    string bufferincmessage = encoder.GetString(message, 0, bytesRead);
                    Log("Server: " + bufferincmessage);
                }
            }
            catch (Exception ex)
            {
                Log(ex.Message);
            }
        }

        public void Log(string msg)
        {
            richTextBox1.BeginInvoke(new Action(
            () =>
            {
                richTextBox1.Text += msg + "\n";
            }));
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            foreach (IPAddress addr in Dns.GetHostAddresses(Dns.GetHostName()))
            {
                if (addr.AddressFamily == AddressFamily.InterNetwork)
                {
                    localIP = addr;
                    break;
                }
            }

            client = new TcpClient(AddressFamily.InterNetwork);
        }

        private void button2_Click(object sender, EventArgs e)
        {
            try
            {
                client.BeginConnect(IPAddress.Parse("109.252.107.144"), 1234, clientConnectCallback, client);
            }
            catch (Exception ex)
            {
                Log(ex.Message);
            }
        }

        private void button1_Click(object sender, EventArgs e)
        {
            if (connected)
            {
                UTF8Encoding encoder = new UTF8Encoding();
                NetworkStream clientStream = client.GetStream();

                byte[] stringToSend = new byte[richTextBox2.Text.Length];
                stringToSend = encoder.GetBytes(richTextBox2.Text);
                clientStream.Write(stringToSend, 0, stringToSend.Length);
            }
        }
    }
}

服务器:

using System;
using System.Collections.Generic;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace TcpTest
{
    public partial class Form1 : Form
    {
        private TcpListener server;
        private List<Thread> clientThreads = null;

        public Thread MainThread;

        public Form1()
        {
            InitializeComponent();
        }

        public void Log(string msg)
        {
            richTextBox1.BeginInvoke(new Action(
            () =>
            {
                richTextBox1.Text += msg + "\n";
            }));
        }

        public static string bufferincmessage;
        public void AcceptSocketPackets(object client)
        {
            TcpClient tcpClient = (TcpClient)client;
            NetworkStream clientStream = tcpClient.GetStream();

            byte[] message = new byte[4096];
            int bytesRead;

            while (true)
            {
                bytesRead = 0;
                try
                {
                    //blocks until a client sends a message
                    bytesRead = clientStream.Read(message, 0, 4096);
                }
                catch (Exception ex)
                {
                    //a socket error has occured
                    Log(ex.Message);
                    break;
                }
                if (bytesRead == 0)
                {
                    //the client has disconnected from the server
                    Log("Client on " + tcpClient.Client.RemoteEndPoint + " has disconnected from the server");
                    break;
                }

                //message has successfully been received
                UTF8Encoding encoder = new UTF8Encoding();
                bufferincmessage = encoder.GetString(message, 0, bytesRead);
                Log("Client from " + tcpClient.Client.RemoteEndPoint + ": " + bufferincmessage);

                string stringToSend = "You sent me: " + bufferincmessage;
                byte[] messageToSend = new byte[stringToSend.Length];
                messageToSend = encoder.GetBytes(stringToSend);
                clientStream.Write(messageToSend, 0, messageToSend.Length);
            }
        }

        public void SocketAcceptCallback(IAsyncResult result)
        {
            TcpClient newClient = server.EndAcceptTcpClient(result);

            Log("Accepted client on " + newClient.Client.RemoteEndPoint);

            clientThreads.Add(new Thread(new ParameterizedThreadStart(AcceptSocketPackets)));
            clientThreads[clientThreads.Count - 1].Start(newClient);

            server.BeginAcceptTcpClient(SocketAcceptCallback, server);
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            MainThread = Thread.CurrentThread;
            clientThreads = new List<Thread>();

            try
            {
                IPAddress localIP = null;
                foreach (IPAddress addr in Dns.GetHostAddresses(Dns.GetHostName()))
                {
                    if (addr.AddressFamily == AddressFamily.InterNetwork)
                    {
                        localIP = addr;
                        break;
                    }
                }

                localIP = IPAddress.Any;
                // could also use this:
                // server = new TcpListener(new IPEndPoint(IPAddress.Any, 1234));
                server = new TcpListener(new IPEndPoint(localIP, 1234));

                Log("Starting server on " + localIP + ":1234");

                server.Start(6);

                server.BeginAcceptTcpClient(SocketAcceptCallback, server);

                Log("Started server on " + localIP + ":1234");
            }
            catch (Exception ex)
            {
                Log(ex.Message);
            }
        }
    }

}
c# tcp system.net
1个回答
-1
投票

C ++给我这样的问题。尝试创建另一个项目,粘贴服务器代码并将其构建为Release x86。如果您更改构建目标并且我们的问题是相同的,Windows防火墙即使在关闭时也不允许服务器或客户端运行而没有任何异常。如果它不起作用我可能不知道答案。

© www.soinside.com 2019 - 2024. All rights reserved.