这篇文章主要讲解了C#使用Tcp/Udp协议的方法，内容清晰明了，对此有兴趣的小伙伴可以学习一下，相信大家阅读完之后会有帮助。
所使用的：多线程 委托 Socket 键值队
废话不多说上代码 综合视频中的理解 有什么不对的地方希望大神指点一下
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
myAddOnlieDelegate = AddOnlie;
myAddTextDelegate = AddTexr;
}
private void AddTexr(string str)
{
//将文字追加到文本中
txt_centext.AppendText(str);
}
///
/// 委托方法
///
///
///
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 Dic = new Dictionary();
//委托
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
}
///
/// 正在进行的后台线程的方法
///
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);
}
}
///
/// 开的发送接受的线程 直接从上面传递过来参数 vs中没显示用什么类型的 视频中vs显示可以使用object类型 所有类型的基类来展示 带参的
///
///
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);
}
}
}
///
/// 发送消息 只能发送字节流
///
///
///
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();
}
} 
