[C#] TCP 채팅 프로그램 #2 Client 구현

해당 게시글은 아래 개발환경을 사용하여 작성됨

IDE : VisualStudio 2022

Framework : .NET 7.0

Language : C# 11

 

※ 이전 게시글

[C#] TCP 채팅 프로그램 #1 Server 구현

 

1. TCP

• TCP에 대한 내용은 아래 게시글을 참고

[C#] 네트워크 통신 - TCP&UDP

 

2. 프로젝트 생성

• 앞서 생성했던 TCP_Project 솔루션에 TCP_Client 프로젝트를 생성
  • 프로젝트명 : TCP_Client
  • 솔루션명 : TCP_Project
  • 프레임워크 : .NET 7.0

 

Step 1. 프로젝트 구성

Step 2. 프레임워크 선택

 

3. 디자인

• 아래 이미지와 같이 컨트롤러들을 배치한다.

Form1 디자인

 

4. C# - TCP Client 코드 작성하기

• 4.1 ~ 4.10를 참고하여 TCP Client 코드를 작성한다.

 

4.1 네임스페이스 작성

• 해당 프로젝트에서 사용할 네임스페이스를 선언한다.

using System.Diagnostics;
using System.Net;
using System.Net.Sockets;
using System.Text;

 

4.2 전역변수 선언

• 해당 프로젝트에서 사용할 전역 변수들을 선언한다.

TcpClient clientSocket = new TcpClient(); // 소켓
NetworkStream stream = default(NetworkStream);
string message = string.Empty;
private int PORT = 5000; // 포트 정보
private string USER_NAME = string.Empty;
private static string CONNECT_STATUS = "DISCONNECT"; // 연결상태

 

4.3 IP&Port 설정

• Server의 IP와 Port 정보를 설정한다.
• IP와 Port를 사용하여 TCP Server와 연결한다.

private int PORT = 5000; // 포트 정보

/// <summary>
/// Form Load 이벤트
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void Form1_Load(object sender, EventArgs e)
{
    InitForm();
    this.Text = "Client";
    txtIP.Text = "TCP Server의 IP 입력";
    txtPort.Text = PORT.ToString();
    txtUserName.Text = GetPID();
    txtStatus.Text = "대기중...";
}

 

4.4 Server Connect

• 서버 연결 버튼을 클릭하면 TCP Server와 연결되도록 코드 작성
• Connect() : TCP Server의 IP와 약속된 Port 정보를 이용하여 Server에 연결

/// <summary>
/// 서버 연결 버튼 클릭
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void btnConnect_Click(object sender, EventArgs e)
{
    try
    {
        if (CONNECT_STATUS.Equals("DISCONNECT"))
        {
            Connect();
            USER_NAME = txtUserName.Text.Trim();
            txtStatus.Text = "연결됨";
            CONNECT_STATUS = "CONNECT";
        }
        else if (CONNECT_STATUS.Equals("CONNECT"))
        {
            return;
        }
        else
        {
            return;
        }

    }
    catch (Exception ex)
    {
        MessageBox.Show("서버가 실행중이 아닙니다.", "연결 실패!");
    }

    message = "채팅 서버에 연결 되었습니다.";
    DisplayText(message);

    byte[] buffer = Encoding.Unicode.GetBytes(USER_NAME + "$");

    stream.Write(buffer, 0, buffer.Length);
    stream.Flush();

    Thread t_handler = new Thread(GetMessage);
    t_handler.IsBackground = true;
    t_handler.Start();
}

/// <summary>
/// Connect 메서드
/// </summary>
private void Connect()
{
    clientSocket.Connect(txtIP.Text.ToString(), PORT); // 접속 IP 및 포트
    stream = clientSocket.GetStream();
}

 

4.5 Server DisConnect

• 연결 끊기 버튼을 클릭하면 TCP Server와 연결이 종료되도록 코드 작성
• DisConnect() : 연결되어있는 Server와 연결 종료

/// <summary>
/// 연결 끊기 버튼 클릭 
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void btnDisConnect_Click(object sender, EventArgs e)
{
    if (CONNECT_STATUS.Equals("DISCONNECT"))
    {
        MessageBox.Show("연결된 상태가 아닙니다.");
        return;
    }
    else if (CONNECT_STATUS.Equals("CONNECT"))
    {
        DisConnect();
        txtStatus.Text = "대기중...";
        CONNECT_STATUS = "DISCONNECT";
        return;
    }
    else
    { }
}

/// <summary>
/// DisConnect 메서드
/// </summary>
private void DisConnect()
{
    clientSocket = null;
    byte[] buffer = Encoding.Unicode.GetBytes("LeaveChat" + "$");
    stream.Write(buffer, 0, buffer.Length);
    stream.Flush();
}

 

4.6 메세지 전송

• 전송할 메세지를 입력하고 Enter 또는 전송 버튼을 클릭하면 입력된 메세지가 Server로 전송된다.

/// <summary>
/// 전송 버튼 클릭
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void btnSendMessage_Click(object sender, EventArgs e)
{
    txtMessage.Focus();
    byte[] buffer = Encoding.Unicode.GetBytes(txtMessage.Text + "$");
    stream.Write(buffer, 0, buffer.Length);
    stream.Flush();

    txtMessage.Text = "";
}

/// <summary>
/// 메세지 TextBox KeyUp 이벤트
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void txtMessage_KeyUp(object sender, KeyEventArgs e)
{
    if (e.KeyCode == Keys.Enter) // 엔터키 눌렀을 때
        btnSendMessage_Click(this, e);
}

 

4.7 메세지 수신

• TCP Server와 연결 시, Thread로 실행한 GetMessage() 메서드를 이용하여 Server로부터 메세지를 수신받는다.

/// <summary>
/// 메세지 수신
/// </summary>
private void GetMessage() // 메세지 받기
{
    while (true)
    {
        stream = clientSocket.GetStream();
        int BUFFERSIZE = clientSocket.ReceiveBufferSize;
        byte[] buffer = new byte[BUFFERSIZE];
        int bytes = stream.Read(buffer, 0, buffer.Length);
        string message = Encoding.Unicode.GetString(buffer, 0, bytes);

        DisplayText(message);
    }
}

 

4.8 프로그램 종료

• FormClosing() 이벤트를 이용하여 프로그램 종료 시, Server와 연결을 종료한다.

private void Form1_FormClosing(object sender, FormClosingEventArgs e)
{
    DisConnect();

    Application.ExitThread();
    Environment.Exit(0);
}

 

4.9 기타 메서드

• DisplayText() : richTextBox에 텍스트를 추가하기 위해 정의된 메서드
• GetPID() : 프로그램이 실행되어있는 ProcessID를 가져오는 메서드, PID를 USER_NAME으로 사용

private void DisplayText(string text) // Server에 메세지 출력
{
    richTextBox1.Invoke((MethodInvoker)delegate { richTextBox1.AppendText(text + "\r\n"); }); // 데이타를 수신창에 표시, 반드시 invoke 사용. 충돌피함.
    richTextBox1.Invoke((MethodInvoker)delegate { richTextBox1.ScrollToCaret(); });  // 스크롤을 젤 밑으로.
}

/// <summary>
/// Process ID 가져오기
/// </summary>
/// <returns></returns>
private string GetPID()
{
    string rtn = string.Empty;
    Process currentProcess = Process.GetCurrentProcess();
    rtn = currentProcess.Id.ToString();

    return rtn;
}

 

4.10 실행 결과

• 실행 결과는 아래 이미지와 같다.
• IP 주소 TextBox에는 TCP Server의 IP를 입력한다.

서버 연결 전

서버 연결 후

 

TCP Server - Client 연결

 

4.11 전체 소스코드

• TCP Client 코드

using System.Diagnostics;
using System.Net;
using System.Net.Sockets;
using System.Text;

namespace TCP_Client
{
    public partial class Form1 : Form
    {
        TcpClient clientSocket = new TcpClient(); // 소켓
        NetworkStream stream = default(NetworkStream);
        string message = string.Empty;
        private int PORT = 5000; // 포트 정보
        private string USER_NAME = string.Empty;
        private static string CONNECT_STATUS = "DISCONNECT"; // 연결상태

        public Form1()
        {
            InitializeComponent();
        }

        /// <summary>
        /// Form Load 이벤트
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Form1_Load(object sender, EventArgs e)
        {
            InitForm();
            this.Text = "Client";
            txtIP.Text = "TCP Server의 IP 입력";
            txtPort.Text = PORT.ToString();
            txtUserName.Text = GetPID();
            txtStatus.Text = "대기중...";
        }

        private void InitForm()
        {
            txtIP.Text = "";
            txtPort.Text = "";
            txtMessage.Text = "";
            richTextBox1.Text = "";
            listBox1.Items.Clear();
        }

        /// <summary>
        /// Process ID 가져오기
        /// </summary>
        /// <returns></returns>
        private string GetPID()
        {
            string rtn = string.Empty;
            Process currentProcess = Process.GetCurrentProcess();
            rtn = currentProcess.Id.ToString();

            return rtn;
        }

        /// <summary>
        /// DisConnect 메서드
        /// </summary>
        private void DisConnect()
        {
            clientSocket = null;
            byte[] buffer = Encoding.Unicode.GetBytes("LeaveChat" + "$");
            stream.Write(buffer, 0, buffer.Length);
            stream.Flush();
        }

        /// <summary>
        /// Connect 메서드
        /// </summary>
        private void Connect()
        {
            clientSocket.Connect(txtIP.Text.ToString(), PORT); // 접속 IP 및 포트
            stream = clientSocket.GetStream();
        }

        /// <summary>
        /// 서버 연결 버튼 클릭
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnConnect_Click(object sender, EventArgs e)
        {
            try
            {
                if (CONNECT_STATUS.Equals("DISCONNECT"))
                {
                    Connect();
                    USER_NAME = txtUserName.Text.Trim();
                    txtStatus.Text = "연결됨";
                    CONNECT_STATUS = "CONNECT";
                }
                else if (CONNECT_STATUS.Equals("CONNECT"))
                {
                    return;
                }
                else
                {
                    return;
                }
            }
            catch (Exception ex)
            {
                MessageBox.Show("서버가 실행중이 아닙니다.", "연결 실패!");
            }

            message = "채팅 서버에 연결 되었습니다.";
            DisplayText(message);

            byte[] buffer = Encoding.Unicode.GetBytes(USER_NAME + "$");

            stream.Write(buffer, 0, buffer.Length);
            stream.Flush();

            Thread t_handler = new Thread(GetMessage);
            t_handler.IsBackground = true;
            t_handler.Start();
        }

        /// <summary>
        /// 메세지 수신
        /// </summary>
        private void GetMessage() // 메세지 받기
        {
            while (true)
            {
                stream = clientSocket.GetStream();
                int BUFFERSIZE = clientSocket.ReceiveBufferSize;
                byte[] buffer = new byte[BUFFERSIZE];
                int bytes = stream.Read(buffer, 0, buffer.Length);
                string message = Encoding.Unicode.GetString(buffer, 0, bytes);

                DisplayText(message);
            }
        }

        /// <summary>
        /// 연결 끊기 버튼 클릭 
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnDisConnect_Click(object sender, EventArgs e)
        {
            if (CONNECT_STATUS.Equals("DISCONNECT"))
            {
                MessageBox.Show("연결된 상태가 아닙니다.");
                return;
            }
            else if (CONNECT_STATUS.Equals("CONNECT"))
            {
                DisConnect();
                txtStatus.Text = "대기중...";
                CONNECT_STATUS = "DISCONNECT";
                return;
            }
            else
            { }
        }

        /// <summary>
        /// 전송 버튼 클릭
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnSendMessage_Click(object sender, EventArgs e)
        {
            txtMessage.Focus();
            byte[] buffer = Encoding.Unicode.GetBytes(txtMessage.Text + "$");
            stream.Write(buffer, 0, buffer.Length);
            stream.Flush();

            txtMessage.Text = "";
        }

        /// <summary>
        /// 메세지 TextBox KeyUp 이벤트
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void txtMessage_KeyUp(object sender, KeyEventArgs e)
        {
            if (e.KeyCode == Keys.Enter) // 엔터키 눌렀을 때
                btnSendMessage_Click(this, e);
        }

        private void DisplayText(string text) // Server에 메세지 출력
        {
            richTextBox1.Invoke((MethodInvoker)delegate { richTextBox1.AppendText(text + "\r\n"); }); // 데이타를 수신창에 표시, 반드시 invoke 사용. 충돌피함.
            richTextBox1.Invoke((MethodInvoker)delegate { richTextBox1.ScrollToCaret(); });  // 스크롤을 젤 밑으로.
        }

        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            DisConnect();

            Application.ExitThread();
            Environment.Exit(0);
        }
    }
}

 

---

C# 윈폼 - TCP/IP 네트워크 통신을 뚫어보자