43.3. 处理逻辑处理程序中的消息

正常消息处理由 handleMessage （） 方法处理。

handleMessage （） 方法收到一个 LogicalMessageContext 对象，它提供对消息正文的访问以及消息上下文中存储的任何属性。

handleMessage （） 方法返回 true 或 false，具体取决于消息处理如何继续。它还可能会抛出异常。

传递给逻辑消息处理程序的 LogicalMessageContext 对象允许使用上下文的 getMessage （） 方法访问消息正文。getMessage （） 方法（如 例 43.2 “在逻辑处理程序中获取消息有效负载的方法” 所示）将消息有效负载返回为 LogicalMessage 对象。

具有 LogicalMessage 对象后，您可以使用它来操作消息正文。例 43.3 “逻辑消息冻结器” 中显示的 LogicalMessage 接口具有 getters 和 setters，用于处理实际消息正文。

逻辑消息的一对 getters 和 setters 使用消息有效负载作为 javax.xml.transform.dom.DOMSource 对象。

没有参数的 getPayload （） 方法将消息有效负载返回为 DOMSource 对象。返回的对象是实际消息有效负载。对返回对象所做的任何更改都会立即更改消息正文。

您可以使用采用单个 Source 对象的 setPayload （） 方法将消息的正文替换为 DOMSource 对象。

通过另一对 getters 和 setters，您可以将消息有效负载用作 JAXB 对象。它们使用 JAXBContext 对象将消息有效负载转换为 JAXB 对象。

要使用 JAXB 对象，请执行以下操作：

传递给逻辑处理程序的逻辑消息上下文是应用的消息上下文的实例，可以访问它中存储的所有属性。处理程序有权访问应用范围和 HANDLER 范围中的属性。

与应用的消息上下文一样，逻辑消息上下文是 Java Map 的子类。要访问存储在上下文中的属性，您可以使用从 Map 接口继承的 get （） 方法和 put （） 方法。

默认情况下，您在逻辑处理程序内部的消息上下文中设置的任何属性都会被分配 HANDLER 范围。如果您希望应用程序代码能够访问所需的属性，您需要使用上下文的 setScope （） 方法将属性明确设置为 APPLICATION。

有关在消息上下文中使用属性的详情，请参考 第 42.1 节 “了解上下文”。

知道消息通过处理程序链的方向通常非常重要。例如，您想要从传入请求检索安全令牌，并将安全令牌附加到传出响应。

消息的方向存储在消息上下文的出站消息属性中。您可以使用 MessageContext.MESSAGE_OUTBOUND_PROPERTY 密钥从消息上下文检索出站消息属性，如 例 43.6 “从 SOAP 消息上下文获取消息方向” 所示。

Boolean outbound;
outbound = (Boolean)smc.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);

属性作为 布尔值对象存储。您可以使用对象的 booleanValue （） 方法来确定属性值。如果属性设为 true，则会出站消息。如果属性设为 false，则消息为 inbound。

handleMessage （） 方法如何完成其消息处理对消息处理的方式有直接影响。它可以通过执行以下操作之一完成：

例 43.7 “逻辑消息处理程序消息处理” 显示一个由服务消费者使用的逻辑消息处理程序的 handleMessage （） 消息实现。它会在请求发送到服务提供商之前处理请求。

public class SmallNumberHandler implements LogicalHandler<LogicalMessageContext>
{
    public final boolean handleMessage(LogicalMessageContext messageContext)
    {
        try
        {
            boolean outbound = (Boolean)messageContext.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);

            if (outbound)
            {
                LogicalMessage msg = messageContext.getMessage();

                JAXBContext jaxbContext = JAXBContext.newInstance(ObjectFactory.class);
                Object payload = msg.getPayload(jaxbContext);
                if (payload instanceof JAXBElement)
                {
                    payload = ((JAXBElement)payload).getValue();
                }

                if (payload instanceof AddNumbers)
                {
                    AddNumbers req = (AddNumbers)payload;

                    int a = req.getArg0();
                    int b = req.getArg1();
                    int answer = a + b;

                    if (answer < 20)
                    {
                      AddNumbersResponse resp = new AddNumbersResponse();
                      resp.setReturn(answer);
                      msg.setPayload(new ObjectFactory().createAddNumbersResponse(resp),
                                                      jaxbContext);

                      return false;
                    }
                }
                else
                {
                   throw new WebServiceException("Bad Request");
                }
            }
            return true;
        }
        catch (JAXBException ex)
        {
            throw new ProtocolException(ex);
        }
    }
...
}

例 43.7 “逻辑消息处理程序消息处理” 中的代码执行以下操作：

检查消息是否为出站请求。

如果消息是出站请求，处理程序会执行额外的消息处理。

从消息上下文获取消息有效负载的 LogicalMessage 表示。

获取实际的消息有效负载作为 JAXB 对象。

检查以确保请求是正确的类型。

如果是，处理程序将继续处理消息。

检查 sum 的值。

如果它小于 20 阈值，则它构建响应并返回到客户端。

构建响应。

返回 false 以停止消息处理，并将响应返回给客户端。

如果消息不是正确的类型，则抛出运行时异常。

此例外返回给客户端。

如果消息是入站响应或 sum 没有达到阈值，则返回 true。

消息处理通常继续。

如果遇到 JAXB marshalling 错误，则抛出 ProtocolException。

异常通过当前处理程序和客户端之间的处理程序的 handleFault （） 方法处理后传递给客户端。