学习Socket编写的聊天室小程序

1.前言

在学习Socket之前&＃xff0c;先来学习点网络相关的知识吧&＃xff0c;自己学习过程中的一些总结&＃xff0c;Socket是一门很高深的学问&＃xff0c;本文只是Socket一些最基础的东西&＃xff0c;大神请自觉绕路。

传输协议

TCP&＃xff1a;Transmission Control Protocol 传输控制协议TCP是一种面向连接&＃xff08;连接导向&＃xff09;的、可靠的、基于字节流的运输层&＃xff08;Transport layer&＃xff09;通信协议。

特点&＃xff1a;

面向连接的协议&＃xff0c;数据传输必须要建立连接&＃xff0c;所以在TCP中需要连接时间。

传输数据大小限制&＃xff0c;一旦连接建立&＃xff0c;双方可以按统一的格式传输大的数据。

一个可靠的协议&＃xff0c;确保接收方完全正确地获取发送方所发送的全部数据。

说到TCP就不得不说经典的三次握手。

在TCP/IP协议中&＃xff0c;TCP协议通过三次握手建立一个可靠的连接

第一次握手&＃xff1a;客户端尝试连接服务器&＃xff0c;向服务器发送syn包&＃xff08;同步序列编号Synchronize Sequence Numbers&＃xff09;&＃xff0c;syn&＃61;j&＃xff0c;客户端进入SYN_SEND状态等待服务器确认

第二次握手&＃xff1a;服务器接收客户端syn包并确认&＃xff08;ack&＃61;j&＃43;1&＃xff09;&＃xff0c;同时向客户端发送一个SYN包&＃xff08;syn&＃61;k&＃xff09;&＃xff0c;即SYN&＃43;ACK包&＃xff0c;此时服务器进入SYN_RECV状态

