import org.vertx.java.core.http.ServerWebSocket; //导入依赖的package包/类
@Override
public void handle(final ServerWebSocket socket) {
    DetectingGateway handler = this.gateway.get();
    if ( handler==null ) {
        LOG.info("Rejecting web socket: no protocol detecting gateway deployed");
        socket.reject();
        return;
    } else if ( pathPrefix!=null && !socket.path().startsWith(pathPrefix) ) {
        LOG.info("Rejecting web socket: request path does not start with:"+ pathPrefix);
        socket.reject();
        return;
    }
    LOG.info("Processing the web socket '"+socket.remoteAddress()+"' with the protocol detecting gateway");
    handler.handle(SocketWrapper.wrap(socket));
}
 

import org.vertx.java.core.http.ServerWebSocket; //导入依赖的package包/类
public void start(int port) {

        vertx = VertxFactory.newVertx();

        httpServer = vertx.createHttpServer();
        httpServer.websocketHandler(new Handler<ServerWebSocket>() {
            public void handle(final ServerWebSocket ws) {

                if (ws.path().equals("/echo")) {

                    ws.frameHandler(new Handler<WebSocketFrame>() {
                        @Override
                        public void handle(WebSocketFrame webSocketFrame) {
                            if (webSocketFrame.isBinary()) {
                                Buffer buff = new Buffer(((WebSocketFrameInternal) webSocketFrame).getBinaryData());
                                ws.writeBinaryFrame(buff);
                            } else if (webSocketFrame.isText()) {
                                ws.writeTextFrame(webSocketFrame.textData());
                            }
                        }
                    });

                } else {
                    ws.reject();
                }
            }
        }).listen(port);
    }
 

import org.vertx.java.core.http.ServerWebSocket; //导入依赖的package包/类
public String getSigned(String name, String path, ServerWebSocket ws) {
	if (ws.headers().get("Cookie") != null) {
		Set<Cookie> cookies = CookieDecoder.decode(ws.headers().get("Cookie"));
		return getSignedCookie(name, path, cookies);
	}
	return null;
}
 

import org.vertx.java.core.http.ServerWebSocket; //导入依赖的package包/类
public HttpGatewayServer(Vertx vertx, HttpGatewayHandler handler, Handler<ServerWebSocket> websocketHandler, int port) {
    this.vertx = vertx;
    this.handler = handler;
    this.websocketHandler = websocketHandler;
    this.port = port;
}
 

import org.vertx.java.core.http.ServerWebSocket; //导入依赖的package包/类
public void addWebSocket(ServerWebSocket webSocket) {
    if(!webSockets.contains(webSocket))webSockets.add(webSocket);
}
 

import org.vertx.java.core.http.ServerWebSocket; //导入依赖的package包/类
public List<ServerWebSocket> getWebSockets() {
    return Collections.unmodifiableList(webSockets);
}
 

import org.vertx.java.core.http.ServerWebSocket; //导入依赖的package包/类
public void removeWebSocket(ServerWebSocket webSocket) {
    webSockets.remove(webSocket);
}
 

import org.vertx.java.core.http.ServerWebSocket; //导入依赖的package包/类
public void addWebSocket(ServerWebSocket webSocket) {
    webSockets.add(webSocket);
}
 

import org.vertx.java.core.http.ServerWebSocket; //导入依赖的package包/类
public List<ServerWebSocket> getWebSockets() {
    return webSockets;
}
 

import org.vertx.java.core.http.ServerWebSocket; //导入依赖的package包/类
/**
 * handles connection close
 *
 * @param event
 */
private void handleConnectionClose(final Void event, ServerWebSocket socket) {
    repository.removeWebSocket(socket);
}