58.2. 处理消息
概述
在普通消息处理中，会调用拦截器的 handleMessage （） 方法。它以 Message 对象的形式接收该消息数据。除消息的实际内容外，Message 对象可以包含与消息或消息处理状态相关的很多属性。Message 对象的确切内容取决于链中当前拦截器前面的拦截器。
获取消息内容
-
public
<T>>; TgetContentjava.lang.Class<T格式getContent （）方法在指定类的对象中返回消息内容。如果内容不能作为指定类的实例使用，则返回 null。可用内容类型的列表由拦截器链上的位置和拦截器链的方向决定。 public
Collection<Attachment>方法返回一个 JavagetAttachments（）Collection对象，该对象包含与消息关联的任何二进制附件。该附件存储在 org.apache.cxf.message.Attachment 对象中。附加对象提供管理二进制数据的方法。重要附件处理拦截器才会执行后可用。
确定消息的方向
消息方向可以通过查询消息交换来确定。消息交换将入站消息和出站消息存储在单独的属性中。[3]
与消息关联的消息交换使用消息的 getExchange （） 方法来检索。如 例 58.1 “获取消息交换” 所示，getExchange （） 不使用任何参数，并将消息交换返回为 org.apache.cxf.message.Exchange 对象。
例 58.1. 获取消息交换
ExchangegetExchange
Exchange 对象有四种方法，显示在 例 58.2 “从消息交换获取消息” 中，用于获取与交换关联的信息。每种方法都将消息返回为 org.apache.cxf.Message 对象，如果消息不存在，它将返回 null。
例 58.2. 从消息交换获取消息
MessagegetInMessageMessagegetInFaultMessagegetOutMessagegetOutFaultMessage
例 58.3 “检查消息链的方向” 显示用于确定当前消息是否出站代码。该方法获取消息交换，并检查当前消息是否与交换的出站消息相同。它还会根据交换出站错误消息检查当前的消息，以针对出站故障拦截器链上的错误消息。
例 58.3. 检查消息链的方向
public static boolean isOutbound()
{
Exchange exchange = message.getExchange();
return message != null
&& exchange != null
&& (message == exchange.getOutMessage()
|| message == exchange.getOutFaultMessage());
}示例
例 58.4 “消息处理方法示例” 显示处理 zip 压缩消息的拦截器代码。它将检查消息的方向，然后执行适当的操作。
例 58.4. 消息处理方法示例
import java.io.IOException;
import java.io.InputStream;
import java.util.zip.GZIPInputStream;
import org.apache.cxf.message.Message;
import org.apache.cxf.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
public class StreamInterceptor extends AbstractPhaseInterceptor<Message>
{
...
public void handleMessage(Message message)
{
boolean isOutbound = false;
isOutbound = message == message.getExchange().getOutMessage()
|| message == message.getExchange().getOutFaultMessage();
if (!isOutbound)
{
try
{
InputStream is = message.getContent(InputStream.class);
GZIPInputStream zipInput = new GZIPInputStream(is);
message.setContent(InputStream.class, zipInput);
}
catch (IOException ioe)
{
ioe.printStackTrace();
}
}
else
{
// zip the outbound message
}
}
...
}