C#소켓 1:1채팅 서버/클라이언트

프로그래밍/C#

C#소켓 1:1채팅 서버/클라이언트

곰환 2017. 4. 19. 16:41

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

namespace server
{
    public partial class Form1 : Form
    {

public class Network
        {
            public Socket sock;
            public byte[] buffer;
            public Int32 size;

public Network(Int32 buffersize)
            {
                this.size = buffersize;
                this.buffer = new byte[size];
            }
            public void inibuffer()
            {
                this.buffer = null;
                this.buffer = new byte[size];
            }

}

//char -> hex
        public string str2hex(string strData)
        {
            string resultHex = string.Empty;
            byte[] arr_byteStr = Encoding.Default.GetBytes(strData);

foreach (byte byteStr in arr_byteStr)
                resultHex += string.Format("{0:X2}", byteStr);

return resultHex;
        }

//hex -> char
        public static byte[] hex2str(string hexData)
        {
            hexData = hexData.Replace("-", "");
            byte[] arr_byteHex = new byte[hexData.Length / 2];
            for (int i = 0; i < arr_byteHex.Length; i++)
            {
                arr_byteHex[i] = Convert.ToByte(hexData.Substring(i * 2, 2), 16);
            }
            
            return arr_byteHex;
        }

private Socket serverSocket;
        private Socket clientSocket;
        private AsyncCallback acbReceiveH;
        private AsyncCallback acbSendH;
        private AsyncCallback acbAcceptH;
        private AsyncCallback acbConnectH;
        private FileStream fsRecv = null;
        private int flag = 0;

#region [폼 에디트]
        public Form1()
        {
            InitializeComponent();
        }

private void Form1_Load(object sender, EventArgs e)
        {
            IPAddress ipaddress = Dns.Resolve(Dns.GetHostName()).AddressList[0];
            ServIPtextBox.Text = Convert.ToString(ipaddress);
            Porttextbox.Text = "";
        }
        #endregion

#region [서버오픈 버튼]
        private void Openbutton_Click(object sender, EventArgs e)
        {

try
            {
                flag = 1;
                acbReceiveH = new AsyncCallback(handleDataReceive);
                acbSendH = new AsyncCallback(handleDataSend);
                acbAcceptH = new AsyncCallback(handleConnectionRequest);
                serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                serverSocket.Bind(new IPEndPoint(IPAddress.Parse(ServIPtextBox.Text), Convert.ToInt32(Porttextbox.Text)));
                serverSocket.Listen(5);
                serverSocket.BeginAccept(acbAcceptH, null);

}
            catch (Exception e1)
            {
                MessageBox.Show(e1.Message);
            }

}
        #endregion

#region [클라이언트 접속 버튼]
        private void LoginButton_Click(object sender, EventArgs e)
        {
            try
            {
                flag = 2;
                clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                IPAddress ipAddr = IPAddress.Parse(clientIPtextbox.Text);
                IPEndPoint ipep = new IPEndPoint(ipAddr, Convert.ToInt32(clientPorttextbox.Text));
                acbConnectH = new AsyncCallback(handleClientConnect);
                acbReceiveH = new AsyncCallback(handleDataReceive);
                acbSendH = new AsyncCallback(handleDataSend);
                clientSocket.BeginConnect(ipep, acbConnectH, clientSocket);
            }
            catch (Exception e1)
            {
                MessageBox.Show(e1.Message);
            }
        }
        #endregion

#region [메세지 전송 버튼]
        private void Sendbutton_Click(object sender, EventArgs e)
        {
            Network ao = new Network(1);

switch (flag)
            {
                case 1: //서버모드
                    if (hexcheckBox.Checked == true)
                    {
                        ao.buffer = hex2str(SendtextBox.Text);
                        ao.sock = serverSocket;
                        serverSocket.BeginSend(ao.buffer, 0, ao.buffer.Length, SocketFlags.None, acbSendH, ao);
                    }
                    else
                    {
                        ao.buffer = Encoding.UTF8.GetBytes(SendtextBox.Text);
                        ao.sock = serverSocket;
                        serverSocket.BeginSend(ao.buffer, 0, ao.buffer.Length, SocketFlags.None, acbSendH, ao);
                    }
                    break;

case 2: //클라이언트 모드
                    if (hexcheckBox.Checked == true)
                    {
                        ao.buffer = hex2str(SendtextBox.Text);
                        ao.sock = clientSocket;
                        clientSocket.BeginSend(ao.buffer, 0, ao.buffer.Length, SocketFlags.None, acbSendH, ao);
                    }
                    else
                    {
                        ao.buffer = Encoding.UTF8.GetBytes(SendtextBox.Text);
                        ao.sock = clientSocket;
                        clientSocket.BeginSend(ao.buffer, 0, ao.buffer.Length, SocketFlags.None, acbSendH, ao);
                    }
                    
                    break;
                default:
                    break;
            }
        }
        #endregion

private void handleClientConnect(IAsyncResult ar)
        {
            Socket sock1 = (Socket)ar.AsyncState;
            try
            {
                sock1.EndConnect(ar);

if (sock1.Connected)
                {
                    Network ao = new Network(6144);
                    ao.sock = sock1;
                    sock1.BeginReceive(ao.buffer, 0, ao.buffer.Length, SocketFlags.None, acbReceiveH, ao);
                    ChattextBox.AppendText("서버와 연결되었습니다.\r\n");
                    fsRecv = new FileStream("download", FileMode.Create, FileAccess.ReadWrite);
                }
                else
                {
                    ChattextBox.AppendText("서버와 연결되었습니다.");
                    sock1.Close();
                }
            }
            catch (Exception e1)
            {
                MessageBox.Show(e1.Message);
            }
        }

private void handleConnectionRequest(IAsyncResult ar)
        {
            serverSocket = serverSocket.EndAccept(ar);
            Network ao = new Network(6144);
            ao.sock = serverSocket;
            serverSocket.BeginReceive(ao.buffer, 0, ao.buffer.Length, SocketFlags.None, acbReceiveH, ao);
            ChattextBox.AppendText("클라이언트와 연결했습니다.\r\n");

}

public void handleDataReceive(IAsyncResult ar)
        {
            Network ao = (Network)ar.AsyncState;
            Int32 recvBytes = ao.sock.EndReceive(ar);

if (showhexCheckbox.Checked == true)
            {
                if (recvBytes > 0)
                {
                    ChattextBox.AppendText("(R) " + str2hex(Encoding.UTF8.GetString(ao.buffer)));
                    ChattextBox.AppendText("\r\n");
                }
                if (fsRecv == null)
                {
                    fsRecv = new FileStream("download", FileMode.Create, FileAccess.ReadWrite);
                }
                fsRecv.Write(ao.buffer, 0, ao.buffer.Length);
                ao.inibuffer();
                ao.sock.BeginReceive(ao.buffer, 0, ao.buffer.Length, SocketFlags.None, acbReceiveH, ao);
            }
            else
            {
                if (recvBytes > 0)
                {
                    ChattextBox.AppendText("(R) " + Encoding.UTF8.GetString(ao.buffer));
                    ChattextBox.AppendText("\r\n");
                }
                if (fsRecv == null)
                {
                    fsRecv = new FileStream("download", FileMode.Create, FileAccess.ReadWrite);
                }
                fsRecv.Write(ao.buffer, 0, ao.buffer.Length);
                ao.inibuffer();
                ao.sock.BeginReceive(ao.buffer, 0, ao.buffer.Length, SocketFlags.None, acbReceiveH, ao);
            }
        }

public void handleDataSend(IAsyncResult ar)
        {
            Network ao = (Network)ar.AsyncState;

Int32 sentbyte = ao.sock.EndSend(ar);

if (showhexCheckbox.Checked == true)
            {
                if (sentbyte > 0)
                {
                    ChattextBox.AppendText("(S) " + str2hex(Encoding.UTF8.GetString(ao.buffer)) + "\r\n");
                }
            }
            else
            {
                if (sentbyte > 0)
                {
                    ChattextBox.AppendText("(S) " + Encoding.UTF8.GetString(ao.buffer) + "\r\n");
                }
            }
        }
    }
}

http://akflsh.tistory.com/entry/c-socket-server 의 프로젝트를 수정하여 만든

비동기 1:1 서버/클라이언트 채팅 프로그램입니다.

새로 추가된 기능입니다.

-클라이언트 접속

-char -> hex값 변환 전송

-hex -> char값 변환 표시