import org.apache.cxf.transport.local.LocalConduit; //导入依赖的package包/类
/**
 * This is a utility method that contains some mocks that are required for cxf local testing.
 * It adds the <code>HTTP.REQUEST</code> to the request context.
 * @param client the cxf client from the test
 */
protected void addCXFClientMocks(WebClient client) {
	Map<String, Object> requestContext = WebClient.getConfig(client).getRequestContext();
	requestContext.put(LocalConduit.DIRECT_DISPATCH, Boolean.TRUE);

	// cxf workaround for using a HttpServletRequest in a local:// call
	HashSet<String> include = new HashSet<>();
	include.add(AbstractHTTPDestination.HTTP_REQUEST);
	requestContext.put(LocalTransportFactory.MESSAGE_INCLUDE_PROPERTIES, include);

	HttpServletRequest mockRequest = mock(HttpServletRequest.class);
	when(mockRequest.getRemoteAddr()).thenReturn("127.0.0.1");
	when(mockRequest.getRequestURL()).thenReturn(new StringBuffer());
	when(mockRequest.getPathInfo()).thenReturn("");
	when(mockRequest.getContextPath()).thenReturn("");
	when(mockRequest.getServletPath()).thenReturn("");
	requestContext.put(AbstractHTTPDestination.HTTP_REQUEST, mockRequest);
}
 

import org.apache.cxf.transport.local.LocalConduit; //导入依赖的package包/类
public void executeCxfCrudMethods() {
    WebClient client = WebClient.create(ENDPOINT_ADDRESS);
    WebClient.getConfig(client).getRequestContext().put(LocalConduit.DIRECT_DISPATCH, Boolean.TRUE);

    client.accept("text/plain");
    client.path("/crud");
    String result = client.get(String.class);
    assertEquals("", result);

    result = client.post("my-value", String.class);
    assertEquals("my-value", result);

    result = client.get(String.class);
    assertEquals("my-value", result);

    client.put("my-value-updated");

    result = client.get(String.class);
    assertEquals("my-value-updated", result);

    client.delete();
    result = client.get(String.class);
    assertNull(result);
}
 

import org.apache.cxf.transport.local.LocalConduit; //导入依赖的package包/类
public WebClient getClient(boolean json){
	List<Object> providers = new ArrayList<Object>();
	providers.add(new JacksonJsonProvider());
	WebClient client = WebClient.create(ENDPOINT_ADDRESS, providers);
	if ( json ) client.type("application/json");
	client.accept("application/json");
	WebClient.getConfig(client).getRequestContext().put(LocalConduit.DIRECT_DISPATCH, Boolean.TRUE);
	return client;
}
 

import org.apache.cxf.transport.local.LocalConduit; //导入依赖的package包/类
@Before
	public void setUp() throws Exception {

		MockitoAnnotations.initMocks( this );
		/*
		userService = Mockito.mock( UserService.class );
		userRestRS = Mockito.spy( new UserRestImpl() );
		ReflectionTestUtils.setField( userRestRS, "userService", userService );
		*/

		final List<Object> providers = new ArrayList<Object>();
		JacksonJaxbJsonProvider jacksonJsonProvider = new JacksonJaxbJsonProvider();
		providers.add( jacksonJsonProvider );

		// custom deserializers for our abstract types ( User and Collection )
		this.objectMapper = jacksonJsonProvider.locateMapper(null, MediaType.APPLICATION_JSON_TYPE);
//		SimpleModule module = new SimpleModule(
//				"Kur8orApiDeserializer",
//				new Version(1, 0, 0, null, "", "")
//		);
//		module.addDeserializer( com.projectx.sdk.user.User.class, userAbstractDeserializer );
//		module.addDeserializer( Collection.class, collectionAbstractDeserializer );
//
//		objectMapper.registerModule( module );

		webClient = WebClient.create( "http://localhost:8080/api", providers );
		WebClient.getConfig( webClient ).getRequestContext().put( LocalConduit.DIRECT_DISPATCH, Boolean.TRUE );
		webClient.accept( "application/json" );

	}
 

import org.apache.cxf.transport.local.LocalConduit; //导入依赖的package包/类
public void executeCxfGetMethod() {
    WebClient client = WebClient.create(ENDPOINT_ADDRESS);
    WebClient.getConfig(client).getRequestContext().put(LocalConduit.DIRECT_DISPATCH, Boolean.TRUE);

    client.accept("text/plain");
    client.path("/test");
    String result = client.get(String.class);

    assertEquals("test-response", result);
}
 

import org.apache.cxf.transport.local.LocalConduit; //导入依赖的package包/类
protected WebClient prepareClient(String username, String password) {

		List providers = new ArrayList<>();
		providers.add(getProvider());
		WebClient client = WebClient.create(ENDPOINT_ADDRESS, providers);// ,
																			// provider);

		ClientConfiguration clientConfig = WebClient.getConfig(client);

		clientConfig.getRequestContext().put(LocalConduit.DIRECT_DISPATCH, Boolean.TRUE);

		client.accept(getAcceptHeader());
		client.type(getContentType());

		createAuthorizationHeader(client, username, password);
		return client;

	}