C#使用Tcp/Udp协议

 public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
            myAddOnlieDelegate = AddOnlie;
            myAddTextDelegate = AddTexr;
        }

        private void AddTexr(string str)
        {
            //将文字追加到文本中
            txt_centext.AppendText(str);
        }

        /// <summary>
        /// 委托方法
        /// </summary>
        /// <param name="str"></param>
        /// <param name="bl"></param>
        private void AddOnlie(string str, bool bl)
        {
            if (bl)
            {
                //如果是true的话对listbox.Item进行一个添加
                listOne.Items.Add(str);
            }
            else
            {
                //反之删除
                listOne.Items.Remove(str);
            }
        }



        //实例化Socket
        Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        //接口
        Thread thread = null;
        //键值队
        Dictionary<string, Socket> Dic = new Dictionary<string, Socket>();
        //委托
        delegate void MyAddOnlieDelegate(string  str,bool bl);
        delegate void MyAddTextDelegate(string str);
        MyAddOnlieDelegate myAddOnlieDelegate;
        MyAddTextDelegate myAddTextDelegate;
        private void button1_Click(object sender, EventArgs e)
        {
            #region 第一步获取IP和端口进行相互通信
            //获取IP
            IPAddress IP = IPAddress.Parse(txt_IP.Text.Trim());
            //把IP和端口号放在IPEndPoint中
            IPEndPoint IEnd = new IPEndPoint(IP,int.Parse(txt_port.Text.Trim()));
            try
            {
                //和socket进行关联
                socket.Bind(IEnd);
                MessageBox.Show("服务器开启成功！");
            }
            catch (Exception ex)
            {
                //失败了直接return出去
                MessageBox.Show("服务器开启失败" + ex.Message);
                return;
            }
            //socket可以对多少个客户端进行监视
            socket.Listen(10);
            #endregion
            #region 第二部开启多线程
            //开始进行多线程操作 开始执行此线程时要调用的方法的
            thread = new Thread(ListenConnectingl);
            //此线程则为后台线程
            thread.IsBackground = true;
            //启动线程
            thread.Start();
            //连接到服务器后把按钮禁用掉
            button1.Enabled = false;
            #endregion
        }

        /// <summary>
        /// 正在进行的后台线程的方法
        /// </summary>
        private void ListenConnectingl()
        {
            //线程使用时进行循环
            while (true)
            {
                //创建一个新的Socket  列:如果有一个新的客户端来连接服务器给他一个Socket
                Socket socketConnect = socket.Accept();
                //把谁连接的客户端给到skt中 字符串
                string skt = socketConnect.RemoteEndPoint.ToString();
                Dic.Add(skt, socketConnect);
                Invoke(myAddOnlieDelegate, skt, true);
                //更新设备列表  需要接受来自不同客户端的消息 接着在开一个线程  
                Thread thr = new Thread(ReceiveMsg);
                thr.IsBackground = true;
                thr.Start(socketConnect);
                
            }
        }
        /// <summary>
        /// 开的发送接受的线程 直接从上面传递过来参数 vs中没显示用什么类型的  视频中vs显示可以使用object类型 所有类型的基类来展示  带参的
        /// </summary>
        /// <param name="socketConnect"></param>
        private void ReceiveMsg(object socketConnect)
        {
            //as：转换强转  把object转换成Socket
            Socket so = socketConnect as Socket;
            while (true)
            {
                byte[] arr = new byte[1024 * 1024 * 2];
                //定义一个变量
                int Length = -1;
                //try
                //{
                    //Receive返回的是一个int类型的数据 如果没有的直接关闭掉
                    Length = so.Receive(arr);
                //}
                //catch (Exception)
                //{

                //    //如果字节数没有的话把他移除掉
                //    string str = so.RemoteEndPoint.ToString();
                //    Dic.Remove(str);
                //    //引用的委托
                //    //Invoke(myAddTextDelegate, str+"下线了");
                //    Invoke(myAddOnlieDelegate, str, false);
                //    break;
                //}
               
                //加的if判断条件
                if (Length == 0)
                {
                    //如果字节数没有的话把他移除掉
                    string str = so.RemoteEndPoint.ToString();
                    Dic.Remove(str);
                    //引用的委托
                    Invoke(myAddOnlieDelegate, str, false);
                    break;
                }
                else
                {
                    //如果成功把接受的byte转换成string
                    string str = Encoding.UTF8.GetString(arr);
                    Invoke(myAddTextDelegate, str+Environment.NewLine);

                } 
            }
        }
        /// <summary>
        /// 发送消息   只能发送字节流
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button2_Click(object sender, EventArgs e)
        {
            //要发送的文字
            string str=txt_gocentext.Text.Trim();
            byte[] bt = Encoding.UTF8.GetBytes(str);
            ///
            if (listOne.SelectedItems.Count == 0)
            {
                MessageBox.Show("请选择要发送的对象");
            }
            else
            {
                foreach (String item in listOne.SelectedItems)
                {
                    //send发送到指定的socket中
                    Dic[item].Send(bt);
                    string Msg = "[发送]" + item + " " + str+ System.Environment.NewLine;
                    //使用一个委托直接写入
                    Invoke(myAddTextDelegate, Msg+ Environment.NewLine);
                }
            }
        }

        private void button3_Click(object sender, EventArgs e)
        {
            Form2 form2 = new Form2();
            form2.Show();
        }
    }