Java 类org.springframework.web.socket.config.annotation.StompEndpointRegistry 实例源码

@Override
protected void registerStompEndpoints(StompEndpointRegistry registry) {
    // Can't rely on classpath detection
    RequestUpgradeStrategy upgradeStrategy = new TomcatRequestUpgradeStrategy();
    registry.addEndpoint("/stomp")
            .setHandshakeHandler(new DefaultHandshakeHandler(upgradeStrategy))
            .setAllowedOrigins("*");
}

@Override
protected void configureStompEndpoints(StompEndpointRegistry registry) {
       registry.addEndpoint(ACTIVITY_FEED_ENDPOINT)
        .setAllowedOrigins(protocol.concat(realmName))
        .withSockJS()
        .setStreamBytesLimit(512 * 1024)
           .setHttpMessageCacheSize(1000)
           .setDisconnectDelay(30 * 1000);

    registry.addEndpoint(PRIVATE_STOCKS_ENDPOINT)
        .setAllowedOrigins(protocol.concat(realmName))
        .withSockJS()
        .setStreamBytesLimit(512 * 1024)
           .setHttpMessageCacheSize(1000)
           .setDisconnectDelay(30 * 1000);
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    String[] allowedOrigins = Optional.ofNullable(jHipsterProperties.getCors().getAllowedOrigins()).map(origins -> origins.toArray(new String[0])).orElse(new String[0]);
    registry.addEndpoint("/websocket/tracker")
        .setHandshakeHandler(defaultHandshakeHandler())
        .setAllowedOrigins(allowedOrigins)
        .withSockJS()
        .setInterceptors(httpSessionHandshakeInterceptor());
}

/**
 * 配置端点注册中心,接收客户端的连接
 *
 * @param registry 端点注册中心
 */
@Override
public void registerStompEndpoints ( StompEndpointRegistry registry ) {
    /* 在指定的映射路径上为Web套接字端点注册一个STOMP. */
    // 表示添加了一个 /aidijing 端点,客户端就可以通过这个端点来进行连接.
    // aidijing
    registry.addEndpoint( stompEndpointsPaths )
            .withSockJS(); // 开启SockJS支持
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    boolean wsEnabled = false;
    for (Map.Entry<String, ZuulWebSocketProperties.WsBrokerage> entry : zuulWebSocketProperties
            .getBrokerages().entrySet()) {
        ZuulWebSocketProperties.WsBrokerage wsBrokerage = entry.getValue();
        if (wsBrokerage.isEnabled()) {
            this.addStompEndpoint(registry, wsBrokerage.getEndPoints());
            wsEnabled = true;
        }
    }

    if (!wsEnabled)
        this.addStompEndpoint(registry, UUID.randomUUID().toString());
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/sockjs")
            .addInterceptors(new SpaceKeyHandshakeInterceptor())
            .setAllowedOrigins(allowedOrigins)
            .withSockJS();
}

@Override
public void registerStompEndpoints(final StompEndpointRegistry registry)
{
    // the endpoint for websocket connections
    registry.addEndpoint(ENDPOINT)
            .setAllowedOrigins("*") // FIXME: for now we allow any origin
            .addInterceptors(new WebSocketHandshakeInterceptor())
            .withSockJS()
    //
    ;
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/seven-wonders-websocket")
            .setHandshakeHandler(handshakeHandler())
            .setAllowedOrigins("http://localhost:3000") // to allow frontend server proxy requests in dev mode
            .withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    // Utiliza este endpoint para connectar desde el navegador
    registry
        .setErrorHandler(new ErrorHandler())
        .addEndpoint("/stomp").withSockJS();

}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
  registry.addEndpoint("/websocket").setAllowedOrigins(
      properties.getWebsockets().getAllowedOrigins().toArray(new String[0])).withSockJS()
      .setSessionCookieNeeded(false)
      .setClientLibraryUrl("/bower_components/sockjs-client/dist/sockjs.min.js")
      .setInterceptors(websocketHandshakeInterceptor());
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry
        .addEndpoint("/stomp")
        .setAllowedOrigins("*")
        .withSockJS()
    ;
}

@Override
protected void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
    stompEndpointRegistry.addEndpoint(SdcctWebSocketPaths.TESTCASES_IHE_RESULTS)
        .setHandshakeHandler(new DefaultHandshakeHandler(new TomcatRequestUpgradeStrategy())).addInterceptors(new HttpSessionHandshakeInterceptor())
        .withSockJS().setClientLibraryUrl(this.sockJsClientLibUrl).setDisconnectDelay(this.sockJsDisconnectDelay).setHeartbeatTime(this.sockJsHeartbeatTime)
        .setHttpMessageCacheSize(this.sockJsHttpMsgCacheSize).setMessageCodec(new Jackson2SockJsMessageCodec(this.objMapper))
        .setStreamBytesLimit(this.sockJsStreamLimit);
}

