Могу ли я иметь XML в журнале при отправке запроса FastInfoset с Apache CXF?

Question

Мне нужно иметь запросы и ответы в журналах приложения, но запросы, отправленные Apache CXF, находятся в FastInfoset (Content-Type: application/fastinfoset), что приводит к тому, что журнал запроса и ответа становится нечитаемым (так как это двоичный файл)). Есть ли способ обойти это так, чтобы я держал сообщения FastInfoset (по соображениям производительности), но я получаю правильный XML в журналах?

Вот конфигурация CXF, которую я имею прямо сейчас, если это поможет:

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:cxf="http://cxf.apache.org/core"
    xsi:schemaLocation="
http://cxf.apache.org/core http://cxf.apache.org/schemas/core.xsd
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd">

    <bean id="logInbound" class="org.apache.cxf.interceptor.LoggingInInterceptor" />
    <bean id="logOutbound" class="org.apache.cxf.interceptor.LoggingOutInterceptor" />

    <cxf:bus>
        <cxf:inInterceptors>
            <ref bean="logInbound" />
        </cxf:inInterceptors>
        <cxf:outInterceptors>
            <ref bean="logOutbound" />
        </cxf:outInterceptors>
        <cxf:outFaultInterceptors>
            <ref bean="logOutbound" />
        </cxf:outFaultInterceptors>
        <cxf:inFaultInterceptors>
            <ref bean="logInbound" />
        </cxf:inFaultInterceptors>
    </cxf:bus>
</beans>

Спасибо заранее за любую помощь.

Answer 1

Я взглянул на LoggingInInterceptor.logInputStream, и кажется, что он не поддерживает fastinfoset. Но вы можете использовать собственный перехватчик вместо LoggingInInterceptor а также LoggingOutInterceptor чтобы извлечь полезную нагрузку, расшифровать ее и записать исходное сообщение.

public class CustomInterceptor extends AbstractPhaseInterceptor<Message> {
    public CustomInterceptor () {
        super(Phase.RECEIVE);
    }

    public void handleMessage(Message message) {
        //Get the message body into payload[] and set a new non-consumed  inputStream into Message
        InputStream in = message.getContent(InputStream.class);
        byte payload[] = IOUtils.readBytesFromStream(in);
        ByteArrayInputStream bin = new ByteArrayInputStream(payload);
        message.setContent(InputStream.class, bin);

        //Decode from FastInfoset and write the payload in your preferred log system
        OutputStream out = System.out 
        decodeFI(in,out);

    }

    public void handleFault(Message messageParam) {
        //Invoked when interceptor fails
        //Exception e = message.getContent(Exception.class);
    }
}

Заменить в файле XML

<bean id="logInbound" class="test.CustomInterceptor" />
<bean id="logOutbound" class="test.CustomInterceptor" />

---

Найти пример того, как декодировать FastInfoset, было непросто. Попробуйте это с помощью DOM и FastInfoset-1.2.12.jar. В этом репо у вас есть несколько примеров использования sTAX и SAX

public void decodeFI(InputStream in, OutputStream out) throws Exception{
    DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
    DocumentBuilder docBuilder = docFactory.newDocumentBuilder();
    Document doc = docBuilder.newDocument();

    DOMDocumentParser parser = new DOMDocumentParser();
    parser.parse(doc, in);

    // write the content into xml file
    TransformerFactory transformerFactory = TransformerFactory.newInstance();
    Transformer transformer = transformerFactory.newTransformer();
    DOMSource source = new DOMSource(doc);
    StreamResult result = new StreamResult(out);
    transformer.transform(source, result);
}