วิธีที่เหมาะสมในการปิดซ็อกเก็ต C # ใน. NET Core 3.1 คืออะไร?

Jan 30 2021

ปัญหา

ฉันพยายามจัดการกับการตัดการเชื่อมต่อสำหรับแอพของฉันและวิธีการใดก็ตามที่ฉันพยายามจนถึงตอนนี้ล้มเหลวฉันพยายามตัดการเชื่อมต่อจากฝั่งเซิร์ฟเวอร์ฉันพยายามตัดการเชื่อมต่อจากฝั่งไคลเอ็นต์ แต่ได้รับปัญหาทั้งสองด้านสิ่งที่ฉันพยายามบรรลุที่นี่คือ เพื่อยกเลิกการเชื่อมต่อแอปผ่านคำสั่ง QUIT โดยไม่ต้องปิดจากไอคอนปิดเนื่องจากมีข้อยกเว้น

client.cs

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

namespace MessengerConsole
{
class Client
{
    static string username;
    static int port = 8888;
    static IPAddress clientIP;
    static Socket serverSocket;
    static Thread processThread;
    static bool connected = false;

    static string GetIp()
    {
        Console.WriteLine("Type the server ip:");
        String clientIP = Console.ReadLine();
        Console.WriteLine("Client IP: " + clientIP);
        //return clientIP;
        //temp solution
        return "192.168.0.106";
    }

    static void printSession()
    {
        Console.Clear();
        Console.WriteLine("//=====================================================");
        Console.WriteLine("//                       Session Details               ");
        Console.WriteLine("//                    =====================");
        Console.WriteLine("//                    IP: " + clientIP + "\n//                    Time: " + DateTime.Now);
        Console.WriteLine("//=====================================================");
    }
    static void clientReceiver()
    {
        while (true)
        {
            Thread.Sleep(500);
            byte[] buffer = new byte[300];
            int rece = serverSocket.Receive(buffer, 0, buffer.Length, 0);
            Array.Resize(ref buffer, rece);
            if (connected == false)
            {
                Console.WriteLine("[" + DateTime.Now.ToString() + "] " + Encoding.Default.GetString(buffer) + " Connected!");
                connected = true;
            }

            else
            {

                if (Encoding.Default.GetString(buffer) == "QUIT")
                {
                    //Quit
                    Console.WriteLine("Server Shutdown");
                    serverSocket.Shutdown(SocketShutdown.Both);
                    serverSocket.Close();
                   
                }
                else
                {
                    Console.WriteLine("[" + DateTime.Now.ToString() + "] " + Encoding.Default.GetString(buffer));
                }

            }
        }
    }



    public static void StartClient()
    {
        processThread = new Thread(clientReceiver);
        Console.WriteLine("Please enter your name");
        username = Console.ReadLine();
        clientIP = IPAddress.Parse(GetIp());  //Returns IP from GetIP()
        Console.WriteLine("Please enter HostPort");
        //string portString = Console.ReadLine();
        //temp port
        string portString = "80";
        try
        {
            port = Convert.ToInt32(portString);
        }
        catch
        {
            port = 8888;
        }
        try
        {

            serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            serverSocket.Connect(new IPEndPoint(clientIP, port));
            processThread.Start();
            byte[] name = Encoding.Default.GetBytes(username);
            
            //Send Name
            serverSocket.Send(name);
           // byte[] data = Encoding.Default.GetBytes("<" + username + "> Connected");
            //serverSocket.Send(data, 0, data.Length, 0);
            printSession();
            while (serverSocket.Connected)
            {
                //byte[] sdata = Encoding.Default.GetBytes("<" + username + ">" + Console.ReadLine());
                byte[] sdata = Encoding.Default.GetBytes(Console.ReadLine());
                if(Encoding.Default.GetString(sdata) == "QUIT")
                {
                    serverSocket.Send(sdata, sdata.Length, 0);
                    serverSocket.Shutdown(SocketShutdown.Both);
                    serverSocket.Disconnect(true);
                    serverSocket.Close();
                }

                else
                {
                    serverSocket.Send(sdata, 0, sdata.Length, 0);
                }

            }
        }
        catch (Exception e)
        {
            Console.ForegroundColor = ConsoleColor.Red;
            Console.WriteLine(e.Message);
            Console.ForegroundColor = ConsoleColor.White;
        }

    }
}
}

