做h5页面网站有哪些,域名多少钱一年,WordPress又拍云联盟代码,保定网站建设系统目录
一.C/S架构#xff1a;
二.Http协议与WebSocket协议的区别#xff1a;
1.Http协议与WebSocket协议的区别#xff1a;
2.WebSocket协议的使用场景#xff1a;
三.项目实际操作#xff1a;
1.导入依赖#xff1a;
2.通过WebSocket实现页面与服务端保持长连接
二.Http协议与WebSocket协议的区别
1.Http协议与WebSocket协议的区别
2.WebSocket协议的使用场景
三.项目实际操作
1.导入依赖
2.通过WebSocket实现页面与服务端保持长连接
3.在config创建WebSocketConfig配置类来开启WebSocket支持
4.在nginx.conf中配置路径
5.推送消息案例 一.C/S架构
我们都知道JavaWeb项目通常是在服务器端部署的。一般我们在开发时候会用到 C / S 架构也就是客户端 / 服务器。客户端是指用户的设备比如个人电脑、手机或平板等它们运行的是浏览器软件通过HTTP协议向服务器发送请求并接收响应。服务器端则是专门用于处理这些请求的服务器如Tomcat、Jetty或IIS这样的Web服务器它们负责运行Java应用程序并执行业务逻辑。
当用户打开浏览器输入URL访问JavaWeb应用时浏览器会发起一个HTTP GET或POST请求到服务器的特定地址即应用的URL。服务器接收到这个请求后解析其内容调用相应的JavaServlet或JSPJava Server Pages执行预定义的业务逻辑并生成HTML响应。然后服务器将响应返回给客户端客户端再呈现给用户。
二.Http协议与WebSocket协议的区别
我们看下面的图 学过 Javaweb 都会了解 Http 协议 Http 协议有一个缺陷通信只能由客户端发起HTTP 协议做不到服务器主动向客户端推送信息。所以这个时候我们就需要一个协议来解决这个问题而这时候就要介绍 WebSocket 协议。
1.Http协议与WebSocket协议的区别
WebSocket是基于TCP的一种新的网络协议。它实现了浏览器与服务器全双工通信——浏览器和服务器只需要完成一次握手两者之间就可以创建持久性的连接并进行双向数据传输。根据上图图的右侧黄色框其代表的是连接的生命周期很容易发现 Http 的连接的声明周期断断续续代表如果通过 Http 协议多次访问就需要连接多次这就叫做短链接而 WebSocket 协议可以持久性的连接也叫做长连接。还有就是 Http 协议的通信是单向的基于请求响应模式而 WebSocket 支持双向通信。
下面表格为上面的总结
Http协议与WebSocket协议的区别 Http协议WebSocket协议短连接长连接单向通信双向通信
2.WebSocket协议的使用场景
视频弹幕网页聊天体育实况更新......
三.项目实际操作
1.导入依赖
dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-websocket/artifactId
/dependency 2.通过WebSocket实现页面与服务端保持长连接
在WebSocket包下导入 WebSocketServer WebSocket 的服务端组件用于与客户端通信
/*** WebSocket服务*/
Component
ServerEndpoint(/ws/{sid})//根据路径匹配以此请求服务端的组件
public class WebSocketServer {//存放会话对象private static MapString, Session sessionMap new HashMap();/*** 连接建立成功调用的方法*/OnOpenpublic void onOpen(Session session, PathParam(sid) String sid) {System.out.println(客户端 sid 建立连接);sessionMap.put(sid, session);}/*** 收到客户端消息后调用的方法** param message 客户端发送过来的消息*/OnMessagepublic void onMessage(String message, PathParam(sid) String sid) {System.out.println(收到来自客户端 sid 的信息: message);}/*** 连接关闭调用的方法** param sid*/OnClosepublic void onClose(PathParam(sid) String sid) {System.out.println(连接断开: sid);sessionMap.remove(sid);}/*** 群发** param message*/public void sendToAllClient(String message) {CollectionSession sessions sessionMap.values();for (Session session : sessions) {try {//服务器向客户端发送消息session.getBasicRemote().sendText(message);} catch (Exception e) {e.printStackTrace();}}}
}
3.在config创建WebSocketConfig配置类来开启WebSocket支持
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;
/*** 开启WebSocket支持*/
Configuration
public class WebSocketConfig { Bean public ServerEndpointExporter serverEndpointExporter() { return new ServerEndpointExporter(); } } 为了方便查看我们使用效果我们创建一个定时任务类用了SpringTask框架
import com.sky.Websocket.WebSocketServer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;Component
public class WebSocketTask {Autowiredprivate WebSocketServer webSocketServer;/*** 通过WebSocket每隔5秒向客户端发送消息*/Scheduled(cron 0/5 * * * * ?)public void sendMessageToClient() {webSocketServer.sendToAllClient(这是来自服务端的消息 DateTimeFormatter.ofPattern(HH:mm:ss).format(LocalDateTime.now()));}
}
随后我们启动这个项目在前段页面会每隔五秒输出内容。 上面是我们服务端给客户端发消息同样我们基于 WebSocket 协议也可以通过客户端给服务端发消息。
当然我们下面看一下前端的代码展示
!DOCTYPE HTML
html
headmeta charsetUTF-8titleWebSocket Demo/title
/head
bodyinput idtext typetext /button onclicksend()发送消息/buttonbutton onclickcloseWebSocket()关闭连接/buttondiv idmessage/div
/body
script typetext/javascriptvar websocket null;var clientId Math.random().toString(36).substr(2);//判断当前浏览器是否支持WebSocketif(WebSocket in window){//连接WebSocket节点websocket new WebSocket(ws://localhost:8080/ws/clientId);}else{alert(Not support websocket)}//连接发生错误的回调方法websocket.onerror function(){setMessageInnerHTML(error);};//连接成功建立的回调方法websocket.onopen function(){setMessageInnerHTML(连接成功);}//接收到消息的回调方法websocket.onmessage function(event){setMessageInnerHTML(event.data);}//连接关闭的回调方法websocket.onclose function(){setMessageInnerHTML(close);}//监听窗口关闭事件当窗口关闭时主动去关闭websocket连接防止连接还没断开就关闭窗口server端会抛异常。window.onbeforeunload function(){websocket.close();}//将消息显示在网页上function setMessageInnerHTML(innerHTML){document.getElementById(message).innerHTML innerHTML br/;}//发送消息function send(){var message document.getElementById(text).value;websocket.send(message);}//关闭连接function closeWebSocket() {websocket.close();}
/script
/html这组前端与后端的代码一起使用就是我们 WebSocket 协议的使用方式。
而我们在使用 WebSocket 协议的时候实际上跟 Http 协议一样都会需要经过 nginx 转发然后才可以转发到我们的后端所以我们在使用WebSocket协议还需要我们提前再 nginx.conf 配置好这个路径。
4.在nginx.conf中配置路径
我们在 server{} 内加入下面代码 # WebSocketlocation /ws/ {proxy_pass http://webservers/ws/;proxy_http_version 1.1;proxy_read_timeout 3600s;proxy_set_header Upgrade $http_upgrade;proxy_set_header Connection $connection_upgrade;}
通过上面的代码就可以将我们的请求转发到webservers而webservers在我们上面同样声明其路径是本地路径ip与端口号。 upstream webservers{server 127.0.0.1:8080 weight90 ;#server 127.0.0.1:8088 weight10 ;} 当然这个最上级的目录肯定是http{}内写的所以这个请求就是基于nginx的反向代理然后将请求转发过来。随后我们基于调用群发方法就可以把消息推送到客户端页面。
5.推送消息案例
推送消息的格式可用当今主流的json格式随后我们看一下代码案例
我们想将信息推送过去可以将信息封装map集合然后调用JSON.toJSONString()方法就可以将map集合转成json串并调用群发方法发送至客户端。
//通过WebSocket向客户端浏览器推送消息type orderId content
Map map new HashMap();
map.put(type,1);
map.put(orderId,ordersDB.getId());
map.put(content,订单号: outTradeNo);
String json JSON.toJSONString(map);
//推送
webSocketServer.sendToAllClient(json); 好了今天的内容就到这里Javaweb内容持续编辑中感谢收看
