tcp server 接收封包資料例子

【实例截图】

【核心代码】

       private void frmTCPServer_Load(object sender, EventArgs e)
        {
            Text = "TCPServer " _server_id ":" _port;

            //注册事件
            TCPServerManager manager = new TCPServerManager(_server_id);  //访问_server_id服务器
            manager.TCPMessageReceived = new TCPMessageReceivedEventHandler(manager_TCPMessageReceived);
            manager.TCPClientConnected = new TCPClientConnectedEventHandler(manager_TCPClientConnected);
            manager.TCPClientDisConnected = new TCPClientDisConnectedEventHandler(manager_TCPClientDisConnected);
            manager.TCPClientDisConnected4Pulse = new TCPClientDisConnected4PulseEventHandler(manager_TCPClientDisConnected4Pulse);
        }

        #region
        /// <summary>
        /// 心跳检测时用户断线
        /// </summary>
        /// <param name="csID"></param>
        /// <param name="uid"></param>
        void manager_TCPClientDisConnected4Pulse(string csID, int uid)
        {
            this.Invoke((Action)delegate()
            {
                foreach (DataGridViewRow row in dataGridView1.Rows)
                {
                    if (row.Cells[0].Value.ToString() == uid.ToString())
                    {
                        dataGridView1.Rows.Remove(row);
                        break;
                    }
                }
                textBox1.AppendText("未收到终端唯一标识为[" uid "]的心跳包\n");
            });
        }
        /// <summary>
        /// 用户断线
        /// </summary>
        /// <param name="csID"></param>
        /// <param name="args"></param>
        void manager_TCPClientDisConnected(string csID, TCPClientDisConnectedEventArgs args)
        {
            this.Invoke((Action)delegate()
            {
                foreach (DataGridViewRow row in dataGridView1.Rows)
                {
                    if (row.Cells[0].Value.ToString() == args.End.UID.ToString())
                    {
                        dataGridView1.Rows.Remove(row);
                        break;
                    }
                }
                textBox1.AppendText(args.Time.ToLongTimeString() " 终端唯一标识为[" args.End.UID "]的用户下线\n");

            });
        }
        //用户上线 这里简单的使用datagridview.tag属性维护在线用户列表
        void manager_TCPClientConnected(string csID, TCPClientConnectedEventArgs args)
        {
            this.Invoke((Action)delegate()
            {
                textBox1.AppendText(args.Time.ToLongTimeString() " " args.End.RemoteIP ":" args.End.RemotePort "连入\n");
                dataGridView1.Rows.Add(args.End.UID, args.End.RemoteIP, args.End.RemotePort, args.Time.ToLongTimeString());
                dataGridView1.Rows[dataGridView1.Rows.Count - 1].Tag = args.End;  //可以自定义数据结构来存储在线列表
            });
        }
        //收到消息
        void manager_TCPMessageReceived(string csID, TCPMessageReceivedEventArgs args)
        {
            this.Invoke((Action)delegate()
            {
                if (args.Msg == Msg.Zmsg1)  //文本
                {
                    textBox1.AppendText(args.Time.ToLongTimeString() " " args.End.RemoteIP ":" args.End.RemotePort " 发送文本:\n"
                        Encoding.Unicode.GetString(args.Data) "\n");
                }
                if (args.Msg == Msg.Zmsg2)  //图片
                {
                    textBox1.AppendText(args.Time.ToLongTimeString() " " args.End.RemoteIP ":" args.End.RemotePort " 发送图片:\n"
                        "见右方-->\n");
                    Image image = Bitmap.FromStream(new MemoryStream(args.Data));
                    pictureBox1.Image = image;
                }
            });
        }
        #endregion

        /// <summary>
        /// 发送文本
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button2_Click(object sender, EventArgs e)
        {
            TCPServerManager manager = new TCPServerManager(_server_id);
            foreach (DataGridViewRow row in dataGridView1.Rows)
            {
                manager.Send(Msg.Zmsg1, Encoding.Unicode.GetBytes(textBox2.Text), row.Tag as TCPEndPoint);  //给在线用户同步发送文本
            }
        }