Java Websocket实例

2019独角兽企业重金招聘Python工程师标准>>> hot3.png

介绍

现很多网站为了实现即时通讯,所用的技术都是轮询(polling)。轮询是在特定的的时间间隔(如每1秒),由浏览器对服务器发出HTTP request,然后由服务器返回最新的数据给客服端的浏览器。这种传统的HTTP request 的模式带来很明显的缺点 – 浏览器需要不断的向服务器发出请求,然而HTTP request 的header是非常长的,里面包含的数据可能只是一个很小的值,这样会占用很多的带宽。

而最比较新的技术去做轮询的效果是Comet – 用了AJAX。但这种技术虽然可达到全双工通信,但依然需要发出请求。

在 WebSocket API,浏览器和服务器只需要要做一个握手的动作,然后,浏览器和服务器之间就形成了一条快速通道。两者之间就直接可以数据互相传送。


依赖:

Tomcat 7 或者 J2EE7

<dependency>
<groupId>org.apache.tomcat</groupId>
<artifactId>tomcat-websocket-api</artifactId>
<version>7.0.47</version>
<scope>provided</scope>
</dependency><dependency>
<groupId>javax</groupId>
<artifactId>javaee-api</artifactId>
<version>7.0</version>
<scope>provided</scope>
</dependency>

注意:早前业界没有统一的标准,各服务器都有各自的实现,现在J2EE7JSR356已经定义了统一的标准,请尽量使用支持最新通用标准的服务器。

详见:http://www.oracle.com/technetwork/articles/java/jsr356-1937161.html

           http://jinnianshilongnian.iteye.com/blog/1909962

 

我是用的Tomcat 7.0.57 + Java7

必须是Tomcat 7.0.47以上

详见:http://www.iteye.com/news/28414

 

ps:最早我们是用的Tomcat 7自带的实现,后来要升级Tomcat 8,结果原来的实现方式在Tomcat 8不支持了,就只好切换到支持Websocket 1.0版本的Tomcat了。

 

主流的java web服务器都有支持JSR365标准的版本了,请自行Google。 

 

用nginx做反向代理的需要注意啦,socket请求需要做特殊配置的,切记!

 

Tomcat的处理方式建议修改为NIO的方式,同时修改连接数到合适的参数,请自行Google!

 

服务端

服务端不需要在web.xml中做额外的配置,Tomcat启动后就可以直接连接了。

 

import com.dooioo.websocket.utils.SessionUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;/*** 功能说明:websocket处理类, 使用J2EE7的标准* 切忌直接在该连接处理类中加入业务处理代码* 作者:liuxing(2014-11-14 04:20)
*/
//relationId和userCode是我的业务标识参数,websocket.ws是连接的路径,可以自行定义
@ServerEndpoint("/websocket.ws/{relationId}/{userCode}")
public class WebsocketEndPoint {private static Log log = LogFactory.getLog(WebsocketEndPoint.class);/*** 打开连接时触发* @param relationId* @param userCode* @param session
*/
@OnOpenpublic void onOpen(@PathParam("relationId") String relationId,@PathParam("userCode") int userCode,Session session){log.info("Websocket Start Connecting:"+ SessionUtils.getKey(relationId, userCode));SessionUtils.put(relationId, userCode, session);
}/*** 收到客户端消息时触发* @param relationId* @param userCode* @param message* @return
*/
@OnMessagepublic String onMessage(@PathParam("relationId") String relationId,@PathParam("userCode") int userCode,String message) {return"Got your message ("+ message +").Thanks !";
}/*** 异常时触发* @param relationId* @param userCode* @param session
*/
@OnErrorpublic void onError(@PathParam("relationId") String relationId,@PathParam("userCode") int userCode,Throwable throwable,Session session) {log.info("Websocket Connection Exception:"+ SessionUtils.getKey(relationId, userCode));log.info(throwable.getMessage(), throwable);SessionUtils.remove(relationId, userCode);
}/*** 关闭连接时触发* @param relationId* @param userCode* @param session
*/
@OnClosepublic void onClose(@PathParam("relationId") String relationId,@PathParam("userCode") int userCode,Session session) {log.info("Websocket Close Connection:"+ SessionUtils.getKey(relationId, userCode));SessionUtils.remove(relationId, userCode);
}}

  

 

工具类用来存储唯一key和连接