server.cs

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

namespace MessengerConsole
{
class Server
{

    //Server Socket
    static Socket serverSocket;
    //Client Socket
    static Socket clientSocket;

    //Other Variables
    static int port = 8888;
    static IPAddress serverIP;
    static Thread processThread;
    static string username;
    static bool connected = false;
    //Function returns IP Address
    static string GetIp()
    {
        //Computer Name
        string hostname = Dns.GetHostName();

        /*The IPHostEntry class associates a Domain Name System (DNS) host name with an array of aliases and 
         * an array of matching IP addresses.
         */
        IPHostEntry ipentry = Dns.GetHostEntry(hostname);

        //The Address
        IPAddress[] ipAddress = ipentry.AddressList;

        return ipAddress[ipAddress.Length - 1].ToString();
    }

    static void printSession()
    {
        Console.Clear();
        Console.WriteLine("//=====================================================");
        Console.WriteLine("//                       Session Details               ");
        Console.WriteLine("//                    =====================");
        Console.WriteLine("//                    You are hosting the server");
        Console.WriteLine("//                    Time: " + DateTime.Now);
        Console.WriteLine("//=====================================================");
    }
    //Receive
    static void serverReciever()
    {
        while (true)
        {
            Thread.Sleep(500);
            byte[] buffer = new byte[300];
            int rece = clientSocket.Receive(buffer, 0, buffer.Length, 0);
            Array.Resize(ref buffer, rece);

            if (connected == false)
            {
                Console.WriteLine("[" + DateTime.Now.ToString() + "] " + Encoding.Default.GetString(buffer) + " Connected!");
                connected = true;
            }

            else
            {
                if(Encoding.Default.GetString(buffer) == "QUIT")
                {
                    //Quit
                    Console.WriteLine("Client disconnected from the chat");
                    clientSocket.Shutdown(SocketShutdown.Both);
                    clientSocket.Close();
                }
                else
                {
                    Console.WriteLine("[" + DateTime.Now.ToString() + "] " + Encoding.Default.GetString(buffer));
                }

            }
        }
    }



    public static void StartServer()
    {
        //Thread
        processThread = new Thread(serverReciever);

        //Display
        Console.WriteLine("Your Local Ip is " + GetIp());
        Console.WriteLine("Please enter your name");
        username = Console.ReadLine();
        Console.WriteLine("Please enter HostPort");
        //  string portString = Console.ReadLine();
        //temp solution
        string portString = "80";
        try
        {
            port = Convert.ToInt32(portString);
        }
        catch
        {
            port = 8888;
        }

        try
        {
            //GetIp returns string
            serverIP = IPAddress.Parse(GetIp());
            //TCP Socket
            serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            serverSocket.Bind(new IPEndPoint(serverIP, port));
            serverSocket.Listen(0);

            //Server Socket listening for client requests
            clientSocket = serverSocket.Accept();
            printSession();
            processThread.Start();
            byte[] name = Encoding.Default.GetBytes(username);
            clientSocket.Send(name);
            while (true)
            {
                byte[] sdata = Encoding.Default.GetBytes(Console.ReadLine());
                clientSocket.Send(sdata, 0, sdata.Length, 0);
            }
        }
        catch
        {
            Console.ForegroundColor = ConsoleColor.Red;
            Console.WriteLine("Server already open!");
            Console.ForegroundColor = ConsoleColor.White;
        }
    }
}
}

นี่คือข้อผิดพลาดที่ฉันได้รับ

