2

我正在尝试在本地 Glassfish 3.1.2 服务器安装中使用 websocket。我在我的 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);
    }
}

VideoSharingWebSocket.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);
    }

}

VideoSharingApplication.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

客户端代码，app.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）日志。

你有什么建议吗？

先感谢您。

此致。

4

1 回答 1

1

GlassFish 3.1.2 使用 Grizzly 1.9.46。Grizzly 2.x 与该版本的 GlassFish 不兼容。您需要在 3.1.2 中使用 1.9.46 或更高版本的 1.9。

于 2012-05-01T17:19:40.913 回答