这个是我业务的需要,我的业务是服务器有对应动作触发时,推送数据到客户端,没有接收客户端数据的操作。

 

import javax.websocket.Session;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;/*** 功能说明:用来存储业务定义的sessionId和连接的对应关系* 利用业务逻辑中组装的sessionId获取有效连接后进行后续操作* 作者:liuxing(2014-12-26 02:32)
*/
public class SessionUtils {public static Map<String, Session> clients = new ConcurrentHashMap<>();public static void put(String relationId, int userCode, Session session){clients.put(getKey(relationId, userCode), session);
}public static Session get(String relationId, int userCode){return clients.get(getKey(relationId, userCode));
}public static void remove(String relationId, int userCode){clients.remove(getKey(relationId, userCode));
}/*** 判断是否有连接* @param relationId* @param userCode* @return
*/public static boolean hasConnection(String relationId, int userCode) {return clients.containsKey(getKey(relationId, userCode));
}/*** 组装唯一识别的key* @param relationId* @param userCode* @return
*/public static String getKey(String relationId, int userCode) {return relationId +"_"+ userCode;
}}

 

 

推送数据到客户端

 

在其他业务方法中调用

 

/*** 将数据传回客户端* 异步的方式* @param relationId* @param userCode* @param message
*/public void broadcast(String relationId, int userCode, String message) {if (TelSocketSessionUtils.hasConnection(relationId, userCode)) {TelSocketSessionUtils.get(relationId, userCode).getAsyncRemote().sendText(message);} else {throw new NullPointerException(TelSocketSessionUtils.getKey(relationId, userCode) +"Connection does not exist");
}}

 

我是使用异步的方法推送数据,还有同步的方法

详见:http://docs.oracle.com/javaee/7/api/javax/websocket/Session.html

 

客户端

var webSocket = null;
var tryTime = 0;
$(function () {
initSocket();window.onbeforeunload = function () {
//离开页面时的其他操作
};
});/*** 初始化websocket,建立连接
*/
function initSocket() {if (!window.WebSocket) {
alert("您的浏览器不支持websocket!");return false;
}webSocket = new WebSocket("ws://127.0.0.1:8080/websocket.ws/"+ relationId +"/"+ userCode);// 收到服务端消息webSocket.onmessage = function (msg) {
console.log(msg);
};// 异常webSocket.onerror = function (event) {
console.log(event);
};// 建立连接webSocket.onopen = function (event) {
console.log(event);
};// 断线重连webSocket.onclose = function () {// 重试10次,每次之间间隔10秒if (tryTime < 10) {setTimeout(function () {webSocket = null;
tryTime++;
initSocket();}, 500);} else {tryTime = 0;
}
};}

 

其他调试工具

Java实现一个websocket的客户端

 

<dependency>
<groupId>org.java-websocket</groupId>
<artifactId>Java-WebSocket</artifactId>
<version>1.3.0</version>
</dependency>

 

import java.io.IOException; import javax.websocket.ClientEndpoint; import javax.websocket.OnError; import javax.websocket.OnMessage; import javax.websocket.OnOpen; import javax.websocket.Session; @ClientEndpointpublic class MyClient { 
@OnOpenpublic void onOpen(Session session) { System.out.println("Connected to endpoint:"+ session.getBasicRemote()); try { 
session.getBasicRemote().sendText("Hello");} catch (IOException ex) { 
}
}@OnMessagepublic void onMessage(String message) { 
System.out.println(message);
}@OnErrorpublic void onError(Throwable t) { 
t.printStackTrace();
}
}

 

import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.URI; import javax.websocket.ContainerProvider; import javax.websocket.DeploymentException; import javax.websocket.Session; import javax.websocket.WebSocketContainer; public class MyClientApp { public Session session; protected void start() 
{WebSocketContainer container = ContainerProvider.getWebSocketContainer(); String uri ="ws://127.0.0.1:8080/websocket.ws/relationId/12345"; System.out.println("Connecting to"+ uri); try { session = container.connectToServer(MyClient.class, URI.create(uri)); } catch (DeploymentException e) { 
e.printStackTrace();} catch (IOException e) { 
e.printStackTrace();
}}public static void main(String args[]){ MyClientApp client = new MyClientApp(); 
client.start();BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); String input =""; try { 
do{input = br.readLine(); 
if(!input.equals("exit"))
client.session.getBasicRemote().sendText(input);}while(!input.equals("exit"));} catch (IOException e) { // TODO Auto-generated catch block 
e.printStackTrace();
}
}
}

 

 

