C/S 架构的简单Socket 通信的例子

新建两个Form程序

引用命名空间：using System.Net; using System.Net.Sockets;

Server 端：

放两个Button和两个TextBox　　　

public partial class Form1 : Form
{

　　　Socket s = null;

　　   IPEndPoint iep = null;

　　　byte[] buf = new byte[1024];

　　   Socket worker = null;

　　　public Form1()
        {
            InitializeComponent();
            Control.CheckForIllegalCrossThreadCalls = false;
        }

　　 private void button1_Click(object sender,EventArgs e)

　　{

　　　　//创建一个通道

　　　　s = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);

　　　　//创建一个侦听点

　　　　iep = new IPEndPoint(IPAddress.Any,20000);

　　　　//绑定到通道上

　　　　s.Bind(iep);

　　　　//侦听

　　　　s.Listen(6);

　　　　//通过异步来处理

　　　　s.BeginAccept(new AsyncCallback(Accept),s);

　　　　this.button1.Visable = false;

　　}

　　void Accept(IAsyncResult ia)

　　{

　　　　s = ia.AsyncState as Socket;

　　　　worker = s.EndAccept();

　　　　s.BeginAccept(new AsyncCallback(Accept),s);

　　　　try

　　　　{

　　　　　　worker.BeginReceive(buf,0,buf.Length,Socket.Flogs.None, new AsyncCallback(Receive),worker);

　　　　}

　　　　catch

　　　　{ throw ;}

　　}

　　void Receive(IAsyncResult ia)

　　{

　　　　worker = ia.AsyncState as Socket;

　　　　int count =　worker.EndReceive(ia);

　　　　worker.BeginReceive(buf,0,buf.Length,Socket.Flogs.None,new AsyncCallback(Receive),worker);

　　　　string context = Encoding.GetEncoding("gb2312").GetString(buf,0,count);

　　　　this.textbox1.text += Environment.NewLine;

　　　　this.textbox1.text += context;

　　}

　　private void button2_Click(object sender, EventArgs e)

　　{

　　　　string context ="XXXXX" + this.textbox2.Text.Trim();

　　　　if(context != "")

　　　　{

　　　　　　this.textbox1.Text += Environment.NewLine;

　　　　　　this.textbox1.Text += context;

　　　　　　this.textbox2.Text = "";

　　　　　　worker.Send(Encoding.GetEncoding("gb2312").GetBytes(context));

　　　　}

　　}
}

客户端：

主要代码：

public partial class Form1 : Form
{

　　Socket s = null;

　　IPEndPoint iep = null;

　　byte[] buf = new byte[1024];

　　public Form1()
     {
            InitializeComponent();
            Control.CheckForIllegalCrossThreadCalls = false;
      }

　　private void button1_Click(object sender,EventArgs e)

　　{

　　　　s = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);

　　　　iep = new IPEndPoint(IPAddress.Parse("127.0.0.1"),20000);

　　　　try

　　　　{

　　　　　　s.Connect(iep);

　　　　　　this.label1.Text = "连接成功";

　　　　　　this.button1.Visable =false;

　　　　}

　　　　catch

　　　　{ throw ;}

　　}

　　private void button2_Click(object sender, EventArgs e)

　　{

　　　　string context = iep.ToString() + ":" + this.textbox2.Text.Trim();

　　　　if(context != "")

　　　　{

　　　　　　this.textbox1.Text += Environment.NewLine;

　　　　　　this.textbox1.Text += context;

　　　　　　this.tetxbox2.Text ="";

　　　　　　s.Send(Encoding.GetEncoding("gb2312").GetBytes(context));

　　　　　　try

　　　　　　{

　　　　　　　　s.BeginReceive(buf,0,buf.Length,Socket.Flogs.None, new AsyncCallback(Receive),s);

　　　　　　}

　　　　　　catch

　　　　　　{ throw ;}

　　　　}

　　}

　　void Receive(IAsynvResult ia)

　　{

　　　　s = ia.AsyncState as Socket;

　　　　int count = s.EndReceive(ia);

　　　　s.BeginReceive(buf,0,buf.Length,Socket.Flogs.None, new AsyncCallback(Receive),s);

　　　　string context =Encoding.GetEncoding("gb2312").GetString(buf,0,count);

　　　　this.textbox1.Text += Environment.NewLine;

　　　　this.textbox1.Text += context;

　　}

}