WebSocket实时异步通信

WebSocket实时异步通信

【一】WebSocket简介

　　WebSocket是HTML5推出一个协议规范，用来B/S模式中服务器端和客户端之间进行实时异步通信。

　　众所周知，传统的HTTP协议中，服务器端和客户端通信只能是在客户端发送一个请求之后，服务器端才能对其响应，也就是说服务器端是不能够主动向客户端发起数据的。

　　当在服务器端和客户端之间需要频繁地实时通信时，传统HTTP协议只能通过Ajax轮询的方式，即客户端每隔一段时间请求一次服务器来获得更新，这样做的对服务器的性能要求特别高，而且占用很多无用的带宽、流量。

 

 

图一 传统HTTP请求会话

图二 WebSocket请求会话

　　WebSocket在实时通信方面很好的弥补了传统HTTP协议的不足。它是一个建立在HTTP协议之上的协议，通过HTTP建立了WebSocket连接之后，服务器端和客户端就可以随时通信了。

 

【二】WebSocket的使用

服务器端

　　Tomcat7.0.5版本及以后的版本之中已经内嵌了支持WebSocket标准协议的jar包websocket-api.jar；在服务器端开发中通过@ServerEndpoint注解表明WebSocket服务端运行在 ws://[Server端IP或域名]:[Server端口]/project-name/注解参数值 路径指定的位置，客户端在创建WebSocket对象的时候，通过该路径指定服务器响应的WebSocket。

　　@OnOpen、@OnClose、@OnError注解WebSocket方法分别响应建立连接、关闭连接和出错时候的回调函数，@OnMessage注解的方法响应收到客户端发送数据的回调函数。Session相当于客户端，可以向客户端发送数据。

　　WebSocket类处理客户端的所有请求，然后根据不同页面的请求调用不同的类对象进行处理。

import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import javax.websocket.Session;
import org.apache.log4j.Logger;
import net.sf.json.JSONObject;

@ServerEndpoint("/websocket")
public class WebSocket {public static Logger log = Logger.getLogger(WebSocket.class);    private Statement stmt = null;private Connection conn = null;    private Timer timer;@OnOpenpublic void onOpen(Session s) {    log.info("client connected");timer = new Timer();//connect databasetry {ResourceBundle config = ResourceBundle.getBundle("config");String driver = config.getString("jdbc.driver");String url = config.getString("jdbc.cfg.url");String username = config.getString("jdbc.cfg.username");String password = config.getString("jdbc.cfg.password");Class.forName(driver);conn = DriverManager.getConnection(url, username, password);stmt = conn.createStatement(); log.info("connect database successful");}catch (ClassNotFoundException e) {e.printStackTrace();}catch (SQLException e) {e.printStackTrace();}}@OnMessagepublic void onMessage(final String message, Session s) throws IOException, InterruptedException{log.info("message="+message);final JSONObject json = JSONObject.fromString(message);if(json.getInt("pageIndex") == 2){        //热门配置页不循环推送    HotConfig hotConfig = new HotConfig(s, stmt);hotConfig.sendWebSocket(json);}else if(json.getInt("pageIndex") == 3){final TrafficLog trafficLog = new TrafficLog(s, stmt);int isRealTimeSearch = json.getInt("isRealTimeSearch");if(isRealTimeSearch == 1){timer.schedule(new TimerTask() { //每隔5分钟执行一次
                    @Override  public void run() {trafficLog.sendWebSocket(json);}            }, 0, 300000); }else{                                //只执行一次timer.schedule(new TimerTask() {@Override  public void run() {trafficLog.sendWebSocket(json);}            }, 0); }}else if(json.getInt("pageIndex") == 4){final RuleLog ruleLog = new RuleLog(s, stmt);int isRealTimeSearch = json.getInt("isRealTimeSearch");if(isRealTimeSearch == 1){timer.schedule(new TimerTask() { //每隔5分钟执行一次
                    @Override  public void run() {ruleLog.sendWebSocket(json);}            }, 0, 300000); }else{                                //只执行一次timer.schedule(new TimerTask() {@Override  public void run() {ruleLog.sendWebSocket(json);}            }, 0); }}else{                                    //isp页面的请求final ISPLog ispLog = new ISPLog(s, stmt);int isRealTimeSearch = json.getInt("isRealTimeSearch");if(isRealTimeSearch == 1){timer.schedule(new TimerTask() { //每隔5分钟执行一次
                    @Override  public void run() {ispLog.sendWebSocket(json);}            }, 0, 300000); }else{                                //只执行一次timer.schedule(new TimerTask() {@Override  public void run() {ispLog.sendWebSocket(json);}            }, 0); }}}@OnClosepublic void onClose(Session s) {log.info("Client closed");try {timer.cancel();            if (stmt != null) {stmt.close();stmt = null;}if (conn != null) {conn.close();conn = null;}} catch (SQLException e) {e.printStackTrace();}}@OnErrorpublic void onError(Throwable e) {log.error("WebSocket Error");e.printStackTrace();}
}


