websocket在线测试(网页websocket)
实战spring-boot-starter-websocket之断网心跳续期实践
业务中需要应用到Websocket长连接进行数据传输，由于服务使用的是Zuul1.0版本，对ws协议支持较弱，后续尝试使用了 spring-boot-starter-websocket来完成的。关于怎么集成的话网上有非常多的文章了，我就不多费口舌了。
我们目前实现的功能是可以通过WebSocket调用接口发送埋点，另外还需要监听用户离开的*为这个埋点画上一个终止访问时间。目前测试下场景有：
前4点触发了任意*作，服务端都会监听到 DISCONNECT离开*。但是第5点直接断网，服务端竟然是无感知的，这个时候产生的问题就是客户断网了，服务端是认为在线的，如果不重新联网登录的话，那么这个用户将会一直一直在线，埋点会一直计算。完了个蛋~
至于为什么断网之后，ws会认为他是在线的，可能管道打开了之后由于断网导致断开时间发送不出去吧。
我目前能够想到比较简单的办法就是：心跳续约
捋清了思路，大概就知道如何做了。
然后特意看了下 spring-boot-starter-websocket的源码，发现其实他有提供此功能。
先说下如何实现:
我们是在在实现了 DelegatingWebSocketMessageBrokerConfiguration的配置类中重写 configureMessageBroker方法。
比较关键就是 setTaskScheduler和 setHeartbeatValue一个负责调度、一个负责配置间隔。
这俩要么都填要么都不填。
配置了这俩参数之后，服务启动的时候会触发一个 HeartbeatTask线程来专门维持心跳。
我们可以看看他的流程是如何运转的。
核心任务调度类: org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler.HeartbeatTask
服务端在启动的时候 SimpleBrokerMessageHandler在初始化完成之后会回调 start的方法，然而他会触发一个 startInternal开始调度任务，判断依据就是有没有配置 TaskScheduler(对应的就是配置类中的setTaskScheduler)，一旦启动之后，会根据你给的心跳数组 serverHeartbeat，来选择调度时间。
org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler
检测心跳、超过间隔则剔除、并且定期回写心跳给客户端。
还有一点需要注意的是读的间隔时间：
假设用户网络不好，心跳漏发了一次，这个时候如果按照本次的逻辑而言，该用户的最后心跳时间肯定会超时。而它的做法是，将设定的读超时时间 3，就相当于有3次机会*。
这个在创建session的时候 SessionInfo里面就已经做好了处理:
org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler.SessionInfo#SessionInfo
所以这个时候，你可能需要根据业务能够接受的时长去配置，也别忘了这个事。
还有很关键的一点就是让客户端的心跳发送间隔和服务端尽可能保持一致，不然有可能出现莫名其妙的下线情况，尽可能还是在这种地方加好日志。
好了，希望在遇到断网问题的时候，能够帮助到你。
如果有疑问请留言，我会尽快答复。
怎样用j*a web和websocket实现网页即时通讯
原理
WebSocket protocol。
现很多网站为了实现即时通讯，所用的技术都是轮询(polling)。轮询是在特定的的时间间隔（如每1秒），由浏览器对服务器发出HTTP request，然后由服务器返回最新的数据给客户端的浏览器。这种传统的HTTP request的模式带来很明显的缺点–浏览器需要不断的向服务器发出请求，然而HTTP request的header是非常长的，里面包含的有用数据可能只是一个很小的值，这样会占用很多的带宽。
而比较新的技术去做轮询的效果是Comet–用了AJAX。但这种技术虽然可达到全双工通信，但依然需要发出请求。
在 WebSocket API，浏览器和服务器只需要做一个握手的动作，然后，浏览器和服务器之间就形成了一条快速通道。两者之间就直接可以数据互相传送。在此WebSocket协议中，为我们实现即时服务带来了两大好处：
1. Header
互相沟通的Header是很小的-大概只有 2 Bytes
2. Server Push
服务器的推送，服务器不再被动的接收到浏览器的request之后才返回数据，而是在有新数据时就主动推送给浏览器。
一、项目简介
WebSocket是HTML5一种新的协议，它实现了浏览器与服务器全双工通信，这里就将使用WebSocket来开发网页聊天室，前端框架会使用AmazeUI，后台使用J*a，编辑器使用UMEditor。
二、涉及知识点
网页前端（HTML+CSS+JS）和J*a
三、软件环境 Tomcat 7 JDK 7 Eclipse J*aEE现代浏览器
四、效果截图
效果1
效果2
五、项目实战
1.新建项目
打开Eclipse J*aEE，新建一个名为Chat的Dynamic Web Project，然后导入处理JSON格式字符串所需要的包，把commons-beanutils-1.8.0.jar、commons-collections-3.2.1.jar、commons-lang-2.5.jar、commons-logging-1.1.1.jar、ezmorph-1.0.6.jar和json-lib-2.4-jdk15.jar这几个包放在WebContent/WEB-INF/lib目录下，最后把项目发布到Tomcat服务器上，到此空项目就搭建完成了。
2.编写前端页面
在WebContent目录下新建一个名为index.jsp的页面，这里使用了AmazeUI框架，它是一个跨屏自适应的前端框架，消息输入框使用了UMEditor，它是一个富文本在线编辑器，能让我们的消息内容多姿多彩。
首先从 AmazeUI*下载压缩包，然后解压把assets文件夹拷贝到WebContent目录下，这样我们就能使用AmazeUI了。
再从 UEditer*下载Mini版的JSP版本压缩包，解压后把整个目录拷贝到WebContent目录下，接下来就可以编写前端代码了，代码如下（你可以按照自己的喜好编写）：
?
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293<%@ page language=”j*a” contentType=”text/html; charset=UTF-8″ pageEncoding=”UTF-8″%><!DOCTYPE html><html lang=”zh”><head><meta charset=”utf-8″><meta http-equiv=”X-UA-Compatible” content=”IE=edge”><meta name=”viewport” content=”width=device-width, initial-scale=1, maximum-scale=1, user-scalable=no”><title>ShiYanLou Chat</title><!– Set render engine for 360 browser–><meta name=”renderer” content=”webkit”><!– No Baidu Siteapp–><meta http-equiv=”Cache-Control” content=”no-siteapp”/><link rel=”alternate icon” href=”assets/i/f*icon.ico”><link rel=”stylesheet” href=”assets/css/amazeui.min.css”><link rel=”stylesheet” href=”assets/css/app.css”><!– umeditor css–><link href=”umeditor/themes/default/css/umeditor.css” rel=”stylesheet”><style>.title{text-align: center;}.chat-content-container{height: 29rem;overflow-y: scroll;border: 1px solid silver;}</style></head><body><!– title start–><div class=”title”><div class=”am-g am-g-fixed”><div class=”am-u-sm-12″><h1 class=”am-text-primary”>ShiYanLou Chat</h1></div></div></div><!– title end–><!– chat content start–><div class=”chat-content”><div class=”am-g am-g-fixed chat-content-container”><div class=”am-u-sm-12″><ul id=”message-list” class=”am-comments-list am-comments-list-flip”></ul></div></div></div><!– chat content start–><!– message input start–><div class=”message-input am-margin-top”><div class=”am-g am-g-fixed”><div class=”am-u-sm-12″><form class=”am-form”><div class=”am-form-group”><script type=”text/plain” id=”myEditor” style=”width: 100%;height: 8rem;”></script></div></form></div></div><div class=”am-g am-g-fixed am-margin-top”><div class=”am-u-sm-6″><div id=”message-input-nickname” class=”am-input-group am-input-group-primary”><span class=”am-input-group-label”><i class=”am-icon-user”></i></span><input id=”nickname” type=”text” class=”am-form-field” placeholder=”Please enter nickname”/></div></div><div class=”am-u-sm-6″><button id=”send” type=”button” class=”am-btn am-btn-primary”><i class=”am-icon-send”></i> Send</button></div></div></div><!– message input end–><!–[if(gte IE 9)|!(IE)]><!–><script src=”assets/js/jquery.min.js”></script><!–<![endif]–><!–[if lte IE 8 ]><script src=””></script><![endif]–><!– umeditor js–><script charset=”utf-8″ src=”umeditor/umeditor.config.js”></script><script charset=”utf-8″ src=”umeditor/umeditor.min.js”></script><script src=”umeditor/lang/zh-cn/zh-cn.js”></script><script>$(function(){//初始化消息输入框var um= UM.getEditor('myEditor');//使昵称框获取焦点$('#nickname')[0].focus();});</script></body></html>
编写完成之后启动Tomcat服务器，然后访问 ，会看到如下界面。
3.编写后台代码
新建一个com.shiyanlou.chat的包，在包中创建一个名为ChatServer的类，从J*aEE 7开始就统一了WebSocket的API，因此无论是什么服务器，用J*a写的代码都是一样的，代码如下：
?
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950 package com.shiyanlou.chat;import j*a.text.SimpleDateFormat;import j*a.util.Date;import j*ax.websocket.OnClose;import j*ax.websocket.OnError;import j*ax.websocket.OnMessage;import j*ax.websocket.OnOpen;import j*ax.websocket.Session;import j*ax.websocket.server.ServerEndpoint;import net.sf.json.JSONObject;/***聊天服务器类*@author shiyanlou**/@ServerEndpoint(“/websocket”)public class ChatServer{private static final SimpleDateFormat DATE_FORMAT= new SimpleDateFormat(“yyyy-MM-dd HH:mm”);//日期格式化@OnOpenpublic void open(Session session){//添加初始化*作}/***接受客户端的消息，并把消息发送给所有连接的会话*@param message客户端发来的消息*@param session客户端的会话*/@OnMessagepublic void getMessage(String message, Session session){//把客户端的消息解析为JSON对象JSONObject jsonObject= JSONObject.fromObject(message);//在消息中添加发送日期jsonObject.put(“date”, DATE_FORMAT.format(new Date()));//把消息发送给所有连接的会话for(Session openSession: session.getOpenSessions()){//添加本条消息是否为当前会话本身发的标志jsonObject.put(“isSelf”, openSession.equals(session));//发送JSON格式的消息openSession.getAsyncRemote().sendText(jsonObject.toString());}}@OnClosepublic void close(){//添加关闭会话时的*作}@OnErrorpublic void error(Throwable t){//添加处理错误的*作}}
4.前后台交互
后台写完了，前台要用WebSocket连接后台，需要新建一个WebSocket对象，然后就可以和服务器端进行交互，从浏览器发送消息给服务器端，同时要验证输入框的内容是否为空，然后接受服务端发送的消息，把它们动态地添加到聊天内容框中，在
?
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354 var um= UM.getEditor('myEditor');$('#nickname')[0].focus();//新建WebSocket对象，最后的/websocket对应服务器端的@ServerEndpoint(“/websocket”)var socket= new WebSocket('ws://${pageContext.request.getServerName()}:${pageContext.request.getServerPort()}${pageContext.request.contextPath}/websocket');//处理服务器端发送的数据socket.onmessage= function(event){addMessage(event.data);};//点击Send按钮时的*作$('#send').on('click', function(){var nickname=$('#nickname').val();if(!um.hasContents()){//判断消息输入框是否为空//消息输入框获取焦点um.focus();//添加抖动效果$('.edui-container').addClass('am-animation-shake');setTimeout(“$('.edui-container').removeClass('am-animation-shake')”, 1000);} else if(nickname==''){//判断昵称框是否为空//昵称框获取焦点$('#nickname')[0].focus();//添加抖动效果$('#message-input-nickname').addClass('am-animation-shake');setTimeout(“$('#message-input-nickname').removeClass('am-animation-shake')”, 1000);} else{//发送消息socket.send(JSON.stringify({content: um.getContent(),nickname: nickname}));//清空消息输入框um.setContent('');//消息输入框获取焦点um.focus();}});//把消息添加到聊天内容中function addMessage(message){message= JSON.parse(message);var messageItem='<li class=”am-comment'+(message.isSelf?'am-comment-flip':'am-comment')+'”>'+'<a href=”j*ascript:void(0)”><img src=”assets/images/'+(message.isSelf?'self.png':'others.jpg')+'” alt=”” width=”48″ height=”48″/></a>'+'<div><header><div>'+'<a href=”j*ascript:void(0)”>'+ message.nickname+'</a><time>'+ message.date+'</time></div></header>'+'<div>'+ message.content+'</div></div></li>';$(messageItem).appendTo('#message-list');//把滚动条滚动到底部$(“.chat-content-container”).scrollTop($(“.chat-content-container”)[0].scrollHeight);}
到这步，简单的网页聊天室就完成了，你可以多开几个窗口或在局域网中邀请小伙伴们来一起测试。
六、小结
本次项目课使用WebSocket实现了简单的网页聊天室，其实WebSocket不仅可以应用于浏览器，也可以应用于桌面客户端。
websocket 高性能 实战
疯狂创客圈 J*a高并发【亿级流量聊天室实战】实战系列【博客园总入口】
架构师成长+面试必备之高并发基础书籍【 Netty Zookeeper Redis高并发实战】
很多项目，都需要基于 Websocket协议做*、在线推送、在线聊天，虽然 Tomcat内置支持 Websocket协议，但是由于 Tomcat的吞吐量、连接数都很低，作为测试是可以的。在生产环境，一定需要使用高吞吐量、高连接数的 Netty服务器进行替代。
之所以 Netty性能高，因为其使用的是 Reactor反应器模式。关于反应器模式原理，请参见《Netty Zookeeper Redis高并发实战》一书。
聊天过程gif演示：
聊天示意图：
Netty搭建的服务器基本上都是差不多的写法：
绑定主线程组和工作线程组，这部分对应架构图中的*循环组。其原理，，请参见《Netty Zookeeper Redis高并发实战》一书。
重点就是ChannelInitializer的配置，以异步的方式启动，最后是结束的时候关闭线程组。
下面是用websocket做聊天室的逻辑：
源码网址： J*a高并发研习社群【博客园总入口】
疯狂创客圈经典图书：《Netty Zookeeper Redis高并发实战》面试必备+面试必备+面试必备
本文链接：http://www.hnxdcx.com/html/87966544.html
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件举报，一经查实，本站将立刻删除。
相关推荐
-
福建招生信息网 山西招生*成绩查询入口
福建教育考试院招生办电话福建教育考试院招生办的官方电话号码是0591-83733333，考生可以通过这个号码联系福建教育考试院招生办，以获取招生有关的信息。 招生办是负责学校招生工作的重要部门，其职责包括招生政策的制定与解释、考试组织和招生报名等。招生办在各个学校和地区都有，在招生旺季往往工作繁忙。他们会制定招生政策，并负责招生宣传、组织招生考试、审核报名材…
-
华楠骏业液压升降平台？请问*作液压升降平台需要什么证书
东莞虎门华楠骏业机械工作时间 早上八点到下午5点。东莞市华楠骏业机械制造有限*是上班时间为早上八点到下午五点，其他时间为加班点，为了生产的需要，有时会加班，有加班费。东莞市华楠骏业机械制造有限*是生产升降机等液压设备的专业厂家。主要设计生产升降平台、升降舞台、油压机等几大类产品。 汽车升降机* 究竟车辆升降机要*呢，坚信这个问题能够算是许多朋友的常识盲区，终…
-
山东招考院网站(山东省高考报名时间)
山东高考网上怎么报名五、报名办法和程序 （一）网上填报基本信息 1．考生上网填报基本信息 考生可任意选择地点并在规定时间内上网填报、修改及查询本人信息。填报过程分为登录、查看提示信息、输入并提交保存信息。修改和查询与填报过程相同。考生要认真核对本人填报的信息，发现问题及时处理。姓名、地名等信息项中如存在字库中没有的汉字，以拼音（半角大写字母）代替。 网上报名…
-
重庆美女交友，重庆本地哪里相亲比较好找对象
重庆美女和成都美女有什么区别 川渝地区，除了以美食、美景出名，在一众明星的带领下，当地的美男、美女也藏不住了，甚至有网友笑称“没有一个追星女孩能躲得过川渝”。 虽说四川和重庆同属一脉，但四川盆地幅员辽阔，每个地区的地理、气候、风俗等都极具当地特色，所以人们的性格也有一定的差异。 在Mob研究院发布的相关文件中，对于成渝两地的女性进行了研究，分别展示了成渝女性…
-
圣剑与魔龙的世界？魔剑与圣剑的继承者
圣剑使的禁咒咏唱所有暗术咒文一阶《束缚》缀写： 如同地狱之锁，连亡者也能捕捉 一阶《冰之吐息》缀写： 水之子啊，冰之童啊，借我你们的吐息吧 三阶《冻影》缀写： 如同水往低处流般的夺走全部生命吧 四阶《狂风暴雪》缀写： 不寻常之地啊，*之冻土啊，借我你的气息吧 让我见识一下吧 十三阶·禁咒《摩诃钵特摩地狱》缀写： 终结者啊冰狼啊借汝之气息予吾赐吾比*亡更冷寂的…
-
桂林生活网二手房市场？在桂林市买房子,哪个地段比较好
在桂林市买房子,哪个地段比较好 可以关注当地的房产交易中心，或者房产网、房产论坛。 买房需要考量： 目的 在购房前，消费者一定要考虑明白为什么买房，是自住、改善住房条件，还是作为投资？如果是自住，可选择交通、生活设施比较便利的小区或二手房；如果是改善住房条件，就选择大户型；而若是投资，则还要结合当下的经济状况。 位置 房产是非常个性化的，位置永远是决定其价值…
-
多玩神雕侠侣(神雕侠侣手游神兽精魄怎么获得)
金庸群侠传通关秘籍 主角的智商一共有五个级别，判别主角智商高低的方法是：进入游戏后，先到南贤居，再到福威镖局找到“松风剑谱”给主角修炼，再查看主角的属性，其需要的经验值有五种可能，即代表主角五个级别的智商，分别是：30、60、90、120和150，30时主角智商最高，150时最低。智商高则炼级时需要的经验值少，反之则多，此原则几乎适用于游戏中任何角色，例如，…
-
第20类商标转让(20类商标商标注册)
第20类家具商标转让第20类家具商标转让包括家具，床，沙发，床垫，柜，办公家具，非金属容器，竹木工艺品，枕头，野营睡袋。家具是指人类维持正常生活、从事生产实践和开展社会活动必不可少的器具设施大类。家具也跟随时代的脚步不断发展创新，到如今门类繁多，用料各异，品种齐全，用途不一。是建立工作生活空间的重要基础。 【注释】 第二十类主要包括家具及其部件和不属别类的塑…
-
北仑房屋出租，宁波北仑58同城租房
宁波北仑区青年申报公租房租赁补贴指南宁波北仑区青年申报公租房租赁补贴指南 一、申报条件 青年量化积分达到一定分值申报公租房租赁补贴，还需同时具备下列条件： 申请人年龄为18至35周岁，持有在北仑区办理的有效《浙江省居住证》或为本区户籍，申请前已连续12个月在北仑区缴纳社保，且延续到查验日仍在保，补缴无效，因受*影响缓缴的视作正常缴存。 申请人及其家庭成员在北…
-
秦如凉沈娴全文免费阅读 秦如凉沈娴是哪部小说
小说*人公沈娴秦如凉的小说叫什么 《千秋我为凰》作者千苒君笑 沈娴成了一个傻子，被赶出家门、毁去容貌不说，肚子里还揣了个崽！丈夫另娶新欢当日，她登门贺喜，狂打新妾脸，震慑八方客。没想到新妾处处跟她飙演技——弱鸡，就凭你？也配给自己加戏？渣男还想虐身又虐心 私信我给你资源。 秦如凉沈娴是哪部小说 《千秋我为凰》千苒君笑 沈娴穿越成了一个傻子，被赶出家门、毁去容…
.jpg "多玩神雕侠侣(神雕侠侣手游神兽精魄怎么获得)")
