import org.atmosphere.cpr.AtmosphereFramework; //导入依赖的package包/类
public WebsocketConsumer(WebsocketEndpoint endpoint, Processor processor) {
    super(endpoint, processor);
    this.framework = new AtmosphereFramework(false, true);

    framework.setUseNativeImplementation(false);
    framework.addInitParameter(ApplicationConfig.WEBSOCKET_SUPPORT, "true");
    framework.addInitParameter(ApplicationConfig.WEBSOCKET_PROTOCOL, 
        endpoint.isUseStreaming() ? WebsocketStreamHandler.class.getName() : WebsocketHandler.class.getName());
    //REVISIT we need to disable JSR356 detection for now when using jetty-9.3 when using atmosphere-2.4.x
    framework.addInitParameter(ApplicationConfig.WEBSOCKET_SUPPRESS_JSR356, "true");
    framework.init();
    
    WebSocketProtocol wsp = framework.getWebSocketProtocol();
    if (wsp instanceof WebsocketHandler) {
        ((WebsocketHandler)wsp).setConsumer(this);            
    } else {
        throw new IllegalArgumentException("Unexpected WebSocketHandler: " + wsp);
    }
}
 

import org.atmosphere.cpr.AtmosphereFramework; //导入依赖的package包/类
AtmosphereCoordinator() {
    framework = new AtmosphereFramework();
    asynchronousProcessor = new NettyCometSupport(framework().getAtmosphereConfig());
    framework.setAsyncSupport(asynchronousProcessor);
    suspendTimer = ExecutorsFactory.getScheduler(framework.getAtmosphereConfig());
    mapper = framework.endPointMapper();
}
 

import org.atmosphere.cpr.AtmosphereFramework; //导入依赖的package包/类
private AtmosphereCoordinator initAtmosphere(Router router, VertxVaadinService service) {
    final String bufferSize = String.valueOf(PushConstants.WEBSOCKET_BUFFER_SIZE);

    AtmosphereInterceptor trackMessageSize = new TrackMessageSizeInterceptor();

    VertxAtmosphere.Builder pushBuilder = new VertxAtmosphere.Builder()
        .initParam(ApplicationConfig.BROADCASTER_CACHE, UUIDBroadcasterCache.class.getName())
        .initParam(ApplicationConfig.ANNOTATION_PROCESSOR, VoidAnnotationProcessor.class.getName())
        .initParam(ApplicationConfig.PROPERTY_SESSION_SUPPORT, "true")
        .initParam(ApplicationConfig.MESSAGE_DELIMITER, String.valueOf(PushConstants.MESSAGE_DELIMITER))
        .initParam(ApplicationConfig.DROP_ACCESS_CONTROL_ALLOW_ORIGIN_HEADER, "false")
        // Disable heartbeat (it does not emit correct events client side)
        // https://github.com/Atmosphere/atmosphere-javascript/issues/141
        .initParam(ApplicationConfig.DISABLE_ATMOSPHEREINTERCEPTORS, HeartbeatInterceptor.class.getName())
        .initParam(ApplicationConfig.WEBSOCKET_BUFFER_SIZE, bufferSize)
        .initParam(ApplicationConfig.WEBSOCKET_MAXTEXTSIZE, bufferSize)
        .initParam(ApplicationConfig.WEBSOCKET_MAXBINARYSIZE, bufferSize)
        .initParam(ApplicationConfig.PROPERTY_ALLOW_SESSION_TIMEOUT_REMOVAL, "false")
        // Disable Atmosphere's message about commercial support
        .initParam("org.atmosphere.cpr.showSupportMessage", "false")
        .interceptor(trackMessageSize);

    AtmosphereCoordinator atmosphereCoordinator = ExposeAtmosphere.newCoordinator(pushBuilder);
    AtmosphereFramework framework = atmosphereCoordinator.framework();
    trackMessageSize.configure(framework.getAtmosphereConfig());

    VertxPushHandler vertxPushHandler = new VertxPushHandler(service);
    vertxPushHandler.setLongPollingSuspendTimeout(framework.getAtmosphereConfig()
        .getInitParameter(com.vaadin.server.Constants.SERVLET_PARAMETER_PUSH_SUSPEND_TIMEOUT_LONGPOLLING, -1));

    PushAtmosphereHandler pushAtmosphereHandler = new PushAtmosphereHandler();
    pushAtmosphereHandler.setPushHandler(vertxPushHandler);
    framework.addAtmosphereHandler("/*", pushAtmosphereHandler);

    atmosphereCoordinator.ready();

    service.addServiceDestroyListener(event -> atmosphereCoordinator.shutdown());

    return atmosphereCoordinator;
}
 

import org.atmosphere.cpr.AtmosphereFramework; //导入依赖的package包/类
public AtmosphereFramework framework() {
    return framework;
}
 

import org.atmosphere.cpr.AtmosphereFramework; //导入依赖的package包/类
@Override
public void init() {
    AtmosphereFramework framework = (AtmosphereFramework) servletContext.getAttribute("AtmosphereServlet");
    servletContext.setAttribute(NOTIFICATION_SERVICE, new NotificationService(framework));
    status = ModuleStatus.ACTIVE;
}
 

import org.atmosphere.cpr.AtmosphereFramework; //导入依赖的package包/类
public NotificationService(AtmosphereFramework framework) {
    this.framework = framework;
}
 

import org.atmosphere.cpr.AtmosphereFramework; //导入依赖的package包/类
@Bean
public AtmosphereFramework atmosphereFramework() {
  return atmosphereServlet().framework();
}
 

import org.atmosphere.cpr.AtmosphereFramework; //导入依赖的package包/类
@Bean
public MetaBroadcaster metaBroadcaster() {
  AtmosphereFramework framework = atmosphereFramework();
  return framework.metaBroadcaster();
}