使用WebSocket构建实时聊天
HTTP协议的生命周期是通过Request和Response来界定的,而Response是被动的(服务端不能主动与客户端通信),收到 一次请求才会返回一次响应。而当服务端需要主动和客户端进行通信,或者需要建立全双工通信(保持在一个连接中)时,HTTP就力不从心了。 在Websocket出现之前,实现全双工通信的方式主要是ajax轮询和long poll,这样是非常消耗性能的。 WebSocket是HTML5 新增加的特性之一,目前主流浏览器大都提供了对其的支持。其特点是可以在客户端和服务端之间建立全双工通信,一些特殊场景,例如实时通信、在线游戏、多人协作等,WebSocket都可以作为解决方案。 Spring自4.0版本后增加了WebSocket支持,本例就使用Spring WebSocket构建一个简单实时聊天的应用。 Spring WebSocket提供了一个WebSocketHandler接口,这个接口提供了WebSocket连接建立后生命周期的处理方法。 WebSocketSession不同于HttpSession,每次断开连接(正常断开或发生异常断开)都会重新起一个WebSocketSession。 这个抽象类提供了一系列对WebSocketSession及传输消息的处理方法: spring WebSocket提供了四种WebSocketMessage的实现:TextMessage(文本类消息)、BinaryMessage(二进制消息)、PingMessage、PongMessage(后两者用于心跳检测,在一端收到了Ping消息的时候,该端点必须发送Pong消息给对方,以检测该连接是否存在和有效)。 HandshakeInterceptor接口是WebSocket连接握手过程的拦截器,通过实现该接口可以对握手过程进行管理。值得注意的是,beforeHandshake中的attributes与WebSocketSession中通过getAttributes();返回的Map是同一个Map,我们可以在其中放入一些用户的特定信息。 通过实现WebSocketConfigurer接口,可以注册相应的WebSocket处理器、路径、允许域、SockJs支持。 url为指定的WebSocket注册路径,当协议为http时,使用ws://,当协议为https,使用wss://。 onmessage的event对象: 可以看出,应使用event.data获取服务端发送的消息。 有的浏览器不支持WebSocket,使用SockJs可以模拟WebSocket。 以下使用WebSocket构建一个实时聊天应用。 1.客户端与服务端通信只使用TextMessage(文本类消息),客户端只能发送聊天文本,服务端可以单播和广播消息,包括聊天文本、上线、下线、掉线、用户列表信息、认证信息和服务器时间。 2.以HttpSession来唯一区别用户,而不是WebSocketSession。 3.核心思路是当新的WebSocketSession建立时,将其加入一个集合,当该session失效时(close、error)将其从集合中删除,当服务端需要单播或广播消息时,以这个集合为根据。 新建Spring Boot项目,添加必要依赖。 (其实在WebSocket中已经没有了请求、响应之分,但习惯上将客户端发送的消息称为请求,服务端发送的消息称为响应) 从chrome的WS控制台,我们可以看到发送的信息 通过setAllowedOrigins(String... origins);方法可以限制访问,查看WebSocket Request Headers的Origin属性: 这种限制与限制跨域是类似的,不同的是端口号不在其限制范围内。可以通过setAllowedOrigins("*");的方式设置允许所有域。 使用WebSocket构建实时聊天 苦逼的IE同志说不出话来,只算到IE11可能不支持WebSocket,没想到他其实是不支持contenteditable="plaintext-only"(后来又发现火狐也不支持)。 WebSocket是一个长连接,需要心跳检测机制来判断服务端与客户端之间建立的WebSocket连接是否存在和有效。当服务端断开连接时,客户端会立马断开连接,并调用websocket.close,而当客户端出现中断网络连接的情况,服务端不会立马作出反应(Spring WebSocket不会),而是过一段时间(推测是几分钟)后才将这个断掉的WebSocketSession踢出。 使用WebSocket构建实时聊天
websocket实现即时通讯怎么操作?
要使用WebSocket实现即时通讯,可以按照以下步骤进行操作:
1,打开浏览器并创建WebSocket对象:在需要与服务器进行通信的页面中添加JavaScript代码,创建WebSocket对象。
例如:
var ws = new WebSocket("ws://server_ip:port");
其中 "ws://server_ip:port" 是WebSocket服务器的地址和端口号。
2,监听WebSocket事件:为WebSocket对象添加事件监听器来处理与服务器的连接、消息接收等事件。例如:
ws.onopen = function() {
console.log("WebSocket连接已打开。");
};
ws.onmessage = function(event) {
console.log("收到消息:" + event.data);
};
ws.onclose = function() {
console.log("WebSocket连接已关闭。");
};
3,发送消息:使用WebSocket对象的send()方法向服务器发送消息。例如:
ws.send("Hello, Server!");
4,服务器端实现:在服务器端编写WebSocket服务端程序来处理来自客户端的连接请求、接收和发送消息等操作。
WebSocket是一种基于TCP协议的全双工通信协议,在实现即时通讯功能时具有优秀的性能和体验表现。以上只是简单介绍了WebSocket的基本操作流程,具体实现方式还需要根据具体需求和情况来调整和完善。