2

CXF (バージョン 3.1.3) クライアントを使用して PATCH メソッドで API を呼び出そうとしていました。

以下のスレッドで指定されている手順に従ってみましたが、解決できませんでした。AsyncHttpConduit の代わりに URLConnectionHttpConduit のみを取得する

http://cxf.apache.org/docs/asynchronous-client-http-transport.html

CXF での PATCH メソッドの使用方法

CXF HttpAsyncClient の use.async.http.conduit コンテキスト プロパティの使用を確認する

コード スニペットは次のとおりです。

    Bus bus = BusFactory.getDefaultBus();
    // insist on the async connector to use PATCH.
    bus.setProperty(AsyncHTTPConduit.USE_ASYNC,  
AsyncHTTPConduitFactory.UseAsyncPolicy.ALWAYS);
    WebClient webClient = WebClient.create(request.getRestURL());
   WebClient.getConfig(webClient).getBus().setProperty
     (AsyncHTTPConduit.USE_ASYNC, AsyncHTTPConduitFactory.UseAsyncPolicy.ALWAYS);
   WebClient.getConfig(webClient).getRequestContext()
       .put(AsyncHTTPConduit.USE_ASYNC, AsyncHTTPConduitFactory.
       UseAsyncPolicy.ALWAYS);
    HTTPConduit conduit = (HTTPConduit)WebClient.getConfig(webClient)
                           .getConduit();
    System.out.println(conduit.getClass().getName());

    Response response = webClient.invoke(request.getMethod(), null);
    System.out.println("service response = "+ response);

X-HTTP-Method-Override=PATCH ヘッダーを POST リクエストで使用してみましたが、

他のサイド サービスは RestEasy を使用して実装されており、X-HTTP-Method-Override ヘッダーを尊重していないように見えます。

問題を見つけるのを手伝ってくれませんか。

4

1 に答える 1

2

同様の問題が発生したとき、使用CloseableHttpAsyncClientしましたが、正常に動作します。以下は参考用のサンプルコードです。

IOReactorConfig ioReactorConfig = IOReactorConfig.custom().setIoThreadCount(10).build();
ConnectingIOReactor ioReactor = new DefaultConnectingIOReactor(ioReactorConfig);
PoolingNHttpClientConnectionManager cm = new PoolingNHttpClientConnectionManager(ioReactor);
cm.setMaxTotal(100);
cm.setDefaultMaxPerRoute(10);

RequestConfig requestConfig = RequestConfig.custom()
                .setConnectTimeout(30000)
                .setSocketTimeout(30000).build();

CloseableHttpAsyncClient httpclient = HttpAsyncClients.custom()
                .setConnectionManager(cm)
                .setConnectionManagerShared(false)
                .setDefaultRequestConfig(requestConfig)
                .build();
httpclient.start();

HttpPatch httpReq = new HttpPatch(url);
StringEntity entity = new StringEntity(json);
httpReq.setEntity(entity);

Future<HttpResponse> future = httpclient.execute(httpReq, context, null);
HttpResponse httpResponse = future.get();
HttpEntity responseEntity = httpResponse.getEntity();
String responseText = responseEntity != null ? EntityUtils.toString(responseEntity) : null;

詳細については、リンクを参照してください。

于 2015-12-25T19:14:39.513 に答える