13

<job/>または<exception/>常にステータスコードを返すサービスにRESTPOSTを作成する必要があります200。（サードパーティ製品のラメ！）。

私は次のようなコードを持っています：

Job job = getRestTemplate().postForObject(url, postData, Job.class);

そして、私のapplicationContext.xmlは次のようになります。

<bean id="restTemplate" class="org.springframework.web.client.RestTemplate">
    <constructor-arg ref="httpClientFactory"/>

    <property name="messageConverters">
        <list>
            <bean class="org.springframework.http.converter.xml.MarshallingHttpMessageConverter">
                <property name="marshaller" ref="jaxbMarshaller"/>
                <property name="unmarshaller" ref="jaxbMarshaller"/>
            </bean>
            <bean class="org.springframework.http.converter.FormHttpMessageConverter"/>
            <bean class="org.springframework.http.converter.StringHttpMessageConverter"/>
        </list>
    </property>
</bean>

<bean id="jaxbMarshaller" class="org.springframework.oxm.jaxb.Jaxb2Marshaller">
    <property name="classesToBeBound">
        <list>
            <value>domain.fullspec.Job</value>
            <value>domain.fullspec.Exception</value>
        </list>
    </property>
</bean>

この電話をかけようとしてサービスが失敗すると、次のようになります。

 Failed to convert value of type 'domain.fullspec.Exception' to required type 'domain.fullspec.Job'

postForObject（）呼び出しで、Job.classを要求していますが、取得していませんが、動揺しています。

私は次のようなことをする必要があると考えています。

