org.springframework.web.socket.WebSocketHttpHeaders.<init>()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(12.6k)|赞(0)|评价(0)|浏览(199)

本文整理了Java中org.springframework.web.socket.WebSocketHttpHeaders.<init>()方法的一些代码示例，展示了WebSocketHttpHeaders.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WebSocketHttpHeaders.<init>()方法的具体详情如下：
包路径：org.springframework.web.socket.WebSocketHttpHeaders
类名称：WebSocketHttpHeaders
方法名：<init>

WebSocketHttpHeaders.<init>介绍

[英]Create a new instance.
[中]创建一个新实例。

代码示例

代码示例来源：origin: spring-projects/spring-framework

  1. /**
  2.  * Returns {@code WebSocketHttpHeaders} object that can only be read, not written to.
  3.  */
  4. public static WebSocketHttpHeaders readOnlyWebSocketHttpHeaders(WebSocketHttpHeaders headers) {
  5.   return new WebSocketHttpHeaders(headers, true);
  6. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Before
  2. public void setUp() {
  3.   headers = new WebSocketHttpHeaders();
  4. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Before
  2. public void setup() {
  3.   this.headers = new WebSocketHttpHeaders();
  4.   this.wsHandler = new AbstractWebSocketHandler() {
  5.   };
  6.   this.wsContainer = mock(WebSocketContainer.class);
  7.   this.wsClient = new StandardWebSocketClient(this.wsContainer);
  8. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Override
  2. public ListenableFuture<WebSocketSession> connect(TransportRequest request, WebSocketHandler handler) {
  3.   final SettableListenableFuture<WebSocketSession> future = new SettableListenableFuture<>();
  4.   WebSocketClientSockJsSession session = new WebSocketClientSockJsSession(request, handler, future);
  5.   handler = new ClientSockJsWebSocketHandler(session);
  6.   request.addTimeoutTask(session.getTimeoutTask());
  7.   URI url = request.getTransportUrl();
  8.   WebSocketHttpHeaders headers = new WebSocketHttpHeaders(request.getHandshakeHeaders());
  9.   if (logger.isDebugEnabled()) {
  10.     logger.debug("Starting WebSocket session on " + url);
  11.   }
  12.   this.webSocketClient.doHandshake(handler, headers, url).addCallback(
  13.       new ListenableFutureCallback<WebSocketSession>() {
  14.         @Override
  15.         public void onSuccess(@Nullable WebSocketSession webSocketSession) {
  16.           // WebSocket session ready, SockJS Session not yet
  17.         }
  18.         @Override
  19.         public void onFailure(Throwable ex) {
  20.           future.setException(ex);
  21.         }
  22.       });
  23.   return future;
  24. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void echoXhrWithHeaders() throws Exception {
  3.   AbstractXhrTransport xhrTransport = createXhrTransport();
  4.   xhrTransport.setXhrStreamingDisabled(true);
  5.   WebSocketHttpHeaders headers = new WebSocketHttpHeaders();
  6.   headers.add("auth", "123");
  7.   testEcho(10, xhrTransport, headers);
  8.   for (Map.Entry<String, HttpHeaders> entry : this.testFilter.requests.entrySet()) {
  9.     HttpHeaders httpHeaders = entry.getValue();
  10.     assertEquals("No auth header for: " + entry.getKey(), "123", httpHeaders.getFirst("auth"));
  11.   }
  12. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void doHandshake() throws Exception {
  3.   WebSocketHttpHeaders headers = new WebSocketHttpHeaders();
  4.   headers.setSecWebSocketProtocol(Arrays.asList("echo"));
  5.   this.wsSession = this.client.doHandshake(new TextWebSocketHandler(), headers, new URI(this.wsUrl)).get();
  6.   assertEquals(this.wsUrl, this.wsSession.getUri().toString());
  7.   assertEquals("echo", this.wsSession.getAcceptedProtocol());
  8. }

代码示例来源：origin: spring-projects/spring-framework

  1. WebSocketHandler wsHandler, Map<String, Object> attributes) throws HandshakeFailureException {
  2. WebSocketHttpHeaders headers = new WebSocketHttpHeaders(request.getHeaders());
  3. if (logger.isTraceEnabled()) {
  4.   logger.trace("Processing request " + request.getURI() + " with headers=" + headers);

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void doHandshakeWithTaskExecutor() throws Exception {
  3.   WebSocketHttpHeaders headers = new WebSocketHttpHeaders();
  4.   headers.setSecWebSocketProtocol(Arrays.asList("echo"));
  5.   this.client.setTaskExecutor(new SimpleAsyncTaskExecutor());
  6.   this.wsSession = this.client.doHandshake(new TextWebSocketHandler(), headers, new URI(this.wsUrl)).get();
  7.   assertEquals(this.wsUrl, this.wsSession.getUri().toString());
  8.   assertEquals("echo", this.wsSession.getAcceptedProtocol());
  9. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void openConnection() throws Exception {
  3.   List<String> subprotocols = Arrays.asList("abc");
  4.   TestLifecycleWebSocketClient client = new TestLifecycleWebSocketClient(false);
  5.   WebSocketHandler handler = new TextWebSocketHandler();
  6.   WebSocketConnectionManager manager = new WebSocketConnectionManager(client, handler , "/path/{id}", "123");
  7.   manager.setSubProtocols(subprotocols);
  8.   manager.openConnection();
  9.   WebSocketHttpHeaders expectedHeaders = new WebSocketHttpHeaders();
  10.   expectedHeaders.setSecWebSocketProtocol(subprotocols);
  11.   assertEquals(expectedHeaders, client.headers);
  12.   assertEquals(new URI("/path/123"), client.uri);
  13.   WebSocketHandlerDecorator loggingHandler = (WebSocketHandlerDecorator) client.webSocketHandler;
  14.   assertEquals(LoggingWebSocketHandlerDecorator.class, loggingHandler.getClass());
  15.   assertSame(handler, loggingHandler.getDelegate());
  16. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void subProtocolNegotiation() throws Exception {
  3.   WebSocketHttpHeaders headers = new WebSocketHttpHeaders();
  4.   headers.setSecWebSocketProtocol("foo");
  5.   URI url = new URI(getWsBaseUrl() + "/ws");
  6.   WebSocketSession session = this.webSocketClient.doHandshake(new TextWebSocketHandler(), headers, url).get();
  7.   assertEquals("foo", session.getAcceptedProtocol());
  8.   session.close();
  9. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void supportedExtensions() {
  3.   WebSocketExtension extension1 = new WebSocketExtension("ext1");
  4.   WebSocketExtension extension2 = new WebSocketExtension("ext2");
  5.   given(this.upgradeStrategy.getSupportedVersions()).willReturn(new String[] {"13"});
  6.   given(this.upgradeStrategy.getSupportedExtensions(this.request)).willReturn(Collections.singletonList(extension1));
  7.   this.servletRequest.setMethod("GET");
  8.   WebSocketHttpHeaders headers = new WebSocketHttpHeaders(this.request.getHeaders());
  9.   headers.setUpgrade("WebSocket");
  10.   headers.setConnection("Upgrade");
  11.   headers.setSecWebSocketVersion("13");
  12.   headers.setSecWebSocketKey("82/ZS2YHjEnUN97HLL8tbw==");
  13.   headers.setSecWebSocketExtensions(Arrays.asList(extension1, extension2));
  14.   WebSocketHandler handler = new TextWebSocketHandler();
  15.   Map<String, Object> attributes = Collections.<String, Object>emptyMap();
  16.   this.handshakeHandler.doHandshake(this.request, this.response, handler, attributes);
  17.   verify(this.upgradeStrategy).upgrade(this.request, this.response, null,
  18.       Collections.singletonList(extension1), null, handler, attributes);
  19. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void subProtocolCapableHandler() {
  3.   given(this.upgradeStrategy.getSupportedVersions()).willReturn(new String[] {"13"});
  4.   this.servletRequest.setMethod("GET");
  5.   WebSocketHttpHeaders headers = new WebSocketHttpHeaders(this.request.getHeaders());
  6.   headers.setUpgrade("WebSocket");
  7.   headers.setConnection("Upgrade");
  8.   headers.setSecWebSocketVersion("13");
  9.   headers.setSecWebSocketKey("82/ZS2YHjEnUN97HLL8tbw==");
  10.   headers.setSecWebSocketProtocol("v11.stomp");
  11.   WebSocketHandler handler = new SubProtocolCapableHandler("v12.stomp", "v11.stomp");
  12.   Map<String, Object> attributes = Collections.<String, Object>emptyMap();
  13.   this.handshakeHandler.doHandshake(this.request, this.response, handler, attributes);
  14.   verify(this.upgradeStrategy).upgrade(this.request, this.response, "v11.stomp",
  15.       Collections.emptyList(), null, handler, attributes);
  16. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void subProtocolCapableHandlerNoMatch() {
  3.   given(this.upgradeStrategy.getSupportedVersions()).willReturn(new String[] {"13"});
  4.   this.servletRequest.setMethod("GET");
  5.   WebSocketHttpHeaders headers = new WebSocketHttpHeaders(this.request.getHeaders());
  6.   headers.setUpgrade("WebSocket");
  7.   headers.setConnection("Upgrade");
  8.   headers.setSecWebSocketVersion("13");
  9.   headers.setSecWebSocketKey("82/ZS2YHjEnUN97HLL8tbw==");
  10.   headers.setSecWebSocketProtocol("v10.stomp");
  11.   WebSocketHandler handler = new SubProtocolCapableHandler("v12.stomp", "v11.stomp");
  12.   Map<String, Object> attributes = Collections.<String, Object>emptyMap();
  13.   this.handshakeHandler.doHandshake(this.request, this.response, handler, attributes);
  14.   verify(this.upgradeStrategy).upgrade(this.request, this.response, null,
  15.       Collections.emptyList(), null, handler, attributes);
  16. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void connectAndUseSubsetOfHandshakeHeadersForHttpRequests() throws Exception {
  3.   ArgumentCaptor<HttpHeaders> headersCaptor = setupInfoRequest(false);
  4.   this.xhrTransport.setStreamingDisabled(true);
  5.   WebSocketHttpHeaders headers = new WebSocketHttpHeaders();
  6.   headers.set("foo", "bar");
  7.   headers.set("auth", "123");
  8.   this.sockJsClient.setHttpHeaderNames("auth");
  9.   this.sockJsClient.doHandshake(handler, headers, new URI(URL)).addCallback(this.connectCallback);
  10.   assertEquals(1, headersCaptor.getValue().size());
  11.   assertEquals("123", headersCaptor.getValue().getFirst("auth"));
  12.   assertEquals(1, this.xhrTransport.getRequest().getHttpRequestHeaders().size());
  13.   assertEquals("123", this.xhrTransport.getRequest().getHttpRequestHeaders().getFirst("auth"));
  14. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void supportedSubProtocols() {
  3.   this.handshakeHandler.setSupportedProtocols("stomp", "mqtt");
  4.   given(this.upgradeStrategy.getSupportedVersions()).willReturn(new String[] {"13"});
  5.   this.servletRequest.setMethod("GET");
  6.   WebSocketHttpHeaders headers = new WebSocketHttpHeaders(this.request.getHeaders());
  7.   headers.setUpgrade("WebSocket");
  8.   headers.setConnection("Upgrade");
  9.   headers.setSecWebSocketVersion("13");
  10.   headers.setSecWebSocketKey("82/ZS2YHjEnUN97HLL8tbw==");
  11.   headers.setSecWebSocketProtocol("STOMP");
  12.   WebSocketHandler handler = new TextWebSocketHandler();
  13.   Map<String, Object> attributes = Collections.emptyMap();
  14.   this.handshakeHandler.doHandshake(this.request, this.response, handler, attributes);
  15.   verify(this.upgradeStrategy).upgrade(this.request, this.response, "STOMP",
  16.       Collections.emptyList(), null, handler, attributes);
  17. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void connectWithHandshakeHeaders() throws Exception {
  3.   ArgumentCaptor<HttpHeaders> headersCaptor = setupInfoRequest(false);
  4.   this.xhrTransport.setStreamingDisabled(true);
  5.   WebSocketHttpHeaders headers = new WebSocketHttpHeaders();
  6.   headers.set("foo", "bar");
  7.   headers.set("auth", "123");
  8.   this.sockJsClient.doHandshake(handler, headers, new URI(URL)).addCallback(this.connectCallback);
  9.   HttpHeaders httpHeaders = headersCaptor.getValue();
  10.   assertEquals(2, httpHeaders.size());
  11.   assertEquals("bar", httpHeaders.getFirst("foo"));
  12.   assertEquals("123", httpHeaders.getFirst("auth"));
  13.   httpHeaders = this.xhrTransport.getRequest().getHttpRequestHeaders();
  14.   assertEquals(2, httpHeaders.size());
  15.   assertEquals("bar", httpHeaders.getFirst("foo"));
  16.   assertEquals("123", httpHeaders.getFirst("auth"));
  17. }

代码示例来源：origin: org.springframework/spring-websocket

  1. /**
  2.  * Returns {@code WebSocketHttpHeaders} object that can only be read, not written to.
  3.  */
  4. public static WebSocketHttpHeaders readOnlyWebSocketHttpHeaders(WebSocketHttpHeaders headers) {
  5.   return new WebSocketHttpHeaders(headers, true);
  6. }

代码示例来源：origin: spring-projects/spring-integration

  1. @Bean
  2. public StompSessionManager stompSessionManager(WebSocketStompClient stompClient) {
  3.   WebSocketStompSessionManager webSocketStompSessionManager =
  4.       new WebSocketStompSessionManager(stompClient, server().getWsBaseUrl() + "/ws");
  5.   webSocketStompSessionManager.setAutoReceipt(true);
  6.   webSocketStompSessionManager.setRecoveryInterval(1000);
  7.   WebSocketHttpHeaders handshakeHeaders = new WebSocketHttpHeaders();
  8.   handshakeHeaders.setOrigin("http://foo.com");
  9.   webSocketStompSessionManager.setHandshakeHeaders(handshakeHeaders);
  10.   StompHeaders stompHeaders = new StompHeaders();
  11.   stompHeaders.setHeartbeat(new long[] { 10000, 10000 });
  12.   webSocketStompSessionManager.setConnectHeaders(stompHeaders);
  13.   return webSocketStompSessionManager;
  14. }

代码示例来源：origin: stackoverflow.com

  1. WebSocketHttpHeaders headers = new WebSocketHttpHeaders();
  2. String auth = "user" + ":" + "password";
  3. headers.add("Authorization", "Basic " + new String(Base64.getEncoder().encode(auth.getBytes())));
  4. stompClient.connect(url, headers, new MyStompSessionHandler());

代码示例来源：origin: stackoverflow.com

  1. WebSocketHttpHeaders handshakeHeaders = new WebSocketHttpHeaders();
  2. StompHeaders connectHeaders = new StompHeaders();
  3. connectHeaders.add("tokenGroup", "192:168:99:3::DEMO");
  4. stompClient.connect(stompUrlEndpoint.toString(), handshakeHeaders, connectHeaders, stompSessionHandlerImp, new Object[0]);

内容来源于网络，如有侵权，请联系作者删除！

WebSocketHttpHeaders

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com