| 单的模拟器写出来了，一个跳过所有业务逻辑直接调用cxf客户端实现代码的测试小程序写出来了，测试之后发现，问题依旧。于是将目光集中到cxf的客户端上。
在测试中发现这样一个规律，在上述服务器端的异常发生前，在客户端中总是会有规律的出现下面这个异常：
Jul 24, 2009 10:36:18 PM org.apache.cxf.phase.PhaseInterceptorChain doIntercept
INFO: Interceptor has thrown exception, unwinding now null
tps = 25
Exception in thread "Thread-41" 2009-07-24 22:36:19,925 149585 [Thread-41] (********Impl.java:459) ERROR junit.framework.Test - Got an exception when invoking **** service:javax.xml.ws.WebServiceException: java.lang.NullPointerException
(这里的信息是和业务相关的，不方便打出，总之和我们讨论的问题无关)
at test.TestMci.execute(TestMci.java:84)
at test.TestMci.access$1(TestMci.java:81)
at test.TestMci$TestThread.run(TestMci.java:90)
at java.lang.Thread.run(Thread.java:595)
Caused by: javax.xml.ws.WebServiceException: java.lang.NullPointerException
at org.apache.cxf.jaxws.JaxWsClientProxy.invoke(JaxWsClientProxy.java:142)
at $Proxy40.authorizeAndPurchase(Unknown Source)
at *********************
6 more
Caused by: java.lang.NullPointerException
at org.apache.cxf.transport.http.HTTPConduit.prepare(HTTPConduit.java:483)
at org.apache.cxf.interceptor.MessageSenderInterceptor.handleMessage(MessageSenderInterceptor.java:46)
at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:226)
at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:469)
at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:299)
at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:251)
at org.apache.cxf.frontend.ClientProxy.invokeSync(ClientProxy.java:73)
at org.apache.cxf.jaxws.JaxWsClientProxy.invoke(JaxWsClientProxy.java:124)
8 more
看来问题是出现在这里了。
CXF client在并发下的线程安全问题(2)
时间:2011-01-27 BlogJava sky ao
进一步的测试发现，低压力下比如2-3个工作线程，基本不会有任何问题，因此可以解释为什么功能测试时不出现问题。工作线程加到10个，基本上还算问题，只有极其偶然的会出现一次两次这个异常。进一步加大工作线程，由于受到测试机器的性能限制，10个工作线程和100个工作线程的tps基本相同，都大体在 300TPS左右(客户端在笔记本上跑的，cpu已经90%+了)。测试的结果是上面的异常开始变的有规律，恩，非常搞笑的规律，大概每10000次左右的请求就发生一次上述异常，非常的稳定而执着的重现。服了,这么有规律而重现性极好的错误，还真是难得一见........
分析一下问题，在tps基本保持不变的情况下，客户端线程从10增加到100问题就变得明显。因此问题的焦点直指线程安全这个老大难问题，重新审视我们使用cxf的代码，发现有个地方
/**
* the server service
*/
MessagingChannelServiceImplService mcsis = null;
/**
* the sever service port
*/
MessagingChannelService mcs = null;
|
