C# 设计一个利用多播技术开展网络会议讨论的通信程序(socket/Multicast)

【实例简介】

设计一个利用多播技术开展网络会议讨论的通信程序

【实例截图】

【核心代码】

using System;//知识点原理一定透彻
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;

using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace 会议
{
    public partial class 多播会议讨论程序 : Form
    {
        Socket socket;
        Thread recvThread;
        IPAddress address = IPAddress.Parse("234.5.6.8");
        IPEndPoint multiIPEndPoint;

        public 多播会议讨论程序()//窗体程序
        {
            InitializeComponent();
            this.txt.Text = "";
            multiIPEndPoint = new IPEndPoint(address,6000);//234.5.6组号，成员通过套接字方法添加或删除成员

            socket = new Socket(AddressFamily.InterNetwork ,SocketType.Dgram ,ProtocolType.Udp);//数据包套接字创建实例，创建组播成员的套接字socket
            IPEndPoint iep = new IPEndPoint(IPAddress.Any ,6000);//用ip，端口号定义一个网络端点【地址】，本机所有可用ip（防止多个ip）
            EndPoint ep = (EndPoint)iep;
            socket.Bind(iep);//将socket绑定到本地端点

            socket.SetSocketOption(SocketOptionLevel.IP ,SocketOptionName.AddMembership ,new MulticastOption(address));//通过套接字的setSocketOption方法，将套接字加入到多播组或者从多播组退出

            Control.CheckForIllegalCrossThreadCalls = false;//遇到线程交叉调用控制问题，请在调用线程之前，增加该语句     C#只有主线程才能操控控件，要想其他线程也操作，第一种方法：关闭安全检查。这句代码当然也就是关闭安全检测了！随着学习的深入，也不难知道，这种关闭安全性检查的方法是权宜之计，不宜使用在真正的项目实践中
            recvThread = new Thread(new ThreadStart(ReceiveMessage));//启动线程，接收消息，receiveMseeage函数执行接收时多线程
            recvThread.IsBackground = true;//设置该线程在后台运行
            recvThread.Start();//启动线程的执行
            byte[] bytes = System.Text.Encoding.Unicode.GetBytes("#");//使用“#”来标志成员加入的标志
            socket.SendTo(bytes, SocketFlags.None, multiIPEndPoint);//向多播端点发送该数据，但是没有显示，然后接收方根据接收到的按标识位进行区别显示
        }

        

        private void ReceiveMessage()//该函数主要是根据接收到的消息，按所发送的特殊标志位来区别显示
        {
            EndPoint ep = (EndPoint)multiIPEndPoint;
            byte[] bytes = new byte[1024];
            string str;
            int length;
            while (true)//循环接收【接收消息不知道什么时候对面发，所以循环】
            {
                length = socket.ReceiveFrom(bytes,ref ep);//ref 带回发送方的端点 ipaddress.Any:6000
                //下面2行是针对ref带回来的发送方端点
                string epAddress = ep.ToString();//将端点（IP：端口号）转为字符串，因为传输时字符数组
                epAddress = epAddress.Substring(0, epAddress.LastIndexOf(":"));//将:之前的提出来   substring(start,end)表示从start到end之间的字符串，包括start位置的字符但是不包括end位置的字符。https://www.jb51.net/article/44921.htm    LastIndexOf:String 在此实例中的最后一个匹配项的索引位置。
                //下面的处理对象是带标志位的接收到的数据
                str = System.Text.Encoding.Unicode.GetString(bytes ,0 ,length);//字符数组转为字符串   
                switch (str[0])
                {
                    case '#'://有成员加入   
                        this.listBox2.Items.Add("[" epAddress "]进入.");//box2消息显示窗口   会根据接收的消息得到epAddress,不管自己还是别人都收到接收到数据
                        string strl = "&:"   epAddress;//现在strl变成了&：发送端的端点
                        for (int i = 0; i < this.listBox1.Items.Count; i  )//在成员显示列Box1中    listBox1.Items.Count：这是得出列表框内的总项目数，将每一行给提出来
                        {
                            strl  = ":"   this.listBox1.Items[i].ToString();//返回当前组件中的内容?????
                        }
                        byte[] users = System.Text.Encoding.Unicode.GetBytes(strl);//传输数据，使得每一个人都知道
                        socket.SendTo(users ,SocketFlags.None ,multiIPEndPoint);////////注意strl发送之后然后break，返回上面循环就变成str ,然后因为含有&所以进入case:语句隔开组成数组，然后
                        break;
                    case '@':
                        this.listBox2.Items.Add("[" epAddress "]退出.");//在@出现的时候已经传输数据，使得每一个人都知道，见下面
                        this.listBox1.Items.Remove(epAddress);
                        break;
                    case '&':
                        string[] strArray = str.Split(':');//英文格式，上面的&：也必须英文格式：分隔符，返回str(是一开始带有标志位的数据，是别人发送的，receive是针对收到的数据，所以有时成员表出现&等是因为别人代码错了，发送的数据错了)各个被分开的子串  https://blog.csdn.net/riyuedangkong1/article/details/52431209 因为string[]所以数组，所以通过“:”来分割的每一段就是一个数组成员
                        for (int i = 1; i < strArray.Length; i  )//遍历改数组，每一个成员、、从i=1开始因为要将分隔开后第一个是& 所以从1而非0
                        {
                            bool isExist = false;//标志位
                            for (int j = 0; j < this.listBox1.Items.Count; j  )//检测每一个成员 
                            {
                                if (strArray[i] == this.listBox1.Items[j].ToString())//相等表示成员中已经有了
                                {
                                    isExist = true;
                                    break;
                                }
                            }
                            if (isExist == false)//如果没有该成员
                            {
                                this.listBox1.Items.Add(strArray[i].Trim());//则将数组中的没有的一项加进去并去空格//该，改，去空格
                            }
                        }
                        break;
                    case '!':
                        this.listBox2.Items.Add("[" epAddress  "]说:");//注意listbox1 2 是哪一个
                        this.listBox2.Items.Add(str.Substring(1));
                        this.listBox2.SelectedIndex = this.listBox2.Items.Count - 1;
                        break;
                }
            }
        }

        private void 多播会议讨论程序_FormClosing(object sender, FormClosingEventArgs e)
        {
            byte[] bytes = System.Text.Encoding.Unicode.GetBytes("@");//使用“@”来标志成员成员的退出
            socket.SendTo(bytes ,SocketFlags.None ,multiIPEndPoint);//向多播端点发送该数据，但是没有显示，然后接收方根据接收到的按标识位进行区别显示
            recvThread.Abort();
            socket.Close();
        }

        private void txt_KeyPress(object sender, KeyPressEventArgs e)//这边也要该以哈yong keypress
        {
            if (e.KeyChar == (char)Keys.Return)
            {
                if (this.txt.Text.Trim().Length > 0)
                {
                    byte[] bytes = System.Text.Encoding.Unicode.GetBytes("!"   this.txt.Text);//使用“！”来代表发送消息
                    this.txt.Text = "";//清空输入的格子
                    socket.SendTo(bytes, SocketFlags.None, multiIPEndPoint);//向多播端点发送该数据，但是没有显示，然后接收方根据接收到的按标识位进行区别显示
                }
            }
        }

        private void label1_Click(object sender, EventArgs e)
        {

        }


    }
}