Scoket 类似聊天

服务端

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;

namespace Sockets
{
    public partial class ServerForm : Form
    {
        Socket s = null;
        IPEndPoint iep = null;
        byte[] buf = new byte[1024];
        Socket worker = null;

        public ServerForm()
        {
            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.Visible = false;
        }

        void Accept(IAsyncResult ia)
        {
            s = ia.AsyncState as Socket;
            //worker = s.EndAccept();
            worker = s.EndAccept(ia);
            s.BeginAccept(new AsyncCallback(Accept), s);
            try
            {
                worker.BeginReceive(buf, 0, buf.Length,SocketFlags.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, SocketFlags.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));
            }
        }

        private void ServerForm_Load(object sender, EventArgs e)
        {

        }
    }
}

客户端

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;

namespace Sockets
{
    public partial class ClientForm : Form
    {
        Socket s = null;
        IPEndPoint iep = null;
        byte[] buf = new byte[1024];

        public ClientForm()
        {
            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("192.168.10.131"), 20000);
            try
            {
                s.Connect(iep);
                this.label1.Text = "连接成功";
                this.button1.Visible = 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.textBox2.Text = "";
                s.Send(Encoding.GetEncoding("gb2312").GetBytes(context));
                try
                {
                    s.BeginReceive(buf, 0, buf.Length, SocketFlags.None, new AsyncCallback(Receive), s);
                }
                catch
                { throw; }
            }
        }

        void Receive(IAsyncResult ia)
        {
            s = ia.AsyncState as Socket;
            int count = s.EndReceive(ia);
            s.BeginReceive(buf, 0, buf.Length, SocketFlags.None, new AsyncCallback(Receive), s);
            string context = Encoding.GetEncoding("gb2312").GetString(buf, 0, count);
            this.textBox1.Text += Environment.NewLine;
            this.textBox1.Text += context;
        }

        private void ClientForm_Load(object sender, EventArgs e)
        {

        }
    }
}