@Override
public void registerStompEndpoints(final StompEndpointRegistry registry) {
  this.registry = registry;
  String atacamaInGulpServeMode = "http://localhost:3000"; 
  String inProcessWebsite = "http://localhost:48002"; 
  registry.addEndpoint("/reply").setAllowedOrigins(atacamaInGulpServeMode, inProcessWebsite).withSockJS();
  registry.addEndpoint("/request").setAllowedOrigins(atacamaInGulpServeMode, inProcessWebsite).withSockJS();
  registry.addEndpoint("/ping").setAllowedOrigins(atacamaInGulpServeMode, inProcessWebsite).withSockJS();
  registry.addEndpoint("/ticks").setAllowedOrigins(atacamaInGulpServeMode, inProcessWebsite).withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {

    logger.info("Initializing websocket standard on path:'{}' ...", defaultWebsocketEndpointPath);
    StompWebSocketEndpointRegistration webSockedEndpoint  = stompEndpointRegistry.addEndpoint(defaultWebsocketEndpointPath);
    logger.info("Initializing websocket sockJs on path:'{}' ...", defaultSockJsEndpointPath);
    StompWebSocketEndpointRegistration sockJsEndpoint = stompEndpointRegistry.addEndpoint(defaultSockJsEndpointPath);
    sockJsEndpoint.withSockJS();
    if (Boolean.valueOf(corsEnabled)){
        logger.info("Initializing cors on websockets");
        webSockedEndpoint.setAllowedOrigins(StringUtils.commaDelimitedListToStringArray(allowedOrigins));
        sockJsEndpoint.setAllowedOrigins(StringUtils.commaDelimitedListToStringArray(allowedOrigins));
    }
}

@Override
public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {

    logger.info("Initializing websocket standard on path:'{}' ...", defaultWebsocketEndpointPath);
    StompWebSocketEndpointRegistration webSockedEndpoint  = stompEndpointRegistry.addEndpoint(defaultWebsocketEndpointPath);
    logger.info("Initializing websocket sockJs on path:'{}' ...", defaultSockJsEndpointPath);
    StompWebSocketEndpointRegistration sockJsEndpoint = stompEndpointRegistry.addEndpoint(defaultSockJsEndpointPath);
    sockJsEndpoint.withSockJS();
    if (Boolean.valueOf(corsEnabled)){
        logger.info("Initializing cors on websockets");
        webSockedEndpoint.setAllowedOrigins(StringUtils.commaDelimitedListToStringArray(allowedOrigins));
        sockJsEndpoint.setAllowedOrigins(StringUtils.commaDelimitedListToStringArray(allowedOrigins));
    }
}

@Override
public final void registerStompEndpoints(StompEndpointRegistry registry) {
    if (registry instanceof WebMvcStompEndpointRegistry) {
        WebMvcStompEndpointRegistry mvcRegistry = (WebMvcStompEndpointRegistry) registry;
        configureStompEndpoints(new SessionStompEndpointRegistry(mvcRegistry,
                sessionRepositoryInterceptor()));
    }
}

@Override
public void configureStompEndpoints(StompEndpointRegistry registry) {
    log.info("WebSocket config: Allowing only origins: " + environment.getProperty("allowed.origin"));
    registry.addEndpoint("/ws").setAllowedOrigins(environment.getProperty("allowed.origin")).setHandshakeHandler(new SecureHandshakeHandler(preAuthAuthenticationManager))
            .withSockJS()
            .setStreamBytesLimit(512 * 1024)
            .setHttpMessageCacheSize(1000)
            .setDisconnectDelay(30 * 1000)
            .setInterceptors(new HttpSessionIdHandshakeInterceptor())
    ;
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    String[] allowedOrigins = Optional.ofNullable(jHipsterProperties.getCors().getAllowedOrigins()).map(origins -> origins.toArray(new String[0])).orElse(new String[0]);
    registry.addEndpoint("/websocket/tracker")
        .setHandshakeHandler(defaultHandshakeHandler())
        .setAllowedOrigins(allowedOrigins)
        .withSockJS()
        .setInterceptors(httpSessionHandshakeInterceptor());
}

@Override
public void registerStompEndpoints(final StompEndpointRegistry registry) {
    registry.addEndpoint("/logoutput")
            .addInterceptors(new HttpSessionHandshakeInterceptor())
            .withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    //使用SockJS协议
    registry.addEndpoint("/endpointshuaishuai").withSockJS();
    registry.addEndpoint("/endpointChat").withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/hello");
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/socket");
    registry.addEndpoint("/socket").withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
    stompEndpointRegistry.addEndpoint("/quarkServer").setAllowedOrigins("*").withSockJS();//stomp节点
}

@Override
public void configureStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
    stompEndpointRegistry.addEndpoint("/mud").withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/logger-app").setAllowedOrigins("*").withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/subscribe").setAllowedOrigins("*");
    registry.addEndpoint("/subscribe").setAllowedOrigins("*").withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint(endpoint).withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/maildump").withSockJS();
}

/**
 * 这个方法的作用是添加一个服务端点，来接收客户端的连接。
 *
 * @param stompEndpointRegistry StompEndpointRegistry
 */
@Override
public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
    //表示添加了一个/socket端点，客户端就可以通过这个端点来进行连接。
    stompEndpointRegistry.addEndpoint("/socket").withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
    stompEndpointRegistry.addEndpoint("/stomp").setAllowedOrigins("*").withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    //no withSockJS() if not working with js
    registry.addEndpoint("/socket-todos").setAllowedOrigins("*").withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/company").withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
  registry.addEndpoint("/websocket").withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
    stompEndpointRegistry.addEndpoint("/commentStream", "/postStream").withSockJS();
}

@Override
public void registerStompEndpoints(final StompEndpointRegistry registry) {
    registry
        .addEndpoint("/websocket")
        .withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
   registry.addEndpoint("/spring-boot-slingshot")
           .withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/gs-guide-websocket").withSockJS()
            .setClientLibraryUrl("/webjars/sockjs-client/1.0.2/sockjs.min.js");
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
       registry.addEndpoint("/mrp-websocket").withSockJS();
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("endpoint")
        .setAllowedOrigins("*");
}

@Override
public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
    stompEndpointRegistry.addEndpoint("/stomp").setAllowedOrigins("*").withSockJS();
}