本文整理了Java中io.reactivex.netty.protocol.http.websocket.WebSocketServerBuilder类的一些代码示例，展示了WebSocketServerBuilder类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WebSocketServerBuilder类的具体详情如下：
包路径：io.reactivex.netty.protocol.http.websocket.WebSocketServerBuilder
类名称：WebSocketServerBuilder

WebSocketServerBuilder介绍

暂无

代码示例

代码示例来源：origin: com.netflix.rxnetty/rx-netty

@Override
protected RxServer<I, O> createServer() {
  PipelineConfigurator<I, O> webSocketPipeline = new WebSocketServerPipelineConfigurator<I, O>(webSocketURI,
      subprotocols, allowExtensions, maxFramePayloadLength, messageAggregator);
  if (getPipelineConfigurator() != null) {
    appendPipelineConfigurator(webSocketPipeline);
  } else {
    pipelineConfigurator(webSocketPipeline);
  }
  return new WebSocketServer<I, O>(serverBootstrap, port, pipelineConfigurator, connectionHandler, eventExecutorGroup);
}

代码示例来源：origin: com.netflix.rxnetty/rx-netty

public static <I extends WebSocketFrame, O extends WebSocketFrame> WebSocketServerBuilder<I, O>
newWebSocketServerBuilder(int port, ConnectionHandler<I, O> connectionHandler) {
  return new WebSocketServerBuilder<I, O>(port, connectionHandler).enableWireLogging(LogLevel.DEBUG);
}

代码示例来源：origin: com.netflix.karyon/karyon2-governator

@Inject
  @SuppressWarnings("unchecked")
  public void setInjector(Injector injector) {
    KaryonWebSocketsModule.WebSocketsServerConfig config = (KaryonWebSocketsModule.WebSocketsServerConfig) injector.getInstance(serverConfigKey);

    ConnectionHandler<I, O> connectionHandler = injector.getInstance(connectionHandlerKey);

    WebSocketServerBuilder<I, O> builder = RxNetty.newWebSocketServerBuilder(config.getPort(), connectionHandler)
        .withMessageAggregator(config.isMessageAggregator());

    if (injector.getExistingBinding(pipelineConfiguratorKey) != null) {
      builder.appendPipelineConfigurator(injector.getInstance(pipelineConfiguratorKey));
    }

    if (injector.getExistingBinding(metricEventsListenerFactoryKey) != null) {
      builder.withMetricEventsListenerFactory(injector.getInstance(metricEventsListenerFactoryKey));
    }

    server = builder.build().start();
    logger.info("Starting WebSockets server {} on port {}...", nameAnnotation.value(), server.getServerPort());
  }
}

代码示例来源：origin: com.netflix.eureka/eureka2-server

public <T extends WebSocketFrame> void connectWebSocketEndpoint(String pathPrefix, ConnectionHandler<T, T> handler) {
  WebSocketServer<T, T> backend = RxNetty.newWebSocketServerBuilder(0, handler).build();
  backend.start();
  backendServers.add(backend);
  proxy.register(ForwardingRule.pathPrefix(backend.getServerPort(), pathPrefix));
  logger.info("Started backend WebSocket server on port {} or {}", backend.getServerPort(), handler.getClass().getSimpleName());
}

代码示例来源：origin: com.netflix.karyon2/karyon-governator

@Inject
  @SuppressWarnings("unchecked")
  public void setInjector(Injector injector) {
    KaryonWebSocketsModule.WebSocketsServerConfig config = (KaryonWebSocketsModule.WebSocketsServerConfig) injector.getInstance(serverConfigKey);

    ConnectionHandler<I, O> connectionHandler = injector.getInstance(connectionHandlerKey);

    WebSocketServerBuilder<I, O> builder = RxNetty.newWebSocketServerBuilder(config.getPort(), connectionHandler)
        .withMessageAggregator(config.isMessageAggregator());

    if (injector.getExistingBinding(pipelineConfiguratorKey) != null) {
      builder.appendPipelineConfigurator(injector.getInstance(pipelineConfiguratorKey));
    }

    if (injector.getExistingBinding(metricEventsListenerFactoryKey) != null) {
      builder.withMetricEventsListenerFactory(injector.getInstance(metricEventsListenerFactoryKey));
    }

    server = builder.build().start();
    logger.info("Starting WebSockets server {} on port {}...", nameAnnotation.value(), server.getServerPort());
  }
}

代码示例来源：origin: com.netflix.eureka/eureka2-dashboard

