cxf侦听器、侦听器和webservice（jaxws）之间的通信

Question

我们有web服务（jaxws），它正在调用另一个web服务（aslo jaxws）。Jaxws客户端配置如下所示--

 <jaxws:client id="helloClient"
              serviceClass="demo.spring.HelloWorld"
              address="http://localhost:9002/HelloWorld" >
      <jaxws:outInterceptors>
             <bean class="com.company.MyOutInterceptor"/>
      </jaxws:outInterceptors>
      <jaxws:inFaultInterceptors>
             <bean class="com.company.MyInFaultInterceptor"/>
      </jaxws:inFaultInterceptors>
      <cxf:properties>
             <entry key="org.apache.cxf.logging.FaultListener">
                 <bean class="com.company.MyFaultListener"/>
             </entry>
      </cxf:properties>
 </jaxws:client>

正如您所看到的，我们有两个拦截器和一个故障侦听器。我们希望在这些拦截器、故障侦听器和web服务代码之间进行通信。正如SO线程中所述，我们使用cxf交换对象在web服务和拦截器之间进行通信。

我们的inFaultInterceptor代码如下所示--

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

      public void handleMessage(Message message) {
          message.getExchange().put("key", "value");
      }

}

Web服务代码如下所示-

public String addNumbers(int a, int b){
     try{
          myService.add(a,b);
     }catch(MyServiceException e){
          //Logging
     }
     Object value = PhaseInterceptorChain.getCurrentMessage().getExchange().get("key");
}  

但是，在我们为给定的“key”获取null的Web服务代码中，表示“key”不存在。

我们有什么方法可以在拦截器和web服务之间进行通信吗？

P、 S：我们可以使用上述方法在拦截器和侦听器中进行通信。也就是说，我们可以在inFaultInterceptor中访问outInterceptor中的密钥集，但在web服务中无法访问任何侦听器或侦听器中设置的密钥。

Answer 1

不确定是否有任何Cxf内置机制，我使用ThreadLocal在webservice方法和拦截器之间传递信息，

public final class KPContextHolder {

    private static ThreadLocal<String> myKey = new ThreadLocal<>();

    private KPContextHolder() {

    }

    public static String getMyKey() {
        return myKey.get();
    }

    public static void setMyKey(final String input) {
        myKey.set(input);
    }

    /**
     * Clear all the fields saved in the thread context
     */
    public static void clear() {
        myKey.remove();

     }

}

拦截器类

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

          public void handleMessage(Message message) {
              KPContextHolder.setMyKey("value");
          }
}

和WebService方法。

public String addNumbers(int a, int b){
     try{
          myService.add(a,b);
     }catch(MyServiceException e){
          //Logging
     }
     String value = KPContextHolder.getMyKey();
} 

注：

1. 一旦使用，您应该显式清除线程上下文，否则将导致内存泄漏