我正在尝试在本地 Glassfish 3.1.2 服务器安装中使用 websockets。我在我的Maven项目中使用Grizzly 2.2:
<dependency>
<groupId>org.glassfish.grizzly</groupId>
<artifactId>grizzly-websockets</artifactId>
<version>2.2</version>
</dependency>
WebSocketsServlet.java
import org.glassfish.grizzly.Grizzly;
import java.util.logging.Logger;
import org.glassfish.grizzly.websockets.WebSocketEngine;
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
public class WebSocketsServlet extends HttpServlet {
private static final Logger logger = Grizzly.logger(WebSocketsServlet.class);
private final VideoSharingApplication app = new VideoSharingApplication();
@Override
public void init(ServletConfig config) throws ServletException {
logger.log(Level.SEVERE, "registering");
WebSocketEngine.getEngine().register(config.getServletContext().getContextPath() + "/videosharing", app);
}
@Override
public void destroy() {
WebSocketEngine.getEngine().unregister(app);
}
}
视频共享网络套接字.java
import java.util.logging.Logger;
import org.glassfish.grizzly.websockets.DefaultWebSocket;
import org.glassfish.grizzly.websockets.ProtocolHandler;
import org.glassfish.grizzly.websockets.WebSocketListener;
import org.glassfish.grizzly.Grizzly;
public class VideoSharingWebSocket extends DefaultWebSocket {
private static final Logger logger = Grizzly.logger(VideoSharingWebSocket.class);
public VideoSharingWebSocket(ProtocolHandler handler, WebSocketListener... listeners) {
super(handler, listeners);
}
}
视频共享应用程序.java
import java.util.logging.Level;
import java.util.logging.Logger;
import org.glassfish.grizzly.Grizzly;
import org.glassfish.grizzly.websockets.ProtocolHandler;
import org.glassfish.grizzly.websockets.WebSocket;
import org.glassfish.grizzly.websockets.WebSocketApplication;
import org.glassfish.grizzly.websockets.WebSocketListener;
import org.glassfish.grizzly.http.HttpRequestPacket;
public class VideoSharingApplication extends WebSocketApplication {
private static final Logger logger = Grizzly.logger(VideoSharingApplication.class);
@Override
public WebSocket createSocket(ProtocolHandler handler, WebSocketListener... listeners) {
logger.log(Level.SEVERE, "createSocket");
return new VideoSharingWebSocket(handler, listeners);
}
@Override
public boolean isApplicationRequest(HttpRequestPacket request) {
logger.log(Level.SEVERE, "isApplicationRequest");
return "/videosharing".equals(request.getRequestURI());
}
@Override
public void onMessage(WebSocket socket, String data) {
logger.log(Level.SEVERE, "onMessage");
for (WebSocket webSocket : getWebSockets()) {
if (socket != webSocket) {
webSocket.send(data);
}
}
}
}
我用这个命令在 Glassfish 中启用了 websockets 支持:
asadmin set configs.config.server-config.network-config.protocols.protocol.http-listener-1.http.websockets-support-enabled=true
客户端代码、应用程序.js:
var network = function () {
return {
initialize: function() {
var url = 'ws://localhost:8080/monApp/videosharing';
var websocket = new WebSocket(url);
websocket.name = APP.id;
websocket.onopen = function(evt) {
alert('onopen');
};
websocket.onerror = function(evt) {
alert('onerror');
};
websocket.onmessage = function (evt) {
alert('onmessage');
var command = JSON.parse(evt.data);
if (command.type == "pause") {
APP.pauseVideo();
} else if (command.type == "play") {
APP.playVideo();
} else if (command.type == "seeked") {
APP.seekVideo(command.currentTime);
} else {
alert("Unknown command " + command);
}
};
websocket.onclose = function()
{
alert('onclose');
};
},
send: function(command) {
websocket.send(command);
}
}
};
var APP = {
id: Math.floor(Math.random() * 10000),
network: network(),
// Cannot use 'this' here after updating window.onload (see below)
initialize: function () {
APP.network.initialize();
var video = APP.getVideo();
video.addEventListener('play',
function (event) {
alert('play');
var command = { type: "play" };
APP.network.send(JSON.stringify(command));
},
false);
video.addEventListener('pause',
function (event) {
alert('pause');
var command = { type: "pause" };
APP.network.send(JSON.stringify(command));
},
false);
video.addEventListener('seeked',
function (event) {
alert('seeked');
var command = { type: "seeked",
currentTime: APP.getVideo().currentTime };
APP.network.send(JSON.stringify(command));
},
false);
},
getVideo: function () {
return document.getElementsByTagName("video")[0];
},
pauseVideo: function () {
var video = this.getVideo();
video.pause();
},
playVideo: function () {
var video = this.getVideo();
video.play();
},
seekVideo: function (currentTime) {
var video = this.getVideo();
video.currentTime = currentTime;
}
};
window.onload = APP.initialize;
我正在 Mac 的 Chrome 18.0.1025.165 中对此进行测试。在页面加载时,我收到此错误:
Unexpected response code: 405
在服务器日志中没有错误,只显示我的"注册"(WebSocketsServlet)日志。
你有什么建议吗?
提前谢谢你。
此致敬意。
GlassFish 3.1.2 使用 Grizzly 1.9.46。 Grizzly 2.x与该版本的GlassFish不兼容。 您需要将 1.9.46 或更高版本的 1.9 与 3.1.2 一起使用。