Chrome安装一个websocket模拟客户端

 

 

 

最后

为了统一的操作体验,对于一些不支持websocket的浏览器,请使用socketjs技术做客户端开发。


转载于:https://my.oschina.net/sphl520/blog/398382

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

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

相关文章

LeetCode 287. 寻找重复数

给定一个包含 n 1 个整数的数组 nums&#xff0c;其数字都在 1 到 n 之间&#xff08;包括 1 和 n&#xff09;&#xff0c;可知至少存在一个重复的整数。假设只有一个重复的整数&#xff0c;找出这个重复的数。 示例 1: 输入: [1,3,4,2,2]输出: 2示例 2: 输入: [3,1,3,4,2]输…

Go学习笔记—并发高级

Go并发机制 ​ 协程&#xff1a;一个线程可以对应多个协程&#xff0c;协程串行运行在用户空间。协程运行在线程之上&#xff0c;当一个协程执行完成后&#xff0c;可以选择主动让出&#xff0c;让另一个协程运行在当前线程之上。协程并没有增加线程数量&#xff0c;只是在线程…

设计模式C++学习笔记之十三(Decorator装饰模式)

装饰模式&#xff0c;动态地给一个对象添加一些额外的职责。就增加功能来说&#xff0c;Decorator模式相比生成子类更为灵活。 13.1.解释 main()&#xff0c;老爸 ISchoolReport&#xff0c;成绩单接口 CFourthGradeSchoolReport&#xff0c;四年级成绩单 ReportDecorator&…

Android应用开发相关下载资源(2014/12/14更新)

官方终于发布了Android Studio正式版&#xff0c;Android Studio将会成为推荐使用的主要Android开发工具. (1)Android SDK (Android SDK主安装包&#xff0c;包含SDK Manager、AVD Manager、工具包tools&#xff0c;释放后的根文件夹为android-sdk-windows): revision 23.0.2ht…

分层在深一步学习

前几天自己写了写DAL层,还有Model!理解到在DAL中主要是写的数据操作,而这些操作又是基于DbHelper这个基类!而数据库的访问则写在了这个基类中,目前还没研究BLL层,不过知道其中写的是算法!在Model中写的对象的属性,还有数据的规范(据说是,呵呵).自己对分层开发很感兴趣!呵呵,加油…

程序员编程艺术:第二章、字符串是否包含问题

程序员编程艺术&#xff1a;第二章、字符串是否包含及相关问题扩展 作者&#xff1a;July&#xff0c;yansha。时间&#xff1a;二零一一年四月二十三日。致谢&#xff1a;老梦&#xff0c;nossiac&#xff0c;Hession&#xff0c;Oliver&#xff0c;luuillu&#xff0c;雨翔&a…

LeetCode—207. 课程表

207. 课程表 题目描述&#xff1a;你这个学期必须选修 numCourses 门课程&#xff0c;记为 0 到 numCourses - 1 。 在选修某些课程之前需要一些先修课程。 先修课程按数组 prerequisites 给出&#xff0c;其中 prerequisites[i] [ai, bi] &#xff0c;表示如果要学习课程 ai…

详解为何在嵌套ESXi环境下要求开启Promiscuous Mode

原文链接&#xff1a;http://bbs.vmanager.cn/forum.php?modviewthread&tid8688&fromuid35445在嵌套环境中&#xff0c;有时候网路不通&#xff0c;此时&#xff0c;调整Promiscuous Mode选项为Accept之后&#xff0c;网路就可以通了。之前只是知道这个选项可以保证嵌…

Rapidmind计算库性能测试

rapidmind.net提供了免费的计算库下载&#xff0c;目的是使用C metaprogramming将计算与硬件平台隔离开来&#xff0c;它提供一套运行库做底层的优化工作。为了测试其真正的性能&#xff0c;以便于在未来的渲染器中使用&#xff0c;我做了一个简单的性能测试程序&#xff0c;将…

VMware 怎么进入BIOS

