websocket即时通讯

websocket即时通讯目录一、websocket简介二、背景三、优点1、控制开销2、实时性更强3、保持连接状态4、更好的二进制支持5、支持扩展和更好的实现压缩效果四、原理1、客户端、服务器建立TCP连接,三次握手。2、TCP连接成功后,客户端通过HTTP协议向服务器传送websocket支持的版本号信息。(开始前的HTTP握手)3、服务器收到客户端的握手请求后,同样采用HTTP协议回馈数据。4、当收到了连接成功的消息后,通过TCP通道进行传输通信。五、websocket和socket的关系六、SuperWebSocket实现服务

大家好,又见面了,我是你们的朋友全栈君。

一、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 class Form1 : Form
{ 

public Form1()
{ 

InitializeComponent();
websocketServer();
}
private void websocketServer()
{ 

Log("我是服务端");
WebSocketServer webSocketServer = new WebSocketServer();
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();
}
private void WebSocketServer_NewSessionConnected(WebSocketSession session)
{ 

Log("欢迎客户端: 加入");
//SendToAll(session, msg);
}
private void WebSocketServer_NewMessageReceived(WebSocketSession session, string value)
{ 

Log("服务端收到客户端的数据 ==》"+value);
//SendToAll(session, value);
}
private void WebSocketServer_SessionClosed(WebSocketSession session, SuperSocket.SocketBase.CloseReason value)
{ 

Log("客户端:关闭,原因:");
//SendToAll(session, msg);
}
/// <summary>
/// 广播,同步推送消息给所有的客户端
/// </summary>
/// <param name="webSocketSession"></param>
/// <param name="msg"></param>
public static void SendToAll(WebSocketSession webSocketSession, string msg)
{ 

foreach (var item in webSocketSession.AppServer.GetAllSessions())
{ 

item.Send(msg);
}
}
private delegate void DoLog(string msg);
public void Log(string msg)
{ 

if (this.logReveal.InvokeRequired)
{ 

DoLog doLog = new DoLog(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 class Form1 : Form
{ 

public Form1()
{ 

InitializeComponent();
websocketServerTest();
}
public static WebSocket webSocket4Net = null;
public void websocketServerTest()
{ 

FileUtil.getInstance().Log("我是客户端");
webSocket4Net = new WebSocket("ws://127.0.0.1:1234");
webSocket4Net.Opened += WebSocket4Net_Opened;
webSocket4Net.Error += websocket_Error;
webSocket4Net.Closed += new EventHandler(websocket_Closed);
webSocket4Net.MessageReceived += WebSocket4Net_MessageReceived;
webSocket4Net.Open();
Thread thread = new Thread(ClientSendMsgToServer);
thread.IsBackground = true;
thread.Start();
//webSocket4Net.Dispose();
}
private void saveBtn_Click(object sender, EventArgs e)
{ 

websocketServerTest();
}
public void ClientSendMsgToServer()
{ 

int i = 1;
while (true)
{ 

webSocket4Net.Send("love girl" + i++);
Thread.Sleep(TimeSpan.FromSeconds(5));
}
}
private void WebSocket4Net_MessageReceived(object sender, MessageReceivedEventArgs e)
{ 

FileUtil.getInstance().Log("服务端回复的数据:" + e.Message);
}
private void WebSocket4Net_Opened(object sender, EventArgs e)
{ 

FileUtil.getInstance().Log("客户端连接成功!发送数据中...");
webSocket4Net.Send("来自客户端,准备发送数据!");
}
private void websocket_Error(object sender, EventArgs e)
{ 

FileUtil.getInstance().Log("WebSocket错误");
Thread.Sleep(5000);
if (webSocket4Net.State!= WebSocketState.Open&&webSocket4Net.State!=WebSocketState.Connecting)
{ 

websocketServerTest();
}
}
private void websocket_Closed(object sender, EventArgs e)
{ 

FileUtil.getInstance().Log("WebSocket已关闭");
Thread.Sleep(5000);
if (webSocket4Net.State != WebSocketState.Open && webSocket4Net.State != WebSocketState.Connecting)
{ 

websocketServerTest();
}
}
}
}

九、客户端向服务端发送消息

1、客户端

在这里插入图片描述

2、服务端

在这里插入图片描述

? Java学习路线总结,搬砖工逆袭Java架构师?

在这里插入图片描述


添加微信,备注1024,获取Java学习路线思维导图

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/157286.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • 《Java多线程编程核心技术》推荐

    《Java多线程编程核心技术》推荐

    2020年11月12日
  • zookeeper的基本操作_奇门遁甲实战入门之五

    zookeeper的基本操作_奇门遁甲实战入门之五本原创入门教程,涵盖ZooKeeper核心内容,通过实例和大量图表,结合实战,帮助学习者理解和运用,任何问题欢迎留言。目录:zookeeper介绍与核心概念 安装和使用 ZooKeeper分布式锁实现 ZooKeeper框架Curator分布式锁实现及源代码分析 zookeeper开发实战(java客户端)本章是后续学习的基石,只有充分理解了分布式系统的概念和面临的问题,以及Z…

  • python里面requests库(python如何爬取网页数据)

    一、什么是RequestsRequests是⽤Python语⾔编写,基于urllib,采⽤Apache2Licensed开源协议的HTTP库。它⽐urllib更加⽅便,可以节约我们⼤量的⼯作,完全满⾜HTTP测试需求。⼀句话——Python实现的简单易⽤的HTTP库二、安装Requests库进入命令行win+R执行命令:pipinstallrequests…

  • linux当前时间命令(shell脚本获取当前日期前一天)

    主要介绍Linux常用命令,可以帮助新手快速掌握Linux系统的基本使用,值得收藏。。

  • EagleEye_eyekey

    EagleEye_eyekey摘要:EagleEye作为阿里集团老牌的链路跟踪系统,其自身业务虽不在交易链路上,但却监控着全集团的链路状态,特别是在中间件的远程调用上,覆盖了集团绝大部分的场景,在问题排查和定位上发挥着巨大的作用,保障了各个系统的稳定性,为整个技术团队打赢这场战役保驾护航。作者:王华锋(水彧)背景 双十一一直是阿里巴巴集团每年要打的一场大战役。要打赢这场战役,技术上,不仅仅是几个应用、几个

  • 深度学习 CNN卷积神经网络 LeNet-5详解

    深度学习 CNN卷积神经网络 LeNet-5详解卷积神经网络(ConvolutionalNeuralNetwork,CNN):是一种常见的深度学习架构,受生物自然视觉认知机制(动物视觉皮层细胞负责检测光学信号)启发而来,是一种特殊的多层前馈神经网络。它的人工神经元可以响应一部分覆盖范围内的周围单元,对于大型图像处理有出色表现。一般神经网络VS卷积神经网络:相同点:卷积神经网络也使用

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号