第三次握手&＃xff1a;第三次握手&＃xff1a;客户端收到服务器的SYN&＃43;ACK包&＃xff0c;向服务器发送确认包ACK(ack&＃61;k&＃43;1&＃xff09;&＃xff0c;此包发送完毕&＃xff0c;客户端和服务器进入ESTABLISHED状态&＃xff0c;完成三次握手

学习Socket编写的聊天室小程序

UDP&＃xff1a; User Datagram Protocol的简称&＃xff0c; 中文名是用户数据包协议&＃xff0c;是 OSI 参考模型中一种无连接的传输层协议&＃xff0c;提供面向事务的简单不可靠信息传送服务。

特点&＃xff1a;

每个数据报中都给出了完整的地址信息&＃xff0c;因此无需要建立发送方和接收方的连接。

UDP传输数据时是有大小限制的&＃xff0c;每个被传输的数据报必须限定在64KB之内。

UDP是一个不可靠的协议&＃xff0c;发送方所发送的数据报并不一定以相同的次序到达接收方。

TCP协议&＃xff1a;就好比两个电话机通过电话线进行数据交互的格式约定

HTTP协议&＃xff1a;就好比两个人通过电话机说话的语法。

&＃xff08;1&＃xff09;公认端口&＃xff08;WellKnownPorts&＃xff09;&＃xff1a;从0到1023&＃xff0c;它们紧密绑定&＃xff08;binding&＃xff09;于一些服务。通常这些端口的通讯明确表明了某种服务的协议。例如&＃xff1a;80端口实际上总是HTTP通讯。

&＃xff08;2&＃xff09;注册端口&＃xff08;RegisteredPorts&＃xff09;&＃xff1a;从1024到49151。它们松散地绑定于一些服务。也就是说有许多服务绑定于这些端口&＃xff0c;这些端口同样用于许多其它目的。例如&＃xff1a;许多系统处理动态端口从1024左右开始。

&＃xff08;3&＃xff09;动态和/或私有端口&＃xff08;Dynamicand/orPrivatePorts&＃xff09;&＃xff1a;从49152到65535。理论上&＃xff0c;不应为服务分配这些端口。实际上&＃xff0c;机器通常从1024起分配动态端口。

OSI网络7层模型

学习Socket编写的聊天室小程序

TCP/IP&＃xff08;Transmission Control Protocol/Internet Protocol&＃xff09;即传输控制协议/网间协议&＃xff0c;是一个工业标准的协议集&＃xff0c;它是为广域网&＃xff08;WANs&＃xff09;设计的。

UDP&＃xff08;User Data Protocol&＃xff0c;用户数据报协议&＃xff09;是与TCP相对应的协议。它是属于TCP/IP协议族中的一种。

应用层 (Application)&＃xff1a;应用层是个很广泛的概念&＃xff0c;有一些基本相同的系统级 TCP/IP 应用以及应用协议&＃xff0c;也有许多的企业商业应用和互联网应用。

传输层 (Transport)&＃xff1a;传输层包括 UDP 和 TCP&＃xff0c;UDP 几乎不对报文进行检查&＃xff0c;而 TCP 提供传输保证。

网络层 (Network)&＃xff1a;网络层协议由一系列协议组成&＃xff0c;包括 ICMP、IGMP、RIP、OSPF、IP(v4,v6) 等。

链路层 (Link)&＃xff1a;又称为物理数据网络接口层&＃xff0c;负责报文传输。

IP地址

每台联网的电脑都有一个唯一的IP地址。

长度32位&＃xff0c;分为四段&＃xff0c;每段8位&＃xff0c;用十进制数字表示&＃xff0c;每段范围 0 ~ 255

特殊IP&＃xff1a;127.0.0.1 用户本地网卡测试

版本&＃xff1a;V4(32位) 和 V6(128位&＃xff0c;分为8段&＃xff0c;每段16位)

端口

在网络上有很多电脑&＃xff0c;这些电脑一般运行了多个网络程序。每种网络程序都打开一个Socket&＃xff0c;并绑定到一个端口上&＃xff0c;不同的端口对应于不同的网络程序。

常用端口&＃xff1a;21 FTP ,25 SMTP ,110 POP3 ,80 HTTP , 443 HTTPS

有两种常用Socket类型&＃xff1a;

流式Socket&＃xff08;STREAM&＃xff09;&＃xff1a;

是一种面向连接的Socket&＃xff0c;针对于面向连接的TCP服务应用&＃xff0c;安全&＃xff0c;但是效率低

数据报式Socket&＃xff08;DATAGRAM&＃xff09;&＃xff1a;

是一种无连接的Socket,对应于无连接的UDP服务应用.不安全(丢失,顺序混乱,在接收端要分析重排及要求重发),但效率高.

说了那么多&＃xff0c;让我们来看看socket在网络7层协议中的位置。如下图所示

2.聊天室原理

学习Socket编写的聊天室小程序

Socket 流式(服务器端和客户端

服务器端的Socket(至少需要两个)

一个负责接收客户端连接请求(但不负责与客户端通信)

每成功接收到一个客户端的连接便在服务端产生一个对应的负责通信的Socket

在接收到客户端连接时创建.

为每个连接成功的客户端请求在服务端都创建一个对应的Socket(负责和客户端通信).

客户端的Socket

客户端Socket

必须指定要连接的服务端IP地址和端口。

通过创建一个Socket对象来初始化一个到服务器端的TCP连接

Socket的通讯过程

服务器端&＃xff1a;

申请一个socket

绑定到一个IP地址和一个端口上

开启侦听&＃xff0c;等待接授连接

客户端&＃xff1a;

申请一个socket

连接服务器&＃xff08;指明IP地址和端口号&＃xff09;

l服务器端接到连接请求后&＃xff0c;产生一个新的socket(端口大于1024&＃xff09;与客户端建立连接并进行通讯&＃xff0c;原监听socket继续监听。

Socket常用的一些类和方法

IPAddress类&＃xff1a;包含了一个IP地址

IPEndPoint类&＃xff1a;包含了一对IP地址和端口号

Socket : 创建一个Socket

Bind: 绑定一个本地的IP和端口号(IPEndPoint)

Listen: 让Socket侦听传入的连接尝试&＃xff0c;并指定侦听队列容量

Connect: 初始化与另一个Socket的连接

Accept: 接收连接并返回一个新的socket

Send: 输出数据到Socket

Receive: 从Socket中读取数据

Close: 关闭Socket (销毁连接)

3.聊天室代码

服务器端代码:

using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;namespace Server
{using System.Net.Sockets;using System.Net;using System.Threading;public partial class Form1 : Form{

public Form1{InitializeComponent;TextBox.CheckForIllegalCrossThreadCalls &＃61; false;}

//服务端监听套接字Socket socketWatch &＃61; null;//服务端监听线程Thread threadWatch &＃61; null;//字典集合&＃xff1a;保存通信套接字Dictionary dictCon &＃61; new Dictionary;

private void btnStartListen_Click(object sender, EventArgs e){try{//1.创建监听套接字使用 ip4协议&＃xff0c;流式传输&＃xff0c;TCP连接socketWatch &＃61; new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//2.绑定端口//2.1获取网络节点对象IPAddress address &＃61; IPAddress.Parse(txtIP.Text);IPEndPoint endPoint &＃61; new IPEndPoint(address, int.Parse(txtPort.Text));//2.2绑定端口&＃xff08;其实内部就向系统的端口表中注册了一个端口&＃xff0c;并指定了当前程序句柄&＃xff09;socketWatch.Bind(endPoint);//2.3设置监听队列socketWatch.Listen(10);//2.4开始监听,调用监听线程执行监听套接字的监听方法threadWatch &＃61; new Thread(WatchConnecting);threadWatch.IsBackground &＃61; true;threadWatch.Start;ShowMsg("枫伶忆,服务器启动啦&＃xff01;");}catch (Exception ex){MessageBox.Show(ex.Message);throw;}}

void WatchConnecting{//2.4开始监听&＃xff1a;此方法会阻断当前线程&＃xff0c;直到有其它程序连接过来&＃xff0c;才执行完毕Socket sokMsg &＃61; socketWatch.Accept;//将当前连接成功的【与客户端通信的套接字】的标识保存起来&＃xff0c;并显示到列表中//将远程客户端的 ip和端口字符串存入列表this.lbOnline.Items.Add(sokMsg.RemoteEndPoint.ToString);//将服务端的通信套接字存入字典集合dictCon.Add(sokMsg.RemoteEndPoint.ToString, sokMsg);ShowMsg("有客户端连接了&＃xff01;");//2.5创建通信线程Thread thrMsg &＃61; new Thread(ReceiveMsg);thrMsg.IsBackground &＃61; true;thrMsg.Start(sokMsg);}

void ReceiveMsg(object obj){try{Socket sokMsg &＃61; obj as Socket;//3.通信套接字监听客户端的消息//3.1创建消息缓存区byte arrMsg &＃61; new byte[1024 * 1024 * 1];while (isReceive){//3.2接收客户端的消息并存入缓存区,注意&＃xff1a;Receive方法也会阻断当前的线程sokMsg.Receive(arrMsg);//3.3将接收到的消息转成字符串string strMsg &＃61; System.Text.Encoding.UTF8.GetString(arrMsg);//3.4将消息显示到文本框ShowMsg(strMsg);}}catch (Exception ex){MessageBox.Show(ex.Message);throw;}}

void ShowMsg(string strmsg){this.txtShow.AppendText(strmsg &＃43; "\r\n");}

private void btnSend_Click_1(object sender, EventArgs e){string strClient &＃61; this.lbOnline.Text;if (string.IsNullOrEmpty(strClient)){MessageBox.Show("请选择你要发送消息的客户端");return;}if (dictCon.ContainsKey(strClient)){string strMsg &＃61; this.txtInput.Text.Trim;ShowMsg("\r\n向客户端【" &＃43; strClient &＃43; "】说&＃xff1a;" &＃43; strMsg);//使用指定的通信套接字将字符串发送到指定的客户端byte arrMsg &＃61; System.Text.Encoding.UTF8.GetBytes(strMsg);dictCon[strClient].Send(arrMsg);}this.txtInput.Text &＃61; "";}

}}

客户端代码:

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;namespace Client
{using System.Net.Sockets;using System.Net;using System.Threading;public partial class Form1 : Form{

public Form1{InitializeComponent;TextBox.CheckForIllegalCrossThreadCalls &＃61; false;}

//客户端通信套接字Socket socketMsg &＃61; null;//客户端通信线程Thread threadMsg &＃61; null;bool isRec &＃61; true;//标记任务

private void btnConnect_Click(object sender, EventArgs e){try{//1.创建监听套接字使用 ip4协议&＃xff0c;流式传输&＃xff0c;TCP连接socketMsg &＃61; new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//2.获取要连接的服务端节点//2.1获取网络节点对象IPAddress address &＃61; IPAddress.Parse(txtIP.Text);IPEndPoint endPoint &＃61; new IPEndPoint(address, int.Parse(txtPort.Text));//3.向服务端发送链接请求socketMsg.Connect(endPoint);ShowMsg("连接服务器成功~~&＃xff01;");//4.开启通信线程threadMsg &＃61; new Thread(RecevieMsg);threadMsg.IsBackground &＃61; true;threadMsg.Start;}catch (Exception ex){MessageBox.Show(ex.Message);throw;}}

void RecevieMsg{try{//3.1创建消息缓存区byte arrMsg &＃61; new byte[1024 * 1024 * 1];while (isRec){socketMsg.Receive(arrMsg);string strMsg &＃61; System.Text.Encoding.UTF8.GetString(arrMsg);ShowMsg("\r\n服务器说&＃xff1a;" &＃43; strMsg);}}catch (Exception ex){MessageBox.Show(ex.Message);throw;}}

private void btnSend_Click_1(object sender, EventArgs e){string strMsg &＃61; this.txtInput.Text.Trim;byte arrMsg &＃61; System.Text.Encoding.UTF8.GetBytes(strMsg);socketMsg.Send(arrMsg);this.txtInput.Text &＃61; "";}

void ShowMsg(string strmsg){this.txtShow.AppendText(strmsg &＃43; "\r\n");}

}

最终的效果图如下:

学习Socket编写的聊天室小程序