目录
一、websocket简介
websocket是一种在单个TCP连接上进行全双工通信的协议。
websocket使得客户端和服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送数据。在WebSocket API中,浏览器和服务器只需要完成一次握手,两者之间就直接可以创建持久性的连接,并进行双向数据传输。
二、背景
很多网站为了实现推送技术,所用的技术都是轮询。
轮询是在特定的时间间隔,由浏览器对客户端发出HTTP请求,然后由服务器返回最新的数据给客户端的浏览器。这种传统的模式带来很明显的缺点,即浏览器需要不断的向服务器发出请求,然后HTTP请求可能包含较长的头部,其中真正有效的数据可能只是很小的一部分,显然这样会浪费很多的宽带等资源。
在这种情况下,HTML5定义了websocket协议,能更好的节省服务器资源和宽带,而且能够更实时地进行通讯。
三、优点
1、控制开销
创建连接后,服务器和客户端之间交换数据时,用于协议控制的数据包头部相对较小。
2、实时性更强
由于协议是全双工的,所以服务器可以随时主动给客户端下发数据。相对于HTTP请求需要等待客户端发起请求服务端才能响应,延迟明显更少。
3、保持连接状态
与HTTP不同的是,Websocket需要先创建连接,这就使得其成为一种有状态的协议,之后通信时可以省略部分状态信息。而HTTP请求可能需要在每个请求都携带状态信息(如身份认证等)。
4、更好的二进制支持
5、支持扩展和更好的实现压缩效果
四、原理
websocket同HTTP一样也是应用层的协议,但是它是一种双向通信协议,建立在TCP之上的。
连接过程(握手过程)
1、客户端、服务器建立TCP连接,三次握手。
这是通信的基础,传输控制层,若失败后续都不执行。
2、TCP连接成功后,客户端通过HTTP协议向服务器传送websocket支持的版本号信息。(开始前的HTTP握手)
3、服务器收到客户端的握手请求后,同样采用HTTP协议回馈数据。
4、当收到了连接成功的消息后,通过TCP通道进行传输通信。
五、websocket和socket的关系
socket其实并不是一个协议,而是为了方便使用TCP和UDP而抽象出来的一层,是位于应用层和传输控制层之间的一组接口。
socket是应用层与TCP/IP协议通信的中间软件抽象层,它是一组接口。在设计模式中,socket其实就是一个门面模式,它把复杂的TCP/IP协议隐藏在socket接口后面,对用户来说,一组简单的接口就是全部,让socket去组织数据,以符合指定的协议。
两台主机通信,必须通过socket连接,socket则利用TCP/IP协议建立TCP连接。TCP连接则更依靠于底层的IP协议,IP协议的连接则依赖于链路层等更低层次。
websocket则是一个典型的应用层协议。
六、通过IpIdea实现Socks5
1、ipidea简介
全球领先的互联网大数据IP资源
ipidea是一家海外爬虫代理商,提供海外住宅ip和海外静态ip,主要是做数据采集的业务,与多个数据采集企业保持长期的合作。它提供9000万ip资源,可以根据抓取需求自定义设置ip轮换时间,从而避免被网站阻止访问。支持账密认证和API提取两种方式提取ip资源,最重要的是支持免费测试。
Socks5代理是Socks的增强版,使用代理服务器可以很好地隐藏匿名访问任何在线信息。
2、Socks5代理可以适用的业务场景
(1)ip封锁
当您尝试从试图限制您的网站访问信息,ip很可能会被封锁。使用socks 5代理可以帮助消除此类限制,使你能正常访问网站。
(2)协议限制
当您尝试使用不同的请求(例如HTTP、HTTPS等)总会有某种限制可能会造成障碍。socks 5代理可以轻松管理任何类型的流量、程序或协议。
(3)提高互联网速度和连接
socks 5代理,由于使用UDP协议,它提供了高效和卓越的互联网性能。其他协议支持TCP主要侧重于根据设置的格式交换包,而UDP则侧重于其他相关因素。UDP不专注于将数据包转换为固定数据包,这使其成为socks 5为用户提供更快和更可靠的互联网连接的理想选择。
(4)减少错误计数并提高性能
socks 5代理是一个不会错误路由或错误标记数据包的代理。
注意,实际上并不是所有代理商都支持socks5协议的,ipidea是支持socks5协议的代理商之一。
七、SuperWebSocket实现服务端
1、创建窗口程序,WindowsFormsWebsocketServer
2、添加程序包
工具 -->Nuget包管理 -->管理解决方案的Nuget程序包 -->搜索 SuperWebSocket ,选择SuperWebSocketNETServer,点击右侧 安装,等待安装完成,安装完成以后,项目会多出很多引用库,如下
3、代码实例
using SuperWebSocket;
using System;
using System.Windows.Forms;
namespace WindowsFormsWebsocketServer{public partial classForm1:Form{publicForm1(){InitializeComponent();websocketServer();}privatevoidwebsocketServer(){Log("我是服务端");WebSocketServer webSocketServer =newWebSocketServer();webSocketServer.NewSessionConnected+=WebSocketServer_NewSessionConnected;webSocketServer.NewMessageReceived+=WebSocketServer_NewMessageReceived;webSocketServer.SessionClosed+=WebSocketServer_SessionClosed;if(!webSocketServer.Setup("127.0.0.1",1234)){Log("设置服务监听失败!");}if(!webSocketServer.Start()){Log("启动服务监听失败!");}Log("启动服务监听成功!");//webSocketServer.Dispose();}privatevoidWebSocketServer_NewSessionConnected(WebSocketSession session){Log("欢迎客户端: 加入");//SendToAll(session, msg);}privatevoidWebSocketServer_NewMessageReceived(WebSocketSession session, string value){Log("服务端收到客户端的数据 ==》"+value);//SendToAll(session, value);}privatevoidWebSocketServer_SessionClosed(WebSocketSession session,SuperSocket.SocketBase.CloseReason value){Log("客户端:关闭,原因:");//SendToAll(session, msg);}/// <summary>/// 广播,同步推送消息给所有的客户端/// </summary>/// <param name="webSocketSession"></param>/// <param name="msg"></param>publicstaticvoidSendToAll(WebSocketSession webSocketSession, string msg){
foreach (var item in webSocketSession.AppServer.GetAllSessions()){item.Send(msg);}}private delegate voidDoLog(string msg);publicvoidLog(string msg){if(this.logReveal.InvokeRequired){DoLog doLog =newDoLog(Log);this.logReveal.Invoke(doLog,new object[]{ msg });}else{if(this.logReveal.Items.Count>20){this.logReveal.Items.RemoveAt(0);}
msg =DateTime.Now.ToLocalTime().ToString()+" "+ msg;this.logReveal.Items.Add(msg);}}}}
八、WebSocket4Net实现客户端
1、创建窗口程序,WindowsFormsWebsocketClient
2、添加程序包
工具 -->Nuget包管理 -->管理解决方案的Nuget程序包 -->搜索 WebSocket4Net ,选择WebSocket4Net,点击右侧 安装,等待安装完成,安装完成以后,项目会多出很多引用库,如下
3、代码实例
using System;
using WebSocket4Net;
using System.Threading;
using System.Windows.Forms;
namespace WindowsFormsWebsocketClient{public partial classForm1:Form{publicForm1(){InitializeComponent();websocketServerTest();}publicstaticWebSocket webSocket4Net =null;publicvoidwebsocketServerTest(){FileUtil.getInstance().Log("我是客户端");
webSocket4Net =newWebSocket("ws://127.0.0.1:1234");webSocket4Net.Opened+=WebSocket4Net_Opened;webSocket4Net.Error+= websocket_Error;webSocket4Net.Closed+=newEventHandler(websocket_Closed);webSocket4Net.MessageReceived+=WebSocket4Net_MessageReceived;webSocket4Net.Open();Thread thread =newThread(ClientSendMsgToServer);thread.IsBackground=true;thread.Start();//webSocket4Net.Dispose();}privatevoidsaveBtn_Click(object sender,EventArgs e){websocketServerTest();}publicvoidClientSendMsgToServer(){int i =1;while(true){webSocket4Net.Send("love girl"+ i++);Thread.Sleep(TimeSpan.FromSeconds(5));}}privatevoidWebSocket4Net_MessageReceived(object sender,MessageReceivedEventArgs e){FileUtil.getInstance().Log("服务端回复的数据:"+e.Message);}privatevoidWebSocket4Net_Opened(object sender,EventArgs e){FileUtil.getInstance().Log("客户端连接成功!发送数据中...");webSocket4Net.Send("来自客户端,准备发送数据!");}privatevoidwebsocket_Error(object sender,EventArgs e){FileUtil.getInstance().Log("WebSocket错误");Thread.Sleep(5000);if(webSocket4Net.State!=WebSocketState.Open&&webSocket4Net.State!=WebSocketState.Connecting){websocketServerTest();}}privatevoidwebsocket_Closed(object sender,EventArgs e){FileUtil.getInstance().Log("WebSocket已关闭");Thread.Sleep(5000);if(webSocket4Net.State!=WebSocketState.Open&&webSocket4Net.State!=WebSocketState.Connecting){websocketServerTest();}}}}
九、客户端向服务端发送消息
1、客户端
2、服务端
十、哪吒社区万粉计划
- Vue.js框架与Web前端开发
- Python网络编程从入门到精通
- 亿级流量Java高并发与网络编程实战
- Spring Cloud Alibaba微服务实战
🍅 Java学习路线总结,搬砖工逆袭Java架构师🍅
🍅 Java学习路线总结,搬砖工逆袭Java架构师🍅
添加微信,备注1024,获取Java学习路线思维导图
版权归原作者 哪 吒 所有, 如有侵权,请联系我们删除。