using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;namespace TcpMsgServer
{public partial class FrmServer : Form{public FrmServer(){InitializeComponent();//关闭对文本框的非法线程操作检查TextBox.CheckForIllegalCrossThreadCalls = false;}Thread threadWatch = null; //负责监听客户端的线程Socket socketWatch = null;  //负责监听客户端的套接字     /// <summary>/// 启动服务/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void btnServerConn_Click(object sender, EventArgs e){try{//定义一个套接字用于监听客户端发来的信息  包含3个参数(IP4寻址协议,流式连接,TCP协议)socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//服务端发送信息 需要1个IP地址和端口号IPAddress ipaddress = IPAddress.Parse(this.txtIP.Text.Trim()); //获取文本框输入的IP地址//将IP地址和端口号绑定到网络节点endpoint上 IPEndPoint endpoint = new IPEndPoint(ipaddress, int.Parse(this.txtPort.Text.Trim())); //获取文本框上输入的端口号//监听绑定的网络节点
                socketWatch.Bind(endpoint);//将套接字的监听队列长度限制为20socketWatch.Listen(20);//创建一个监听线程 threadWatch = new Thread(WatchConnecting);//将窗体线程设置为与后台同步threadWatch.IsBackground = true;//启动线程
                threadWatch.Start();//启动线程后 txtMsg文本框显示相应提示txtMsg.AppendText("开始监听客户端传来的信息!" + "\r\n");this.btnServerConn.Enabled = false;}catch (Exception ex) {txtMsg.AppendText("服务端启动服务失败!" + "\r\n");this.btnServerConn.Enabled = true;}}//创建一个负责和客户端通信的套接字 Socket socConnection = null;/// <summary>/// 监听客户端发来的请求/// </summary>private void WatchConnecting(){while (true)  //持续不断监听客户端发来的请求
            {socConnection = socketWatch.Accept();txtMsg.AppendText("客户端连接成功! " + "\r\n");//创建一个通信线程 ParameterizedThreadStart pts = new ParameterizedThreadStart(ServerRecMsg);Thread thr = new Thread(pts);thr.IsBackground = true;//启动线程
                thr.Start(socConnection);}}/// <summary>/// 发送信息到客户端的方法/// </summary>/// <param name="sendMsg">发送的字符串信息</param>private void ServerSendMsg(string sendMsg){try{//将输入的字符串转换成 机器可以识别的字节数组byte[] arrSendMsg = Encoding.UTF8.GetBytes(sendMsg);//向客户端发送字节数组信息
                socConnection.Send(arrSendMsg);//将发送的字符串信息附加到文本框txtMsg上txtMsg.AppendText("服务器 " + GetCurrentTime() + "\r\n" + sendMsg + "\r\n");}catch (Exception ex) {txtMsg.AppendText("客户端已断开连接,无法发送信息！" + "\r\n");}}/// <summary>/// 接收客户端发来的信息 /// </summary>/// <param name="socketClientPara">客户端套接字对象</param>private void ServerRecMsg(object socketClientPara){Socket socketServer = socketClientPara as Socket;while (true){//创建一个内存缓冲区 其大小为1024*1024字节  即1Mbyte[] arrServerRecMsg = new byte[1024 * 1024];try{//将接收到的信息存入到内存缓冲区,并返回其字节数组的长度int length = socketServer.Receive(arrServerRecMsg);//将机器接受到的字节数组转换为人可以读懂的字符串string strSRecMsg = Encoding.UTF8.GetString(arrServerRecMsg, 0, length);//将发送的字符串信息附加到文本框txtMsg上  txtMsg.AppendText("天涯 " + GetCurrentTime() + "\r\n" + strSRecMsg + "\r\n");}catch (Exception ex) {txtMsg.AppendText("客户端已断开连接！" + "\r\n");break;}}}/// <summary>/// 发送消息到客户端/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void btnSendMsg_Click(object sender, EventArgs e){//调用 ServerSendMsg方法  发送信息到客户端ServerSendMsg(this.txtSendMsg.Text.Trim());this.txtSendMsg.Clear();}/// <summary>/// 快捷键 Enter 发送信息/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void txtSendMsg_KeyDown(object sender, KeyEventArgs e){//如果用户按下了Enter键if (e.KeyCode == Keys.Enter){//则调用 服务器向客户端发送信息的方法
                ServerSendMsg(txtSendMsg.Text.Trim());this.txtSendMsg.Clear();}}/// <summary>/// 获取当前系统时间的方法/// </summary>/// <returns>当前时间</returns>private DateTime GetCurrentTime(){DateTime currentTime = new DateTime();currentTime = DateTime.Now;return currentTime;}/// <summary>/// 获取本地IPv4地址/// </summary>/// <returns></returns>public IPAddress GetLocalIPv4Address() {IPAddress localIpv4 = null;//获取本机所有的IP地址列表IPAddress[] IpList = Dns.GetHostAddresses(Dns.GetHostName());//循环遍历所有IP地址foreach (IPAddress IP in IpList) {//判断是否是IPv4地址if (IP.AddressFamily == AddressFamily.InterNetwork){localIpv4 = IP;}else {continue;}}return localIpv4;}/// <summary>/// 获取本地IP事件/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void btnGetLocalIP_Click(object sender, EventArgs e){//接收IPv4的地址IPAddress localIP = GetLocalIPv4Address();//赋值给文本框this.txtIP.Text = localIP.ToString();}}
}

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;namespace TcpMsgClient
{public partial class FrmClient : Form{public FrmClient(){InitializeComponent();//关闭对文本框的非法线程操作检查TextBox.CheckForIllegalCrossThreadCalls = false;}//创建 1个客户端套接字 和1个负责监听服务端请求的线程  Socket socketClient = null;Thread threadClient = null;/// <summary>/// 连接服务端事件/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void btnListenServer_Click(object sender, EventArgs e){//定义一个套字节监听  包含3个参数(IP4寻址协议,流式连接,TCP协议)socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//需要获取文本框中的IP地址IPAddress ipaddress = IPAddress.Parse(this.txtIP.Text.Trim());//将获取的ip地址和端口号绑定到网络节点endpoint上IPEndPoint endpoint = new IPEndPoint(ipaddress, int.Parse(this.txtPort.Text.Trim()));//这里客户端套接字连接到网络节点(服务端)用的方法是Connect 而不是Bindtry{socketClient.Connect(endpoint);this.txtMsg.AppendText("客户端连接服务端成功！" + "\r\n");this.btnListenServer.Enabled = false;//创建一个线程 用于监听服务端发来的消息threadClient = new Thread(RecMsg);//将窗体线程设置为与后台同步threadClient.IsBackground = true;//启动线程
                threadClient.Start();}catch (Exception ex) {this.txtMsg.AppendText("远程服务端断开，连接失败！" + "\r\n");}         }/// <summary>/// 接收服务端发来信息的方法/// </summary>private void RecMsg(){while (true) //持续监听服务端发来的消息
            {try{//定义一个1M的内存缓冲区 用于临时性存储接收到的信息byte[] arrRecMsg = new byte[1024 * 1024];//将客户端套接字接收到的数据存入内存缓冲区, 并获取其长度int length = socketClient.Receive(arrRecMsg);//将套接字获取到的字节数组转换为人可以看懂的字符串string strRecMsg = Encoding.UTF8.GetString(arrRecMsg, 0, length);//将发送的信息追加到聊天内容文本框中txtMsg.AppendText("服务端 " + GetCurrentTime() + "\r\n" + strRecMsg + "\r\n");}catch (Exception ex) {this.txtMsg.AppendText("远程服务器已中断连接！"+"\r\n");this.btnListenServer.Enabled = true;break;}}}/// <summary>/// 发送字符串信息到服务端的方法/// </summary>/// <param name="sendMsg">发送的字符串信息</param>private void ClientSendMsg(string sendMsg){try { //将输入的内容字符串转换为机器可以识别的字节数组byte[] arrClientSendMsg = Encoding.UTF8.GetBytes(sendMsg);//调用客户端套接字发送字节数组
                socketClient.Send(arrClientSendMsg);//将发送的信息追加到聊天内容文本框中txtMsg.AppendText("天涯 " + GetCurrentTime() + "\r\n" + sendMsg + "\r\n");}catch(Exception ex){this.txtMsg.AppendText("远程服务器已中断连接,无法发送消息！" + "\r\n");}}private void btnSendMsg_Click(object sender, EventArgs e){//调用ClientSendMsg方法 将文本框中输入的信息发送给服务端ClientSendMsg(this.txtClientSendMsg.Text.Trim());this.txtClientSendMsg.Clear();}private void txtClientSendMsg_KeyDown(object sender, KeyEventArgs e){//当光标位于文本框时 如果用户按下了键盘上的Enter键 if (e.KeyCode == Keys.Enter){//则调用客户端向服务端发送信息的方法ClientSendMsg(this.txtClientSendMsg.Text.Trim());this.txtClientSendMsg.Clear();}}/// <summary>/// 获取当前系统时间的方法/// </summary>/// <returns>当前时间</returns>private DateTime GetCurrentTime(){DateTime currentTime = new DateTime();currentTime = DateTime.Now;return currentTime;}}
}