C#소켓 1:1채팅 서버

using System; 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]; } } private Socket serverSocket; private AsyncCallback acbReceiveH; private AsyncCallback acbSendH; private AsyncCallback acbAcceptH; private FileStream fsRecv = null; private int flag = 0; private byte[] readB = new byte[3072]; public delegate void SetProgCallBack(int vv); public delegate void SetLabelCallBack(string str); NetworkStream stream = default(NetworkStream); 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 = ""; } #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 Sendbutton_Click(object sender, EventArgs e) { Network ao = new Network(1); ao.buffer = Encoding.UTF8.GetBytes(SendtextBox.Text); //SendtextBox.Text = ""; ao.sock = serverSocket; serverSocket.BeginSend(ao.buffer, 0, ao.buffer.Length, SocketFlags.None, acbSendH, ao); } #endregion public void handleDataReceive(IAsyncResult ar) { Network ao = (Network)ar.AsyncState; Int32 recvBytes = ao.sock.EndReceive(ar); if (recvBytes > 0) ChattextBox.AppendText(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 (sentbyte > 0) { ChattextBox.AppendText(Encoding.UTF8.GetString(ao.buffer) + "\r\n"); } } private void handleConnectionRequest(IAsyncResult ar) { serverSocket = serverSocket.EndAccept(ar); Network ao = new Network(100); ao.sock = serverSocket; serverSocket.BeginReceive(ao.buffer, 0, ao.buffer.Length, SocketFlags.None, acbReceiveH, ao); } } }