@PostConstruct
public void start() {
  server = RxNetty.newWebSocketServerBuilder(config.getWebSocketPort(), new ConnectionHandler<WebSocketFrame, WebSocketFrame>() {
    @Override
    public Observable<Void> handle(final ObservableConnection<WebSocketFrame, WebSocketFrame> connection) {
      return connection.getInput().flatMap(new Func1<WebSocketFrame, Observable<Void>>() {
        @Override
        public Observable<Void> call(WebSocketFrame wsFrame) {
          if (wsFrame instanceof TextWebSocketFrame) {
            TextWebSocketFrame textFrame = (TextWebSocketFrame) wsFrame;
            logger.info("Got ws-message: " + textFrame.text());
            final String cmd = textFrame.text();
            if (cmd.equals("get status")) {
              return streamEurekaStatus(connection);
            } else {
              // registry
              return streamEurekaRegistryData(connection);
            }
          } else {
            return Observable.empty();
          }
        }
      });
    }
  }).build().start();
  logger.info("Starting WebSocket server on port {}...", server.getServerPort());
}

代码示例来源：origin: com.netflix.karyon/karyon-governator

@Inject
  @SuppressWarnings("unchecked")
  public void setInjector(Injector injector) {
    WebSocketsServerConfig config = (WebSocketsServerConfig) injector.getInstance(serverConfigKey);

    ConnectionHandler<I, O> connectionHandler = injector.getInstance(connectionHandlerKey);

    WebSocketServerBuilder<I, O> builder = RxNetty.newWebSocketServerBuilder(config.getPort(), connectionHandler)
        .withMessageAggregator(config.isMessageAggregator());

    if (injector.getExistingBinding(pipelineConfiguratorKey) != null) {
      builder.appendPipelineConfigurator(injector.getInstance(pipelineConfiguratorKey));
    }

    if (injector.getExistingBinding(metricEventsListenerFactoryKey) != null) {
      builder.withMetricEventsListenerFactory(injector.getInstance(metricEventsListenerFactoryKey));
    }

    server = builder.build().start();
    logger.info("Starting WebSockets server {} on port {}...", nameAnnotation.value(), server.getServerPort());
  }
}

代码示例来源：origin: io.reactivex/rxnetty

@Override
protected RxServer<I, O> createServer() {
  PipelineConfigurator<I, O> webSocketPipeline = new WebSocketServerPipelineConfigurator<I, O>(webSocketURI,
      subprotocols, allowExtensions, maxFramePayloadLength, messageAggregator);
  if (getPipelineConfigurator() != null) {
    appendPipelineConfigurator(webSocketPipeline);
  } else {
    pipelineConfigurator(webSocketPipeline);
  }
  return new WebSocketServer<I, O>(serverBootstrap, port, pipelineConfigurator, connectionHandler, eventExecutorGroup);
}

代码示例来源：origin: com.netflix.eureka2/eureka-dashboard

@PostConstruct
public void start() {
  server = RxNetty.newWebSocketServerBuilder(config.getWebSocketPort(), new ConnectionHandler<WebSocketFrame, WebSocketFrame>() {
    @Override
    public Observable<Void> handle(final ObservableConnection<WebSocketFrame, WebSocketFrame> connection) {
      return connection.getInput().flatMap(new Func1<WebSocketFrame, Observable<Void>>() {
        @Override
        public Observable<Void> call(WebSocketFrame wsFrame) {
          final SocketAddress socketAddress = connection.getChannel().remoteAddress();
          if (wsFrame instanceof TextWebSocketFrame) {
            TextWebSocketFrame textFrame = (TextWebSocketFrame) wsFrame;
            logger.info("Got ws-message: " + textFrame.text());
            final String cmd = textFrame.text();
            if (cmd.equals("get status")) {
              return streamEurekaStatus(connection);
            } else {
              // registry
              return streamEurekaRegistryData(connection);
            }
          } else {
            return Observable.empty();
          }
        }
      });
    }
  }).build().start();
  logger.info("Starting WebSocket server on port {}...", server.getServerPort());
}

代码示例来源：origin: io.reactivex/rxnetty

public static <I extends WebSocketFrame, O extends WebSocketFrame> WebSocketServerBuilder<I, O>
newWebSocketServerBuilder(int port, ConnectionHandler<I, O> connectionHandler) {
  return new WebSocketServerBuilder<I, O>(port, connectionHandler).enableWireLogging(LogLevel.DEBUG);
}