简单的网站建设模板,全国哪个餐饮品牌的网站做的好处,网址查询ip解析,云伙伴公司客户案例2019独角兽企业重金招聘Python工程师标准 介绍 现很多网站为了实现即时通讯#xff0c;所用的技术都是轮询(polling)。轮询是在特定的的时间间隔#xff08;如每1秒#xff09;#xff0c;由浏览器对服务器发出HTTP request#xff0c;然后由服务器返回最新… 2019独角兽企业重金招聘Python工程师标准 介绍 现很多网站为了实现即时通讯所用的技术都是轮询(polling)。轮询是在特定的的时间间隔如每1秒由浏览器对服务器发出HTTP request然后由服务器返回最新的数据给客服端的浏览器。这种传统的HTTP request 的模式带来很明显的缺点 – 浏览器需要不断的向服务器发出请求然而HTTP request 的header是非常长的里面包含的数据可能只是一个很小的值这样会占用很多的带宽。 而最比较新的技术去做轮询的效果是Comet – 用了AJAX。但这种技术虽然可达到全双工通信但依然需要发出请求。 在 WebSocket API浏览器和服务器只需要要做一个握手的动作然后浏览器和服务器之间就形成了一条快速通道。两者之间就直接可以数据互相传送。 依赖 Tomcat 7 或者 J2EE7 dependency
groupIdorg.apache.tomcat/groupId
artifactIdtomcat-websocket-api/artifactId
version7.0.47/version
scopeprovided/scope
/dependencydependency
groupIdjavax/groupId
artifactIdjavaee-api/artifactId
version7.0/version
scopeprovided/scope
/dependency 注意早前业界没有统一的标准各服务器都有各自的实现现在J2EE7的JSR356已经定义了统一的标准请尽量使用支持最新通用标准的服务器。 详见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) {returnGot 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 MapString, 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
groupIdorg.java-websocket/groupId
artifactIdJava-WebSocket/artifactId
version1.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
