Java中Websocket使用实例解析
Java中Websocket使用实例解析
在 WebSocket API，浏览器和服务器只需要要做一个握手的动作，然后，浏览器和服务器之间就形成了一条快速通道。两者之间就直接可以数据互相传送。下面店铺给大家介绍Java中Websocket使用实例解析，欢迎阅读!
Java中Websocket使用实例解析
运行环境
客户端
实现了websocket的浏览器
     
     
Chrome     
Supported in version 4+     
Firefox     
Supported in version 4+     
Internet Explorer     
Supported in version 10+     
Opera     
Supported in version 10+     
Safari     
Supported in version 5+     
服务端
依赖
<dependency>
<groupId>at</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>
注意：早前业界没有统一的标准，各服务器都有各自的实现，现在J2EE7的JSR356已经定义了统一的标准，请尽量使用支持最新通用标准的服务器。
我是用的Tomcat 7.0.57 + Java7
必须是Tomcat 7.0.47以上
ps：最早我们是用的Tomcat 7自带的实现，后来要升级Tomcat 8，结果原来的实现方式在Tomcat 8不支持了，就只好切换到支持Websocket 1.0版本的Tomcat了。
主流的java web服务器都有支持JSR365标准的版本了，请自行Google。
用nginx做反向代理的需要注意啦，socket请求需要做特殊配置的，切记!
Tomcat的处理方式建议修改为NIO的方式，同时修改连接数到合适的参数，请自行Google!
服务端不需要在l中做额外的配置，Tomcat启动后就可以直接连接了。
实现
import com.dooioo.websocket.utils.SessionUtils;
import org.apachemons.logging.Log;
import org.apachemons.logging.LogFactory;
import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
/**
* 功能说明：websocket处理类, 使用J2EE7的标准
* 切忌直接在该连接处理类中加入业务处理代码
*/
//relationId和userCode是我的业务标识参数,websocket.ws是连接的路径，可以自行定义
@ServerEndpoint("/websocket.ws/{relationId}/{userCode}")
public class WebsocketEndPoint {
private static Log log = Log(WebsocketEndPoint.class);
/**
* 打开连接时触发
* @param relationId
* @param userCode
* @param session
*/
@OnOpen
public void onOpen(@PathParam("relationId") String relationId,
@PathParam("userCode") int userCode,
Session session){
log.info("Websocket Start Connecting: " + Key(relationId, userCode));
SessionUtils.put(relationId, userCode, session);
}
/**
* 收到客户端消息时触发
* @param relationId
* @param userCode
* @param message
* @return
*/
@OnMessage
public String onMessage(@PathParam("relationId") String relationId,
@PathParam("userCode") int userCode,
String message) {
return "Got your message (" + message + ").Thanks !";
}
/**
* 异常时触发
* @param relationId
* @param userCode
* @param session
*/
@OnError
public void onError(@PathParam("relationId") String relationId,
@PathParam("userCode") int userCode,
Throwable throwable,
Session session) {
log.info("Websocket Connection Exception: " + Key(relationId, userCode));
log.Message(), throwable);
ve(relationId, userCode);
app开发实例
}
/**
* 关闭连接时触发
* @param relationId
* @param userCode
* @param session
*/
@OnClose
public void onClose(@PathParam("relationId") String relationId,
@PathParam("userCode") int userCode,
Session session) {
log.info("Websocket Close Connection: " + Key(relationId, userCode));
ve(relationId, userCode);
}
}
工具类用来存储唯一key和连接
这个是我业务的`需要，我的业务是服务器有对应动作触发时，推送数据到客户端，没有接收客户端数据的操作。
import javax.websocket.Session;
import java.util.Map;
import urrent.ConcurrentHashMap;
/**
* 功能说明：用来存储业务定义的sessionId和连接的对应关系
* 利用业务逻辑中组装的sessionId获取有效连接后进行后续操作
*/
public class SessionUtils {
public static Map clients = new ConcurrentHashMap<>();
public static void put(String relationId, int userCode, Session session){
clients.put(getKey(relationId, userCode), session);