Socket通信

前段时间被问到Socket，当时懵圈了。只记得在学习网络编程的时候了解过这个，具体的实现步骤只剩下一点模糊的印象了。所以，借助百度又重新学习了一下Socket。

文章代码照着陈希章老师的代码写了一遍，只是将控制台程序改成了winform程序，复习了Socket通信流程。

陈老师博客链接（向初学Socket的同学强力推荐）：http://www.cnblogs.com/chenxizhang/archive/2011/09/10/2172994.html#!comments

服务端代码：

 public partial class FormServer : Form
    {
       
        static byte[] buffer = new byte[1024];

        public FormServer()
        {
            InitializeComponent();
        }

        private void FormServer_Load(object sender, EventArgs e)
        {
            Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//生成socket
            socket.Bind(new IPEndPoint(IPAddress.Any, 4530));//绑定socket
            socket.Listen(4);//监听socket，并设置队列长度
            socket.BeginAccept(new AsyncCallback(ClientAccepted), socket);
            txtShowMessage.Invoke(new MethodInvoker(delegate { txtShowMessage.AppendText("服务端初始化完成
"); }));
        }


        public static void ReceiveMessage(IAsyncResult ar)
        {
            try
            {
                var socket = ar.AsyncState as Socket;

                var length = socket.EndReceive(ar);
                //读取出来消息内容
                var message = Encoding.Unicode.GetString(buffer, 0, length);
                //显示消息
                txtShowMessage.Invoke(new MethodInvoker(delegate { txtShowMessage.AppendText(message+"
"); }));

                //接收下一个消息(因为这是一个递归的调用，所以这样就可以一直接收消息了）
                socket.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveMessage), socket);
            }
            catch (Exception ex)
            {
                txtShowMessage.AppendText(ex.Message + "
");
            }
        }


        public static void ClientAccepted(IAsyncResult ar)
        {

            var socket = ar.AsyncState as Socket;

            //这就是客户端的Socket实例，我们后续可以将其保存起来
            var client = socket.EndAccept(ar);

            //给客户端发送一个欢迎消息
            client.Send(Encoding.Unicode.GetBytes("Hi there, I accept you request at " + DateTime.Now.ToString()));


            //实现每隔两秒钟给服务器发一个消息
            //这里我们使用了一个定时器
            var timer = new System.Timers.Timer();
            timer.Interval = 2000D;
            timer.Enabled = true;
            timer.Elapsed += (o, a) =>
            {
                //检测客户端Socket的状态
                if (client.Connected)
                {
                    try
                    {
                        client.Send(Encoding.Unicode.GetBytes("Message from server at " + DateTime.Now.ToString()));
                    }
                    catch (SocketException ex)
                    {
                        txtShowMessage.AppendText(ex.Message + "
");
                    }
                }
                else
                {
                    timer.Stop();
                    timer.Enabled = false;
                    txtShowMessage.AppendText("Client is disconnected, the timer is stop.
");
                }
            };
            timer.Start();


            //接收客户端的消息(这个和在客户端实现的方式是一样的）
            client.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveMessage), client);

            //准备接受下一个客户端请求
            socket.BeginAccept(new AsyncCallback(ClientAccepted), socket);
        }
    }

客户端代码：

 public partial class FormClient : Form
    {
        public FormClient()
        {
            InitializeComponent();
        }
       // Socket socket;//接收服务端数据socket对象
        static byte[] buffer = new byte[1024];
        string message = string.Empty;//服务端传过来的数据
        private void FormClient_Load(object sender, EventArgs e)
        {
            Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//创建socket
            socket.Connect("127.0.0.1", 4530);//根据IP地址和端口进行连接
            
            socket.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveMessage), socket);
            //接受用户输入，将消息发送给服务器端
            while (true)
            {
                var message = "Message from client : " + Console.ReadLine();
                var outputBuffer = Encoding.Unicode.GetBytes(message);
                socket.BeginSend(outputBuffer, 0, outputBuffer.Length, SocketFlags.None, null, null);
            }
        }

      

        public  void ReceiveMessage(IAsyncResult ar)
        {
            try
            {
                var socket = ar.AsyncState as Socket;
                var length = socket.EndReceive(ar);
                //读取出来消息内容
                var message = Encoding.Unicode.GetString(buffer, 0, length);
                //显示消息
                txtShowMessage.Invoke(new MethodInvoker(delegate { txtShowMessage.AppendText(message+"
"); }));
                //接收下一个消息(因为这是一个递归的调用，所以这样就可以一直接收消息了）
                socket.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveMessage), socket);

            }
            catch (Exception ex)
            {
                txtShowMessage.AppendText(ex.Message + "
");
            }
        }
    }

运行结果：