import org.red5.server.plugin.PluginRegistry; //导入依赖的package包/类
@Override
public void onWSMessage(WSMessage message) {
    // assume we have text
    String msg = new String(message.getPayload().array());
    log.info("onWSMessage: {}", msg);
    // get the path 
    String path = message.getPath();
    // just echo back the message
    WebSocketScopeManager manager = ((WebSocketPlugin) PluginRegistry.getPlugin("WebSocketPlugin")).getManager(path);
    if (manager != null) {
        // get the ws scope
        WebSocketScope wsScope = manager.getScope(path);
        Set<WebSocketConnection> conns = wsScope.getConns();
        for (WebSocketConnection conn : conns) {
            log.debug("Echoing to {}", conn);
            try {
                conn.send(msg);
            } catch (UnsupportedEncodingException e) {
                log.warn("Encoding issue with the message data: {}", message, e);
            }
        }
    } else {
        log.info("No manager found for path: {}", path);
    }
}
 

import org.red5.server.plugin.PluginRegistry; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public void sessionClosed(IoSession session) throws Exception {
    log.trace("Session closed");
    // remove connection from scope
    WebSocketConnection conn = (WebSocketConnection) session.removeAttribute(Constants.CONNECTION);
    if (conn != null) {
        // remove from the manager
        WebSocketPlugin plugin = (WebSocketPlugin) PluginRegistry.getPlugin("WebSocketPlugin");
        if (plugin != null) {
            String path = conn.getPath();
            if (path != null) {
                WebSocketScopeManager manager = (WebSocketScopeManager) session.removeAttribute(Constants.MANAGER);
                if (manager == null) {
                    manager = plugin.getManager(path);
                }
                if (manager != null) {
                    manager.removeConnection(conn);
                } else {
                    log.debug("WebSocket manager was not found");
                }
            } else {
                log.debug("WebSocket connection path was null");
            }
        } else {
            log.debug("WebSocket plugin was not found");
        }
    } else {
        log.debug("WebSocket connection was null");
    }
    super.sessionClosed(session);
}
 

import org.red5.server.plugin.PluginRegistry; //导入依赖的package包/类
/**
 * Receive data from a client.
 * 
 * @param message
 */
public void receive(WSMessage message) {
    log.trace("receive message");
    if (isConnected()) {
        WebSocketScopeManager manager = (WebSocketScopeManager) session.getAttribute(Constants.MANAGER);
        if (manager == null) {
            WebSocketPlugin plugin = (WebSocketPlugin) PluginRegistry.getPlugin("WebSocketPlugin");
            manager = plugin.getManager(path);
        }
        WebSocketScope scope = manager.getScope(path);
        scope.onMessage(message);
    } else {
        log.warn("Not connected");
    }
}
 

import org.red5.server.plugin.PluginRegistry; //导入依赖的package包/类
/**
 * Registers with the WebSocketScopeManager.
 */
public void register() {
    log.info("Application scope: {}", scope);
    // set the logger to the app scope
    //log = Red5LoggerFactory.getLogger(WebSocketScope.class, scope.getName());
    WebSocketScopeManager manager = ((WebSocketPlugin) PluginRegistry.getPlugin("WebSocketPlugin")).getManager(scope);
    manager.setApplication(scope);
    log.info("WebSocket app added: {}", scope.getName());
    manager.addWebSocketScope(this);
    log.info("WebSocket scope added");
}
 

import org.red5.server.plugin.PluginRegistry; //导入依赖的package包/类
@Test
public void testUriWithParams() throws Throwable {
    log.info("\ntestUriWithParams enter");
    // create the server instance
    Thread server = new Thread() {
        @Override
        public void run() {
            log.debug("Server thread run");
            try {
                WSServer.main(null);
            } catch (IOException e) {
                log.error("Error in server thread", e);
            }
            log.debug("Server thread exit");
        }
    };
    server.setDaemon(true);
    server.start();
    // add plugin to the registry
    WebSocketPlugin plugin = new WebSocketPlugin();
    PluginRegistry.register(plugin);
    // start plugin
    plugin.doStart();
    // create a scope for the manager
    IScope appScope = new GlobalScope();
    // create an app
    MultiThreadedApplicationAdapter app = new MultiThreadedApplicationAdapter();
    app.setScope(appScope);
    // add the app
    plugin.setApplication(app);
    // get the manager
    WebSocketScopeManager manager = plugin.getManager(appScope);
    manager.setApplication(appScope);
    // wait for server
    while (!WSServer.isListening()) {
        Thread.sleep(10L);
    }
    // create the client
    final TyrusWSClient client = new TyrusWSClient();
    //final TyrusWSClient client = new TyrusWSClient(8192 * 10);
    Thread t = new Thread(new Runnable() {
        public void run() {
            client.start();
        }
    }, "tyrus");
    t.start();
    t.join(5000);
    // send a message
    //client.sendMessage("This is a test");
    // terminate client
    client.terminate();
    // stop server
    server.interrupt();
    WSServer.stop();
    // stop plugin
    PluginRegistry.shutdown();
    log.info("testUriWithParams exit");
}
 

import org.red5.server.plugin.PluginRegistry; //导入依赖的package包/类
@Override
public boolean appStart(IScope scope) {
    WebSocketScopeManager manager = ((WebSocketPlugin) PluginRegistry.getPlugin("WebSocketPlugin")).getManager();
    manager.addApplication(scope);
    return super.appStart(scope);
}
 

import org.red5.server.plugin.PluginRegistry; //导入依赖的package包/类
@Override
public void appStop(IScope scope) {
    WebSocketScopeManager manager = ((WebSocketPlugin) PluginRegistry.getPlugin("WebSocketPlugin")).getManager();
    manager.removeApplication(scope);
    super.appStop(scope);
}