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

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값 변환 표시