C # сокеты TCP клиент / служба - PullRequest
Новая
       31

C # сокеты TCP клиент / служба

1 голос
/ 16 июля 2011

У меня есть клиент и сервер, с которыми я пытаюсь связаться друг с другом через локальную сеть (127.0.0.1).

Сначала я запускаю приложение «сервер»: 

public override void StartListening(int port, IPAddress address) {
            listenClient = new TcpListener(address, port);
            listenClient.Start();
            listenDelimiter = new IPEndPoint(address, port);
            if (listenThread != null) listenThread.Abort();
            listenThread = new Thread(new ParameterizedThreadStart(ListenThread));
            listenThread.IsBackground = true;
            listenThread.Start(port);
        }

        public void ListenThread(object o) {
            while (true) {
                try {
                    Socket incomingConnection = listenClient.AcceptSocket();
                    NetworkStream conStream = new NetworkStream(incomingConnection);
                    NetworkConnection nc = new NetworkConnection((incomingConnection.RemoteEndPoint as IPEndPoint).Port, (incomingConnection.RemoteEndPoint as IPEndPoint).Address);
                    Clients.Add(nc);
                    nc.MonitorTCPStream(conStream, this);
                }
                catch (Exception e) {
                    Console.WriteLine("Server has crashed. Networking error: " + e.Message);
                    Console.WriteLine("Will restart in 60 seconds...");
                    Thread.Sleep(60000);
                    StartListening(WORLDMAP_PORT, IPAddress.Any);
                }
            }
        }

Тогда «клиент»: 

try {
                    if (worldMapConnection != null) worldMapConnection.Close();
                    worldMapConnection = new TcpClient(address.ToString(), port);
                    worldMapConnection.Connect(WORLDMAP_ADDRESS, WORLDMAP_PORT);
                    if (worldMapThread != null) worldMapThread.Abort();
                    worldMapThread = new Thread(new ParameterizedThreadStart(WorldMapListener));
                    worldMapThread.IsBackground = true;
                    worldMapThread.Start();
                    if (Engine.Renderer.GetTopMenu().GetType() == typeof(MenuContainerConnecting)) Engine.Renderer.CloseMenu();
                }
                catch (System.Net.Sockets.SocketException e) {
                    if (Engine.Renderer.GetTopMenu().GetType() == typeof(MenuContainerConnecting)) Engine.Renderer.CloseMenu();
                    switch (e.SocketErrorCode) {
                        case SocketError.AddressAlreadyInUse: {
                                Engine.Renderer.OpenMenu(new MenuContainerNotice("Connection Error", "You already have a copy of the game connected to the game server.", "Okay"));
                            } break;
                        case SocketError.ConnectionRefused: {
                                Engine.Renderer.OpenMenu(new MenuContainerNotice("Connection Error", "The connection was refused by the game server.", "Okay"));
                            } break;
                        case SocketError.HostUnreachable: {
                                Engine.Renderer.OpenMenu(new MenuContainerNotice("Connection Error", "Could not connect to the game server. Check your internet connection.", "Okay"));
                            } break;
                        default: {
                                Engine.Renderer.OpenMenu(new MenuContainerNotice("Connection Error", "Could not connect to the game server. The server may be down for maintenance.", "Okay"));
                            } break;
                    }
                }
                catch (Exception) {
                    if (Engine.Renderer.GetTopMenu().GetType() == typeof(MenuContainerConnecting)) Engine.Renderer.CloseMenu();
                    Engine.Renderer.OpenMenu(new MenuContainerNotice("Connection Error", "Could not connect to the game server. An unknown error has occoured.", "Okay"));
                }

WORLDMAP_ADDRESS равен 127.0.0.1.Используемый порт одинаков для обоих приложений (8269).

Однако, когда я запускаю клиент, он перехватывает исключение System.Net.Sockets.SocketException, сообщение которого в отладчике выглядит так:

"Был сделан запрос на подключение к уже подключенному сокету 127.0.0.1:8269"

Я не понимаю этого, потому что мой сервер использует TcpListener, а клиент - TcpClient,Конечно, это не должно быть проблемой?

1 Ответ

5 голосов
/ 16 июля 2011

Эти две строки в клиенте являются избыточными: 

                worldMapConnection = new TcpClient(address.ToString(), port);
                worldMapConnection.Connect(WORLDMAP_ADDRESS, WORLDMAP_PORT);

Создание объекта TcpClient с адресом и портом достаточно для его подключения.

...