오류가 왜 나오는지 모르겠어요 C# TCP

Question

using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Net;using System.Net.Sockets;using System.Runtime.CompilerServices;using System.Text;using System.Threading;using System.Threading.Tasks;using System.Timers;using System.Windows.Forms;using System.Windows.Forms.VisualStyles;namespace Server{ public partial class Server : Form { // 전역변수 private TcpListener Serverlistener1; private TcpListener Serverlistener2; private TcpClient Client1; private TcpClient Client2; private int Count; // list의 인덱스로 쓸 카운트 int[] list = new int[2]; // 포트에 담을 리스트 생성 private int ConnectedClients = 0; // 접속된 클라이언트 수를 추적하는 변수 private readonly object clientLock = new object(); // 쓰레드 안전을 위한 락 오브젝트 private int Number = 1; // 숫자를 100 까지 보낼 때 필요한 전역변수 private static System.Timers.Timer timer; // 시간마다 숫자를 보내기 위한 타이머 private bool BusyCheck = false; // Client2가 바쁜지 안바쁜지 체크할 논리 private bool StartCheck = true; // Client1이 시작했는지 안했는지 체크할 논리 private string Message; private string Number2; public Server() { try { InitializeComponent(); } catch(Exception ex) { MessageBox.Show("Server 기본생성자 오류입니다. " + ex.Message); } } ///

/// 2개의 포트번호를 받기 위한 클릭 이벤트 ///

private void btnPort_Click(object sender, EventArgs e) { try { string port = tbPort.Text.Trim(); if (Count == 2) { // 재입력시 다시 적용할 수 있게 초기화 Count = 0; list[0] = 0; list[1] = 0; } if (int.TryParse(port, out int input)) { if (input.ToString().Length < 4 || input.ToString().Length > 4) { MessageBox.Show("4자리만 입력하세요"); tbPort.Text = ""; } else { // 사용자에게 입력받은 포트 값을 받기 위한 리스트 list[Count++] = Int32.Parse(tbPort.Text); // 사용자에게 현재 1번 입력 받았으므로 if (list[1] == 0) { MessageBox.Show("한번 더 입력하세요."); } if (list[1] != 0) { // 포트 번호가 낮은 것은 Client1에 반영, 높은 것은 Client2에 반영 if (list[0] > list[1]) { lbPortValue1.Text = list[1].ToString(); lbPortValue2.Text = list[0].ToString(); } else { lbPortValue1.Text = list[0].ToString(); lbPortValue2.Text = list[1].ToString(); } } // 입력창 초기화 tbPort.Clear(); } } else { MessageBox.Show("정확한 값을 입력하세요."); } } catch (Exception ex) { MessageBox.Show("btnPort_Click에러입니다." + ex.Message); } } ///

/// 서버를 시작하는 클릭 이벤트 ///

private async void btnStart_Click(object sender, EventArgs e) { try { if (list[1] == 0) { MessageBox.Show("한번 더 입력하셔야 합니다."); } else { lbServer.Text = "서버가 시작되었습니다."; Serverlistener1 = new TcpListener(IPAddress.Parse("127.0.0.1"), Int32.Parse(lbPortValue1.Text)); Serverlistener2 = new TcpListener(IPAddress.Parse("127.0.0.1"), Int32.Parse(lbPortValue2.Text)); Serverlistener1.Start(); // 서버 실행 Serverlistener2.Start(); // 각 포트에서 클라이언트 연결을 수신하는 작업을 시작 Task acceptClient1Task = AcceptClientAsync(Serverlistener1, 1); Task acceptClient1Task2 = AcceptClientAsync(Serverlistener2, 2); await Task.WhenAll(acceptClient1Task, acceptClient1Task2); } } catch (Exception ex) { MessageBox.Show("btnStart_Click 에러입니다." + ex.Message); } } ///

/// 클라이언트로부터 데이터를 받기 및 접속자가 몇명인지 체크하는 함수 ///

private async Task AcceptClientAsync(TcpListener Serverlistener, int clientId) { try { while (true) { TcpClient client = await Serverlistener.AcceptTcpClientAsync(); // 쓰레드를 보호하기 위해 lock을 걸음 lock (clientLock) { ConnectedClients++; ClientCount(); // client 번호를 각 할당(각각에게 데이터를 보내기 위한 용) if (clientId == 1) Client1 = client; else if (clientId == 2) Client2 = client; } _ = HandleClient(client, clientId); } } catch (Exception ex) { MessageBox.Show("AcceptClientAsync 오류입니다. " + ex.Message); } } ///

/// 데이터를 다루는 함수 ///

private async Task HandleClient(TcpClient client, int clientId) { try { NetworkStream stream = client.GetStream(); // 여기 있는 stream으로 데이터를 주고 받을 수 있음 byte[] sizebuffer = new byte[64]; int read; while ((read = await stream.ReadAsync(sizebuffer, 0, sizebuffer.Length)) != 0) { // 받은 메시지를 가공 string message = Encoding.UTF8.GetString(sizebuffer, 0, sizebuffer.Length); // Client1, Client2에게 받은 메시지를 처리하는 if문 if (clientId == 1 && message.Contains("start!@#$") && BusyCheck == false) { // start!@#$를 지우고 ip, port만 나오게함 message = message.Replace("start!@#$", ""); Message = message; StartCheck = true; Thread thread = new Thread(() => StartTimer()); thread.Start(); BeginInvoke(new Action(() => lstServer.Items.Insert(0 , DateTime.Now + " Client1이 Start하라 했습니다."))); } else if (message.Contains("reset!@#$")) { Number = 1; BeginInvoke(new Action(() => lstServer.Items.Insert(0 , DateTime.Now + " Client1이 Reset하라 합니다."))); } else if (message.Contains("stop!@#$") && StartCheck == true) { StartCheck = false; if(BusyCheck == false) { StopTimer(); } BeginInvoke(new Action(() => lstServer.Items.Insert(0 , DateTime.Now + " Client1이 Stop하라 합니다."))); } else if (message.Contains("busy!@#$")) { if(StartCheck == true) { BusyCheck = true; StopTimer(); BeginInvoke(new Action(() => lstServer.Items.Insert(0 , DateTime.Now + " Client2가 바쁘다고???"))); } else // StartCheck == false일 때 { BusyCheck = true; BeginInvoke(new Action(() => lstServer.Items.Insert(0 , DateTime.Now + " Client2가 바쁘다고???"))); } } else if (message.Contains("resume!@#$")) { if(StartCheck == true) { BusyCheck = false; StartTimer(); BeginInvoke(new Action(() => lstServer.Items.Insert(0 , DateTime.Now + " Client2가 이제 보내도 된다고 합니다."))); } else { BusyCheck = false; BeginInvoke(new Action(() => lstServer.Items.Insert(0 , DateTime.Now + " Client2가 이제 보내도 된다고 합니다."))); } } } } catch (Exception ex) { MessageBox.Show("HandleClient 에러입니다." + ex.Message); } finally { client.Close(); lock (clientLock) { ConnectedClients--; ClientCount(); } } } ///

/// Client2에게 메시지 보내기용 ///

private async Task SendMessageToClient(TcpClient client, string message) { try { NetworkStream stream = client.GetStream(); var messageBuffer = Encoding.UTF8.GetBytes(message); BeginInvoke(new Action(() => lstServer.Items.Insert(0, DateTime.Now + " " + Number2))); await stream.WriteAsync(messageBuffer, 0, messageBuffer.Length); } catch (Exception ex) { MessageBox.Show("SendMessageToClient 에러입니다." + ex.Message); } } ///

/// Client 몇명인지 체크하는 함수 ///

private void ClientCount() { try { if (InvokeRequired) { BeginInvoke(new Action(ClientCount)); } else { lbClientCount.Text = ConnectedClients.ToString(); } } catch(Exception ex) { MessageBox.Show("ClientCount 오류입니다. " + ex.Message); } } ///

/// Client2에게 숫자를 시간마다 보내기 위한 함수 ///

private void StartTimer() { try { timer = new System.Timers.Timer(1000); // 1초마다 실행 timer.Elapsed += OnTimedEvent; timer.AutoReset = true; timer.Enabled = true; } catch(Exception ex) { MessageBox.Show("StartTimer 오류입니다. " + ex.Message); } } ///

/// 숫자 처리용 ///

private async void OnTimedEvent(Object source, ElapsedEventArgs e) { try { string message = "Number: " + Number++ + " "; Number2 = message; // 100이면 멈추게 하기 위해 if (Number == 101) { StopTimer(); Number = 1; } if (Client2 != null) { await SendMessageToClient(Client2, Message + " " + message); } } catch(Exception ex) { MessageBox.Show("OnTimedEvent 오류입니다. " + ex.Message); } } ///

/// 타이머를 멈추게 하기위한 함수 ///

private void StopTimer() { try { timer.Stop(); timer.Dispose(); timer = null; } catch(Exception ex) { MessageBox.Show("StopTimer 오류입니다. " + ex.Message); } } private void btnServerClose_Click(object sender, EventArgs e) { try { // 클라이언트 연결 해제 if (Client1 != null) { Client1.Close(); Client1 = null; } if (Client2 != null) { Client2.Close(); Client2 = null; } // 타이머 정지 if (timer != null) { timer.Stop(); timer.Dispose(); timer = null; } // 서버 리스너 정지 if (Serverlistener1 != null) { Serverlistener1.Stop(); Serverlistener1 = null; } if (Serverlistener2 != null) { Serverlistener2.Stop(); Serverlistener2 = null; } // 연결된 클라이언트 수 초기화 ConnectedClients = 0; ClientCount(); lbServer.Text = "서버가 종료되었습니다."; } catch(Exception ex) { MessageBox.Show("btnServerClose_Click 오류입니다. " + ex.Message); } } } }btnServerClose_Click을 클릭했을 때 AcceptClientAsync에서 삭제된 개체에 액세스 할 수 없습니다.가 뜨는데 저기로 버튼 클릭시 저기로 가는 경로가 아예없는데 왜 뜨는지 알 수 있을 까요 ???

kenu,전독시 · Answer

btnServerClose_Click 이벤트 핸들러 내에서 AcceptClientAsync 함수를 호출하지 않지만, AcceptClientAsync 함수 내에서 Client1과 Client2 객체를 사용하고 있습니다. 따라서 btnServerClose_Click에서 Client1과 Client2를 닫거나 초기화하는 코드가 실행되면, 이미 연결이 종료되었거나 초기화된 상태에서 AcceptClientAsync가 이들을 참조하려고 시도하게 됩니다. 이는 ObjectDisposedException 또는 NullReferenceException을 발생시킬 수 있습니다.이 문제를 해결하려면, btnServerClose_Click 이벤트 핸들러에서 AcceptClientAsync 함수가 실행되는 동안에 Client1과 Client2를 닫거나 초기화하는 대신, 먼저 AcceptClientAsync 함수가 완전히 종료될 때까지 기다린 후에 이러한 작업을 수행해야 합니다. 이를 위해 CancellationTokenSource와 CancellationToken을 사용하여 AcceptClientAsync 함수의 실행을 취소할 수 있도록 할 수 있습니다.다음은 수정된 코드 예시입니다:private CancellationTokenSource cts = new CancellationTokenSource(); private async void btnServerClose_Click(object sender, EventArgs e) { try { // 클라이언트 연결 해제 if (Client1!= null) { Client1.Close(); Client1 = null; } if (Client2!= null) { Client2.Close(); Client2 = null; } // 타이머 정지 if (timer!= null) { timer.Stop(); timer.Dispose(); timer = null; } // 서버 리스너 정지 if (Serverlistener1!= null) { Serverlistener1.Stop(); Serverlistener1 = null; } if (Serverlistener2!= null) { Serverlistener2.Stop(); Serverlistener2 = null; } // 연결된 클라이언트 수 초기화 ConnectedClients = 0; ClientCount(); lbServer.Text = "서버가 종료되었습니다."; } catch (Exception ex) { MessageBox.Show("btnServerClose_Click 오류입니다. " + ex.Message); } } private async Task AcceptClientAsync(TcpListener Serverlistener, int clientId, CancellationToken cancellationToken) { try { while (!cancellationToken.IsCancellationRequested) { TcpClient client = await Serverlistener.AcceptTcpClientAsync(); // 쓰레드를 보호하기 위해 lock을 걸음 lock (clientLock) { ConnectedClients++; ClientCount(); // client 번호를 각 할당(각각에게 데이터를 보내기 위한 용) if (clientId == 1) Client1 = client; else if (clientId == 2) Client2 = client; } _ = HandleClient(client, clientId); } } catch (Exception ex) { MessageBox.Show("AcceptClientAsync 오류입니다. " + ex.Message); } } 이렇게 하면, btnServerClose_Click에서 AcceptClientAsync 함수가 실행 중인 경우 해당 함수의 실행을 취소하고, 이후에 클라이언트 연결을 닫거나 초기화할 수 있습니다. 이렇게 하면 ObjectDisposedException 또는 NullReferenceException을 방지할 수 있습니다.from: https://www.phind.com/search?cache=j6p769w0keb3as9am10t5jq8

오류가 왜 나오는지 모르겠어요 C# TCP

1개의 답변

#windowsform 목록