　　响应具体某个页面的请求

import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import javax.websocket.Session;
import org.apache.log4j.Logger;
import net.sf.json.JSONObject;public class HotConfig {private Session session;private Statement stmt = null;private ResultSet rs = null;private static Logger log = Logger.getLogger(HotConfig.class);public HotConfig(Session s, Statement stmt){this.session = s;this.stmt = stmt;}public void sendWebSocket(final JSONObject json){String srcIp = json.getString("srcIp");String startTime = json.getString("startTime");String endTime = json.getString("endTime");Map<String, ArrayList<Long>> params = new HashMap<String, ArrayList<Long>>();ArrayList<Long> pzID = new ArrayList<Long>();             //different chart lines nameArrayList<Long> statCount = new ArrayList<Long>();        //chart x axisArrayList<Long> pzIDReverse = new ArrayList<Long>();            //different chart lines nameArrayList<Long> statCountReverse = new ArrayList<Long>();        //chart x axistry {String srcIpCriteria = "";                        //拼接源IP SQL条件if(srcIp.length() > 0) {srcIpCriteria = " where CLIENT_IP='"+srcIp+"' ";}String startTimeCriteria = "";                    //拼接源IP SQL条件if(startTime.length() > 0) {if(srcIpCriteria.equals(""))startTimeCriteria = " where STAT_TIME >= to_date('"+startTime +"','yyyy-mm-dd hh24:mi')";elsestartTimeCriteria = " and STAT_TIME >= to_date('"+startTime +"','yyyy-mm-dd hh24:mi')";}String endTimeCriteria = "";                      //拼接源IP SQL条件if(endTime.length() > 0) {if(srcIpCriteria.equals("") && startTimeCriteria.equals(""))endTimeCriteria = " where STAT_TIME < to_date('" +endTime+"','yyyy-mm-dd hh24:mi') ";elseendTimeCriteria = " and STAT_TIME < to_date('" +endTime+"','yyyy-mm-dd hh24:mi') ";}String sql = "select * from (select PZ_ID, sum(STAT_COUNT) as sumCount from RULE_HOT_CONFIG_INFO" + srcIpCriteria + startTimeCriteria + endTimeCriteria + " group by PZ_ID order by sumCount desc) where rownum <= 50";                log.info("sql="+sql+"execute success");rs = stmt.executeQuery(sql);while(rs.next()){ pzID.add(rs.getLong(1));statCount.add(rs.getLong(2));}for(int i = pzID.size() - 1; i >= 0; i--){pzIDReverse.add(pzID.get(i));statCountReverse.add(statCount.get(i));}params.put("pzID", pzIDReverse);params.put("statCount",statCountReverse);         session.getBasicRemote().sendText(JSONObject.fromBean(params).toString());log.info("主动发给前端的数据="+JSONObject.fromBean(params).toString());} catch (IOException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();}}}

 

客户端

　　目前主流的浏览器Firefox、Chrome已经支持WebSocket协议，这意味只不需要引用额外的js库就可以直接使用WebSocket了。

<script type="text/javascript">   
　　　　 //创建WebSocket对象，用于一开始建立连接，之后就不要再建立连接了var webSocket = new WebSocket('ws://localhost:8080/websocket/websocket');webSocket.onopen = function(event) {};webSocket.onmessage = function(event) {
　　　　　　　　//接收来自服务器的数据，这里客户端没有发送任何请求，任何时间接收到数据都可以异步调用onMessage(event);
　　　　　　　　var  m = JSON.parse(event.data);
　　　　　　　　alert(m);};webSocket.onerror = function(event) {};     function onMessage(event) {}
</script>

 

 推荐学习文章：http://www.ibm.com/developerworks/cn/java/j-lo-WebSocket/

　　　　　 　　http://www.tuicool.com/articles/7zyMvy6

　　　　　　　 http://www.alixixi.com/web/a/2014032492868.shtml

转载于:https://www.cnblogs.com/vincent-vg/p/5831421.html

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/254541.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

多线程和多进程的区别（小结）

多线程和多进程的区别（小结）

分类&#xff1a; linux 2009-06-19 09:33 11501人阅读 评论(15) 收藏 举报 很想写点关于多进程和多线程的东西&#xff0c;我确实很爱他们。但是每每想动手写点关于他们的东西&#xff0c;却总是求全心理作祟&#xff0c;始终动不了手。 今天终于下了决心&#xff0c;写点东西…
阅读更多...
redis-cli使用密码登录

redis-cli使用密码登录

redis-cli使用密码登录 注意IP地址要写正确&#xff01; 学习了: https://blog.csdn.net/lsm135/article/details/52932896 https://blog.csdn.net/zyz511919766/article/details/42268219 https://zhidao.baidu.com/question/756651357338691604.html 登录后 auth pass 或者 r…
阅读更多...
FFT快速傅式变换算法halcon算子，持续更新

FFT快速傅式变换算法halcon算子，持续更新

目录convol_fftconvol_gaborcorrelation_fftdeserialize_fft_optimization_dataenergy_gaborfft_genericfft_imagefft_image_invgen_bandfiltergen_bandpassgen_derivative_filtergen_filter_maskgen_gaborgen_gauss_filtergen_highpassgen_lowpassgen_mean_filtergen_sin_band…
阅读更多...
仿照vue实现简易的MVVM框架（一）

仿照vue实现简易的MVVM框架（一）

代码github地址&#xff1a; https://github.com/susantong/myMVVM 主要的方法有&#xff1a; compile 深度遍历前端界面的节点&#xff0c;将其复制进一个addQuene队列中pasers 遍历所有的节点&#xff0c;并将节点包装成一个含有本节点、自定义属性及属性值的对象。要想实现双…
阅读更多...
tomcat 启动时内存溢出

tomcat 启动时内存溢出

在tomcat_home/bin目录下找到catalina.bat&#xff0c;用文本编辑器打开&#xff0c;加上下面一行&#xff1a; set JAVA_OPTS -Xms1024M -Xmx1024M -XX:PermSize256M -XX:MaxNewSize256M -XX:MaxPermSize256M 解释一下各个参数&#xff1a; -Xms1024M&#xff1a;初始化堆内存…
阅读更多...
@angular/platform-browser-dynamic

@angular/platform-browser-dynamic

/** experimental */ export declare class JitCompilerFactory implements CompilerFactory {createCompiler(options?: CompilerOptions[]): Compiler; }export declare const platformBrowserDynamic: (extraProviders?: StaticProvider[] | undefined) > PlatformRef;…
阅读更多...
牛人项目失败的总结

牛人项目失败的总结

tom_lt: 遇到的失败项目比较多&#xff01;让人郁闷&#xff01;&#xff01; 仔细分析原因&#xff0c;主要在于&#xff1a; 1.项目开始需求不明确。领导决定动手&#xff0c;就开始启动项目&#xff0c;造成和客户需要差距太大&#xff0c;导致失败&#xff1b; 2.需求变更没…
阅读更多...
Android:日常学习笔记(8)———探究UI开发(5)

Android:日常学习笔记(8)———探究UI开发(5)

Android:日常学习笔记(8)———探究UI开发(5) ListView控件的使用 ListView概述 A view that shows items in a vertically scrolling list. The items come from the ListAdapter associated with this view. 1.关于ArrayAdapter&#xff1a; ArrayAdapter<T> 是 ListAd…
阅读更多...
Geometric-Transformations图像几何变换halcon算子，持续更新

Geometric-Transformations图像几何变换halcon算子，持续更新

目录affine_trans_imageaffine_trans_image_sizeconvert_map_typemap_imagemirror_imagepolar_trans_image_extpolar_trans_image_invprojective_trans_imageprojective_trans_image_sizerotate_imagezoom_image_factorzoom_image_sizeaffine_trans_image 功能&#xff1a;把任…
阅读更多...
hibernate inverse属性的作用

hibernate inverse属性的作用

hibernate配置文件中有这么一个属性inverse&#xff0c;它是用来指定关联的控制方的。inverse属性默认是false&#xff0c;若为false&#xff0c;则关联由自己控制&#xff0c;若为true&#xff0c;则关联由对方控制。见例子&#xff1a; 一个Parent有多个Child,一个Child只能有…
阅读更多...
分布式锁与实现(一)——基于Redis实现

分布式锁与实现(一)——基于Redis实现

概述 目前几乎很多大型网站及应用都是分布式部署的&#xff0c;分布式场景中的数据一致性问题一直是一个比较重要的话题。分布式的CAP理论告诉我们“任何一个分布式系统都无法同时满足一致性&#xff08;Consistency&#xff09;、可用性&#xff08;Availability&#xff09;和…
阅读更多...
浅析软件项目管理中十个误区(来自：http://manager.csdn.net/n/20051213/30907.html）

浅析软件项目管理中十个误区(来自：http://manager.csdn.net/n/20051213/30907.html）

随着计算机硬件水平的不断提高&#xff0c;计算机软件的规模和复杂度也随之增加。计算机软件开发从“个人英雄”时代向团队时代迈进&#xff0c;计算机软件项目的管理也从“作坊式”管理向“软件工厂式”管理迈进。这就要求软件开发人员特别是软件项目管理人员更深一步地理解和…
阅读更多...
俩孩随笔

俩孩随笔

俩孩随笔 有人给我贴了技术男加奶爸的标签&#xff0c;不过这两项都不是我的强项。我深知自己最大的长处在哪&#xff1a;普通&#xff0c;扔人堆里&#xff0c;不是认不出来&#xff0c;而是压根看不着。想把事情做好&#xff0c;常常会用力过度。工作平平淡淡&#xff0c;需…
阅读更多...
Inpainting图像修复halcon算子，持续更新

Inpainting图像修复halcon算子，持续更新

目录harmonic_interpolationinpainting_anisoinpainting_cedinpainting_ctinpainting_mcfinpainting_textureharmonic_interpolation 功能&#xff1a;对一个图像区域执行谐波插值。 inpainting_aniso 功能&#xff1a;通过各向异性扩散执行图像修复。 inpainting_ced 功能…
阅读更多...
算法（伪代码）的书写

算法（伪代码）的书写

q ⇒ Queue&#xff08;队列&#xff09;, s ⇒ Set&#xff08;集合&#xff09;pq ⇒ PriorityQueue&#xff08;优先队列&#xff09;d ⇒ distance1. initialization 变量&#xff0c;数据结构的定义&#xff0c;及初始值的赋值&#xff1b;比如著名的 Dijkstra &#xff0…
阅读更多...
第八次作业——系统设计与团队分配（个人）

第八次作业——系统设计与团队分配（个人）

团队作业地址&#xff1a;https://www.cnblogs.com/clio-hhhhhhl/p/9079157.html 个人码云地址&#xff1a;https://gitee.com/Cliohl/events 团队码云地址&#xff1a;https://gitee.com/Cliohl/zhuoyue 项目进展&#xff1a; 上礼拜进展&#xff1a;把部分前端页面实现出来&a…
阅读更多...
深入理解Activity启动流程(二)–Activity启动相关类的类图

深入理解Activity启动流程(二)–Activity启动相关类的类图

本文原创作者:Cloud Chou. 欢迎转载&#xff0c;请注明出处和本文链接 本系列博客将详细阐述Activity的启动流程&#xff0c;这些博客基于Cm 10.1源码研究。 在介绍Activity的详细启动流程之前&#xff0c;先为大家介绍Activity启动时涉及到的类&#xff0c;这样大家可以有大概…
阅读更多...
Lines色线halcon算子，持续更新

Lines色线halcon算子，持续更新

目录bandpass_imagelines_colorlines_facetlines_gaussbandpass_image 功能&#xff1a;使用带通滤波器提取边缘。 lines_color 功能&#xff1a;检测色线和它们的宽度。 lines_facet 功能&#xff1a;使用面模型检测线。 lines_gauss 功能&#xff1a;检测线和它们的宽…
阅读更多...
疑问+软件

疑问+软件

问题 1学好软件工程需要打好哪些基础&#xff1f; 2怎样学好软件工程&#xff1f; 3软件工程的发展前景如何&#xff1f; 4软件工程具体能从事哪些职业&#xff1f; 5怎样准确的找到自己的定位&#xff1f; 软件 1支付宝 优点&#xff1a;支付便捷&#xff0c;转账方便&#xf…
阅读更多...
成功的项目管理

成功的项目管理

内容提要 第一讲 项目与项目管理 1.项目的基本概念 2.项目管理的概念 3.项目管理的重要性 第二讲 项目管理的最新发展 1.现代项目管理的创立过程 2.现代项目管理的发展趋势 3.项目管理流行的原因 第三讲 信息时代的项目管理 1.信息时代的特点 2.信息时代项目管理的特点 3.按项目…
阅读更多...
最新文章

Copyright @ 2022~2023