Object o = getRestTemplate().postForObject(url, postData, Object.class);
if (o instanceof Job.class) {
   ...
else if (o instanceof Exception.class) {
}

しかし、これは機能しません。これは、JAXBがObject.classにマーシャリングする方法がわからないと文句を言うためです。当然のことながら。

MarshallingHttpMessageConverterのサブクラスを作成し、readFromSource（）をオーバーライドしようとしました

保護されたオブジェクトreadFromSource（クラスクラズ、HttpHeadersヘッダー、ソースソース）{

    Object o = null;
    try {
        o = super.readFromSource(clazz, headers, source);
    } catch (Exception e) {
        try {
            o = super.readFromSource(MyCustomException.class, headers, source);
        } catch (IOException e1) {
            log.info("Failed readFromSource "+e);
        }
    }

    return o;
}

残念ながら、これは機能しません。これは、ソース内の基になる入力ストリームが、再試行するまでに閉じられているためです。

ありがたいことに受け取った提案、

トム

更新：inputStreamのコピーを取得することでこれを機能させることができます

protected Object readFromSource(Class<?> clazz, HttpHeaders headers, Source source) {
    InputStream is = ((StreamSource) source).getInputStream();

    // Take a copy of the input stream so we can use it for initial JAXB conversion
    // and if that fails, we can try to convert to Exception
    CopyInputStream copyInputStream = new CopyInputStream(is);

    // input stream in source is empty now, so reset using copy
    ((StreamSource) source).setInputStream(copyInputStream.getCopy());

    Object o = null;
    try {
        o = super.readFromSource(clazz, headers, source);
      // we have failed to unmarshal to 'clazz' - assume it is <exception> and unmarshal to MyCustomException

    } catch (Exception e) {
        try {

            // reset input stream using copy
            ((StreamSource) source).setInputStream(copyInputStream.getCopy());
            o = super.readFromSource(MyCustomException.class, headers, source);

        } catch (IOException e1) {
            e1.printStackTrace();  
        }
        e.printStackTrace();
    }
    return o;

}

CopyInputStreamはhttp://www.velocityreviews.com/forums/t143479-how-to-make-a-copy-of-inputstream-object.htmlから取得されます。ここに貼り付けます。

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;

public class CopyInputStream
{
private InputStream _is;
private ByteArrayOutputStream _copy = new ByteArrayOutputStream();

/**
 * 
 */
public CopyInputStream(InputStream is)
{
    _is = is;

    try
    {
        copy();
    }
    catch(IOException ex)
    {
        // do nothing
    }
}

private int copy() throws IOException
{
    int read = 0;
    int chunk = 0;
    byte[] data = new byte[256];

    while(-1 != (chunk = _is.read(data)))
    {
        read += data.length;
        _copy.write(data, 0, chunk);
    }

    return read;
}

public InputStream getCopy()
{
    return (InputStream)new ByteArrayInputStream(_copy.toByteArray());
}
}
4

2 に答える 2

8

同じ問題を解決しようとしたときに、次の解決策を見つけました。

RestTemplateのデフォルトのインスタンスを使用しており、xjcを使用してファイルを生成しました。呼び出されるコンバーターはJaxb2RootElementHttpMessageConverterです。

入力クラスにXmlRootElementアノテーションが付けられている場合、コンバーターは「実際の」タイプを返すことがわかります。つまり、メソッド

protected Object readFromSource(Class clazz, HttpHeaders headers, Source source)

clazzにXmlRootElementアノテーションが存在する場合、clazzのインスタンスではないオブジェクトを返す可能性があります。この場合、clazzは、clazzをアンマーシャリングするアンマーシャラーを作成するためにのみ使用されます。

次のトリックで問題を解決します。

@XmlRootElement()
@XmlSeeAlso({ Exception.class, Job.class })
public static abstract class XmlResponse {}

XmlResponse.classをpostForObject（...）に渡すと、応答はExceptionまたはJobになります。

これは多少のハックですが、postForObjectメソッドが複数のオブジェクトクラスを返すことができないという問題を解決します。

于 2014-01-25T17:42:12.133 に答える
5

@トム：カスタムMarshallingHttpMessageConverterを作成しても何の役にも立たないと思います。組み込みのコンバーターは、サービスが失敗したときに正しいクラス（Exceptionクラス）RestTemplateを返しますが、応答タイプをJobクラスとして指定しているため、呼び出し先にExceptionクラスを返す方法がわかりません。

RestTemplateソースコードを読みましたが、現在このAPIを呼び出しています：-

public <T> T postForObject(URI url, Object request, Class<T> responseType) throws RestClientException {
    HttpEntityRequestCallback requestCallback = new HttpEntityRequestCallback(request, responseType);
    HttpMessageConverterExtractor<T> responseExtractor =
            new HttpMessageConverterExtractor<T>(responseType, getMessageConverters());
    return execute(url, HttpMethod.POST, requestCallback, responseExtractor);
}

ご覧のとおり、応答タイプに基づいてタイプTを返します。おそらく行う必要があるのは、タイプTではなくオブジェクトを返すRestTemplate新しいAPIをサブクラス化して追加し、返されたオブジェクトのチェックをpostForObject()実行できるようにすることです。instanceof

アップデート

ビルトインを使う代わりに、この問題の解決策を考えていましRestTemplateた。自分で書いてみませんか？RestTemplateこれは、新しいメソッドを追加するためにサブクラス化するよりも優れていると思います。

これが私の例です...確かに、私はこのコードをテストしませんでしたが、それはあなたにアイデアを与えるはずです：-

// reuse the same marshaller wired in RestTemplate
@Autowired
private Jaxb2Marshaller jaxb2Marshaller;

public Object genericPost(String url) {
    // using Commons HttpClient
    HttpClient client = new HttpClient();
    PostMethod method = new PostMethod(url);

    // add your data here
    method.addParameter("data", "your-data");

    try {
        int returnCode = client.executeMethod(method);

        // status code is 200
        if (returnCode == HttpStatus.SC_OK) {
            // using Commons IO to convert inputstream to string
            String xml = IOUtil.toString(method.getResponseBodyAsStream());
            return jaxb2Marshaller.unmarshal(new StreamSource(new ByteArrayInputStream(xml.getBytes("UTF-8"))));
        }
        else {
            // handle error
        }
    }
    catch (Exception e) {
        throw new RuntimeException(e);
    }
    finally {
        method.releaseConnection();
    }

    return null;
}

からのAPIの一部を再利用したい状況がある場合はRestTemplate、カスタム実装をラップするアダプターを構築し、コード全体RestTemplateにAPIを実際に公開せずにAPIを再利用できRestTemplateます。

たとえば、次のようなアダプタインターフェイスを作成できます。-

public interface MyRestTemplateAdapter {
    Object genericPost(String url);

    // same signature from RestTemplate that you want to reuse
    <T> T postForObject(String url, Object request, Class<T> responseType, Object... uriVariables);
}

具体的なカスタムRESTテンプレートは次のようになります。-

public class MyRestTemplateAdapterImpl implements MyRestTemplateAdapter {
    @Autowired
    private RestTemplate    restTemplate;

    @Autowired
    private Jaxb2Marshaller jaxb2Marshaller;

    public Object genericPost(String url) {
        // code from above
    }

    public <T> T postForObject(String url, Object request, Class<T> responseType, Object... uriVariables) {
        return restTemplate.postForObject(url, request, responseType);
    }
}

このアプローチはサブクラス化よりもはるかにクリーンでRestTemplateあり、Webサービス呼び出しからの結果をどのように処理するかをより細かく制御できると思います。

于 2011-03-02T19:15:37.643 に答える