控件:三个按钮,输入框,文件框(richTextBox)
打开服务器按钮方法
Socket socket;// 服务器对象
Dictionary<string,Socket> dic = new Dictionary<string,Socket>();// 存储客户端对象
// 打开服务器
private void button1_Click(object sender, EventArgs e)
{
button1.Enabled = false; // 按钮关闭启用
button2.Enabled = true; // 按钮启用
// 1 创建服务器对象
socket = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
// 2 绑定终端
IPEndPoint ip = new IPEndPoint(IPAddress.Any, 3000);
socket.Bind(ip);
// 3 监听终端
socket.Listen(100);
// 4 开启连接,写在异步任务里面。直接写在此处会阻塞线程
// Task.Factory.StartNew(()=>使用工厂模式开启线程
//{
//{)
StartA(socket);
}
public void StartA(Socket socket)
{
Task.Run(() =>
{
while (true)
{
try
{
// 当客户关闭之后,这个地方接受客户端接受不到了。kehuduan就是null
// 使用kehuduan就会报错
Socket kehuduan = socket.Accept();// 接受客户端
dic.Add(kehuduan.RemoteEndPoint.ToString(), kehuduan); // 保存客户端
richTextBox1.Invoke((Action)(() =>
{
richTextBox1.AppendText($"{kehuduan.RemoteEndPoint.ToString()}已经连接\t\n");
}));
//5 接受数据
StartReceive(kehuduan);
}
catch
{
// 如果Accept 出错的时候 关闭线程
// 例如socket为空,相当服务器主动断开
socket.Close();// 关闭服务器
break;
}
}
});
}
发送消息按钮
private void button3_Click(object sender, EventArgs e)
{
// 发消息
byte[] bs = Encoding.UTF8.GetBytes(this.textBox1.Text);
foreach (var item in dic) // 遍历所有
{
item.Value.Send(bs);
}
}
关闭服务器
// 断开连接 有两种方式断开 1 服务器主动关闭 2 客户端断开
// 1 服务器主动关闭
private void button2_Click(object sender, EventArgs e)
{
button1.Enabled = true;
button2.Enabled = false;
foreach (var item in dic)
{
Socket s = item.Value;
s.Shutdown(SocketShutdown.Both);// 关闭服务器
s.Close();
}
dic.Clear();// 清空客户端
socket.Close(); // 关闭服务器
socket = null;// 释放资源
}
启动服务器后可以使用《tcp客户端》连接服务器