ข้อยกเว้นที่ไม่สามารถจัดการได้ System.ObjectDisposedException: ไม่สามารถเข้าถึงอ็อบเจ็กต์ที่ถูกกำจัด ชื่อวัตถุ: 'System.Net.Sockets.Socket' ที่บัฟเฟอร์ System.Net.Sockets.Socket.Receive (Byte [], Int32 offset, Int32 size, SocketFlags socketFlags, SocketError & errorCode) ที่ System.Net.Sockets.Socket.Receive (Byte [] buffer, Int32 offset, Int32 size, SocketFlags socketFlags) ที่ MessengerConsole.Client.clientReceiver () ใน C: \ Users \ MessengerConsoleAppV2 \ MessengerConsole \ Client.cs: บรรทัดที่ 42 ที่ System.Threading.ThreadHelper.ThreadStart_Context (สถานะวัตถุ) ที่ System.Threading.ExecutionContext.RunInternal (ExecutionContextecutionContext , การเรียกกลับ ContextCallback, สถานะวัตถุ) - จุดสิ้นสุดของการติดตามสแต็กจากตำแหน่งก่อนหน้าซึ่งมีการโยนข้อยกเว้น - ที่ System.Threading.ExecutionContext.RunInternal (ExecutionContextecutionContext, ContextCallback callback,สถานะวัตถุ) ที่ System.Threading.ThreadHelper.ThreadStart ()

ฉันลองใช้ Socket.Disconnect (), Socket.Close (), Socket.Dispose () และทั้งหมดให้ผลลัพธ์เหมือนกัน

แก้ไข:

เพิ่มreturnใน

if(Encoding.Default.GetString(sdata) == "QUIT")
            {
                serverSocket.Send(sdata, sdata.Length, 0);
                serverSocket.Shutdown(SocketShutdown.Both);
                serverSocket.Close();
                return;
            }

ผลลัพธ์ไม่มีข้อผิดพลาดทางฝั่งเซิร์ฟเวอร์ แต่ไคลเอ็นต์ยังคงแสดงข้อยกเว้นของอ็อบเจ็กต์ที่ถูกกำจัดที่ถูกเข้าถึง

ข้อยกเว้นที่ไม่สามารถจัดการได้ System.ObjectDisposedException: ไม่สามารถเข้าถึงอ็อบเจ็กต์ที่ถูกกำจัด ชื่อวัตถุ: 'System.Net.Sockets.Socket' ที่บัฟเฟอร์ System.Net.Sockets.Socket.Receive (Byte [], Int32 offset, Int32 size, SocketFlags socketFlags, SocketError & errorCode) ที่ System.Net.Sockets.Socket.Receive (Byte [] buffer, Int32 offset, Int32 size, SocketFlags socketFlags) ที่ MessengerConsole.Client.clientReceiver () ใน C: \ Users \ MessengerConsoleAppV2 \ MessengerConsole \ Client.cs: บรรทัดที่ 44 ที่ System.Threading.ThreadHelper.ThreadStart_Context (สถานะวัตถุ) ที่ System.Threading.ExecutionContext.RunInternal (ExecutionContextecutionContext , การเรียกกลับ ContextCallback, สถานะวัตถุ) - จุดสิ้นสุดของการติดตามสแต็กจากตำแหน่งก่อนหน้าซึ่งมีการโยนข้อยกเว้น - ที่ System.Threading.ExecutionContext.RunInternal (ExecutionContextecutionContext, ContextCallback callback,สถานะวัตถุ) ที่ System.Threading.ThreadHelper.ThreadStart ()

คำตอบ

1 AlexeyRumyantsev Jan 30 2021 at 22:00

ในทุกตำแหน่งของรหัสที่เกี่ยวข้องกับQUITคุณเพียงปิดและทิ้งซ็อกเก็ต แต่ไม่กลับมาจากลูปที่ไม่มีที่สิ้นสุดที่ให้บริการซ็อกเก็ตนี้ ฉันคิดว่าสแต็กนี้ถูกโยนในการทำซ้ำครั้งต่อไปเมื่อConnectedคุณสมบัติได้รับการประเมินบนซ็อกเก็ตที่ถูกทิ้งลองเพิ่มreturnคำสั่งหลังจากที่คุณปิดซ็อกเก็ต