import org.springframework.web.socket.sockjs.client.RestTemplateXhrTransport; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
  String token = authenticate();
  webSocketHttpHeaders = new WebSocketHttpHeaders();
  webSocketHttpHeaders.add("Authorization", "Bearer " + token);

  blockingQueue = new LinkedBlockingDeque<>();
  RestTemplateXhrTransport restTemplateXhrTransport = new RestTemplateXhrTransport();


  SockJsClient sockJsClient = new SockJsClient(Arrays.asList(restTemplateXhrTransport));
  sockJsClient.setHttpHeaderNames("Authorization");
  stompClient = new WebSocketStompClient(sockJsClient);
}
 

import org.springframework.web.socket.sockjs.client.RestTemplateXhrTransport; //导入依赖的package包/类
@BeforeClass
public static void setup() throws Exception {
	log.info("Setting up Quotes Web Socket Integration test....");
	port = SocketUtils.findAvailableTcpPort();

	server = new TomcatWebSocketTestServer(port);
	server.deployConfig(FrontendWebApplicationInitializer.class);
	server.start();

	loginAndSaveXAuthToken("harrymitchell", "HarryMitchell5!", headers);

	List<Transport> transports = new ArrayList<>();
	transports.add(new WebSocketTransport(new StandardWebSocketClient()));
	RestTemplateXhrTransport xhrTransport = new RestTemplateXhrTransport(new RestTemplate());
	xhrTransport.setRequestHeaders(headers);
	transports.add(xhrTransport);

	sockJsClient = new SockJsClient(transports);
       sockJsClient.setHttpHeaderNames("X-Auth-Token");
	log.info("Setup complete!");
}
 

import org.springframework.web.socket.sockjs.client.RestTemplateXhrTransport; //导入依赖的package包/类
@Test
public void run() throws Exception {
    List<Transport> transports = new ArrayList<Transport>(2);
    transports.add(new WebSocketTransport(new StandardWebSocketClient()));
    transports.add(new RestTemplateXhrTransport());

    SockJsClient sockJsClient = new SockJsClient(transports);
    ListenableFuture<WebSocketSession> wsSession = sockJsClient.doHandshake(
        this.webSocketHandler, "ws://localhost:" + this.port + "/sockjs");

    this.thrown.expect(ExecutionException.class);
    wsSession.get().sendMessage(new TextMessage("a"));
}
 

import org.springframework.web.socket.sockjs.client.RestTemplateXhrTransport; //导入依赖的package包/类
@Before
public void setup() {
	List<Transport> transports = Arrays.asList(
			new WebSocketTransport(new StandardWebSocketClient()),
			new RestTemplateXhrTransport(new RestTemplate()));
	this.sockJsClient = new SockJsClient(transports);
}
 

import org.springframework.web.socket.sockjs.client.RestTemplateXhrTransport; //导入依赖的package包/类
@BeforeClass
public static void setup() throws Exception {

 // Since test classpath includes both embedded Tomcat and Jetty we need to
 // set a Spring profile explicitly to bypass WebSocket engine detection.
 // See {@link org.springframework.samples.portfolio.config.WebSocketConfig}

 // This test is not supported with Jetty because it doesn't seem to support
 // deployment withspecific ServletContainerInitializer's at for testing

 System.setProperty("spring.profiles.active", "test.tomcat");

 port = SocketUtils.findAvailableTcpPort();

 server = new TomcatWebSocketTestServer(port);
 server.deployConfig(TestDispatcherServletInitializer.class, WebSecurityInitializer.class);
 server.start();

 loginAndSaveJsessionIdCookie("fabrice", "fab123", headers);

 List<Transport> transports = new ArrayList<>();
 transports.add(new WebSocketTransport(new StandardWebSocketClient()));
 RestTemplateXhrTransport xhrTransport = new RestTemplateXhrTransport(new RestTemplate());
 xhrTransport.setRequestHeaders(headers);
 transports.add(xhrTransport);

 sockJsClient = new SockJsClient(transports);
}
 

import org.springframework.web.socket.sockjs.client.RestTemplateXhrTransport; //导入依赖的package包/类
@Override
protected WebSocketClient createWebSocketClient() {
	List<Transport> transports = new ArrayList<>(2);
	transports.add(new WebSocketTransport(new StandardWebSocketClient()));
	transports.add(new RestTemplateXhrTransport());
	return new SockJsClient(transports);
}
 

import org.springframework.web.socket.sockjs.client.RestTemplateXhrTransport; //导入依赖的package包/类
@Test
public void run() throws Exception {
	List<Transport> transports = new ArrayList<>(2);
	transports.add(new WebSocketTransport(new StandardWebSocketClient()));
	transports.add(new RestTemplateXhrTransport());

	SockJsClient sockJsClient = new SockJsClient(transports);
	ListenableFuture<WebSocketSession> wsSession = sockJsClient.doHandshake(
			this.webSocketHandler, "ws://localhost:" + this.port + "/sockjs");

	this.thrown.expect(ExecutionException.class);
	wsSession.get().sendMessage(new TextMessage("a"));
}
 

import org.springframework.web.socket.sockjs.client.RestTemplateXhrTransport; //导入依赖的package包/类
public PersonWebSocketClient(RestTemplate restTemplate) {
    this(new SockJsClient(Arrays.asList(new WebSocketTransport(new SSLWebSocketClient()), new RestTemplateXhrTransport(restTemplate))), new MappingJackson2MessageConverter());
}
 

import org.springframework.web.socket.sockjs.client.RestTemplateXhrTransport; //导入依赖的package包/类
@BeforeClass
public static void setup() throws Exception {

    System.setProperty("spring.profiles.active", "test.tomcat");

    port = SocketUtils.findAvailableTcpPort();

    server = new TomcatWebSocketTestServer(port);
    server.deployConfig(TestDispatcherServletInitializer.class);
    server.start();

    webSocketUri = "ws://localhost:" + port + "/composite/websocket";

    List<Transport> transports = new ArrayList<>();
    transports.add(new WebSocketTransport(new StandardWebSocketClient()));
    RestTemplateXhrTransport xhrTransport = new RestTemplateXhrTransport(new RestTemplate());
    xhrTransport.setRequestHeaders(headers);
    transports.add(xhrTransport);

    sockJsClient = new SockJsClient(transports);

}