2019独角兽企业重金招聘Python工程师标准>>> 虚拟机(Vmware)引导Linux虚拟机时&#xff0c;需要设置成光盘启动来引导系统&#xff0c;但是vmware默认是硬盘启动&#xff0c;所以会启动不了或者别的问题存在。所以要进bios里面设置成开机的启动顺序&#xff0c;要将…

LeetCode—208. 实现 Trie (前缀树)

208. 实现 Trie (前缀树) 题目描述&#xff1a;Trie&#xff08;发音类似 “try”&#xff09;或者说 前缀树 是一种树形数据结构&#xff0c;用于高效地存储和检索字符串数据集中的键。这一数据结构有相当多的应用情景&#xff0c;例如自动补完和拼写检查。 请你实现 Trie 类…

SQL入侵恢复XP_CMDSHLL与开3389

一,用SQL连接器恢复XP_CMDSHLLE的命令 &#xff08;1&#xff09;sp_addextendedproc xp_cmdshell,dllnamexplog70.dll &#xff08;2&#xff09;首先在SqlExec Sunx Version的Format选项里填上%s&#xff0c;在CMD选项里输入 sp_addextendedproc xp_cmdshell,xpsql70.dll 去除…

java中long类型转换为int类型

由int类型转换为long类型是向上转换&#xff0c;可以直接进行隐式转换&#xff0c;但由long类型转换为int类型是向下转换&#xff0c;可能会出现数据溢出情况&#xff1a; 主要以下几种转换方法&#xff0c;供参考&#xff1a;一、强制类型转换 [java] long ll 300000; in…

中国最好的电子商务平台,75商务网成功上线

中国B2B电子商务网站多年处于停滞不前&#xff0c;行业垄断现象&#xff0c;而且非常专注于B2B方向发展&#xff0c;没有其他业务范围可以拓展。http://www.755563.com/ “ 75商务网 ”看到其中亮点&#xff0c;在原有B2B基础上增加新型模式&#xff0c;变成B2B2C形式&#xff…

SVN钩子HOOK设置自动备份,服务本地可以看到所有更新内容。

可以实现SVN本机备份。或者其他备份。关键是可以保持有一份最新的SVN文件可以查看。 实现SVN与WEB同步,可以CO一个出来,也可以直接用自动更新web目录的方法&#xff0c;我们要在svn版本库中配置钩子来实现&#xff0c;就是创建一个post-commit的配置文件&#xff0c;对其进行简…

LeetCode—33. 搜索旋转排序数组

33. 搜索旋转排序数组 题目描述&#xff1a;整数数组 nums 按升序排列&#xff0c;数组中的值 互不相同 。 在传递给函数之前&#xff0c;nums 在预先未知的某个下标 k&#xff08;0 < k < nums.length&#xff09;上进行了 旋转&#xff0c;使数组变为 [nums[k], nums…

巧用脚本为木马“整容”

目的&#xff1a; 掌握基础的VBS脚本&#xff0c;“改变”木马后缀名不引起警觉&#xff0c;他点击木马后会先运行一段我们装备好的素材&#xff0c;音乐或图片&#xff0c;然后才执行木马 诱骗对方运行木马 前工作&#xff1a;根据需要准备一款木马&#xff0c;一个ICO图标文件…

重读STL

从第一次使用STL到现在也有四年了&#xff0c;说来惭愧&#xff0c;以前一直只是现用现查&#xff0c;还从来没有仔细地读一读STL的文档。前两天偶尔看到一个别人推荐的链接&#xff08;http://www.sgi.com/tech/stl/&#xff09;&#xff0c;才想起应该看看&#xff0c;一读之…

OSChina 周四乱弹 —— 熊孩子毁灭世界

2019独角兽企业重金招聘Python工程师标准>>> 小伙伴们赶快起床&#xff0c;开源中国要出大事啦~ 为方便大家搜索开源软件&#xff0c;开源中国决定整理 IT 公司开源软件。初步列表不一定完善&#xff0c;小伙伴们有什么意见可以向小小编或者红薯提出来~ 好啦好啦&am…

华为EC169 3G卡在Win7下的安装

最近换了机器&#xff0c;安装的是Win7。结果发现安装华为EC169 3G卡时&#xff0c;无法安装。&#xff08;注&#xff1a;我已更新为最新支持Win7的驱动。&#xff09; 折腾了近半天的时间&#xff0c;才发现是内码的问题。 由于工作需要&#xff0c;我将非Unicode的内码改为了…