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

普通消息处理由 handleMessage （） 方法处理。

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

根据消息处理方式，handleMessage （） 方法返回 true 或 false。它还可能会抛出异常。

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

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

其中一个对 getters 和 setter of the logical message of the message payload 一起用于 javax.xml.transform.dom.DOMSource 对象。

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

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

其他对 getters 和 setters 允许您将消息有效负载用作 JAXB 对象。它们使用 JAXBContext 对象将消息有效负载转换为 JAXB 对象。

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

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

与应用的消息上下文一样，逻辑消息上下文是 Java map 的子类。若要访问上下文中存储的属性，您可以使用 get （） 方法和从 Map 接口继承的 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，则消息为入站。

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 以停止消息处理，并将响应返回给客户端。

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

这个例外返回给客户端。

如果消息是入站响应，则返回 true，或者 sum 不满足阈值。

消息处理通常会继续。

如果遇到 JAXB marshalling 错误，则引发 ProtocolException。

异常在由当前处理程序和客户端之间的处理程序的 handleFault （） 方法处理后返回给客户端。