8
与えられた
  • 私の Java アプリは、JBoss (4.0.4GA) にデプロイされた WAR です。
  • ActiveMQ (5.6.0) インスタンスをパブリッシュおよびサブスクライブします
  • Java アプリは、ActiveMQ とのすべての統合 (生成と消費) に Apache Camel (2.10.3) を使用します。
  • 独自の (CentOS 5.6 Final) クアッドコア仮想サーバー上の JBoss および ActiveMQ。各仮想は異なる物理サーバー上にあります。

スレッド ハングの問題があり、スレッド ダンプに次のように表示されます。

java.net.SocketInputStream.socketRead0(Native Method)
java.net.SocketInputStream.read(SocketInputStream.java:129)
java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
java.io.BufferedInputStream.read1(BufferedInputStream.java:258)
java.io.BufferedInputStream.read(BufferedInputStream.java:317)
sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:687)
sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:632)
sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1195)
java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:379)
org.springframework.remoting.httpinvoker.SimpleHttpInvokerRequestExecutor.validateResponse(SimpleHttpInvokerRequestExecutor.java:146)
org.springframework.remoting.httpinvoker.SimpleHttpInvokerRequestExecutor.doExecuteRequest(SimpleHttpInvokerRequestExecutor.java:66)
org.springframework.remoting.httpinvoker.AbstractHttpInvokerRequestExecutor.executeRequest(AbstractHttpInvokerRequestExecutor.java:136)
org.springframework.remoting.httpinvoker.HttpInvokerClientInterceptor.executeRequest(HttpInvokerClientInterceptor.java:192)
org.springframework.remoting.httpinvoker.HttpInvokerClientInterceptor.executeRequest(HttpInvokerClientInterceptor.java:174)
org.springframework.remoting.httpinvoker.HttpInvokerClientInterceptor.invoke(HttpInvokerClientInterceptor.java:142)
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:202)
$Proxy117.SigmaCruxer(Unknown Source)
com.tms.SigmaClient.SigmaClient.processMessage(SigmaClient.java:46)
com.tms.SigmaClient.SigmaServiceEndpoint.doSigma(SigmaServiceEndpoint.java:29)
com.tms.SigmaClient.SigmaServiceEndpoint.mark(SigmaServiceEndpoint.java:43)
sun.reflect.GeneratedMethodAccessor193.invoke(Unknown Source)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
java.lang.reflect.Method.invoke(Method.java:597)
org.apache.camel.component.bean.MethodInfo.invoke(MethodInfo.java:329)
org.apache.camel.component.bean.MethodInfo$1.proceed(MethodInfo.java:231)
org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:169)
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:104)
org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:74)
org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:102)
org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:72)
org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:50)
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)
org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:114)
org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:284)
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:109)
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:69)
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:99)
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:318)
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)
org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:305)
org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:69)
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:104)
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:85)
org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:91)
org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:560)
org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:498)
org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:467)
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
java.lang.Thread.run(Thread.java:662)

これらの 2 つの記事 (こことここ) によると、私の JBoss アプリにはブロッキング I/O 操作がSocket.read()あり、ダウンストリーム サービス プロバイダー (私の場合は ActiveMQ) からの応答が完了するのを待っています。繰り返しになりますが、これらの記事によると、犯人は次の 3 つの項目のいずれかです。

  • ActiveMQ が異常または不安定な状態にあり、応答が遅すぎるため、リッスン/待機/ブロック スレッドがハングします。また
  • ActiveMQ インスタンス自体は問題ありませんが、完了するまでに時間がかかりすぎる操作 (KahaDB への書き込みなど) を処理しているため、スレッドが再びハングします。また
  • JBoss アプリ (WAR) と ActiveMQ インスタンスの間にネットワークの問題があります。

3つのうちどれに該当するかを調べてみました。そのスレッド ダンプに、それがどれであるかを示すものはありますか? 私の理解(これらの記事を読んだ後) は、実際のハングは、クライアント側 (ブロッキング) ソケットが、応答が完了したと見なすために必要なすべてのバイトを受信して​​いないという事実です。つまり、ActiveMQ からの応答をまったく受け取っていないか、完全な応答を受け取っていません。

だから私は尋ねます：

  1. 3 つのシナリオのどれが該当するかを明確に示すものはありますか? もしそうなら、何/なぜですか? そうでない場合、私の次のステップは何ですか(私は ActiveMQ をセットアップした「管理者」でもあるため、JBoss とデプロイされた WAR だけでなく、ActiveMQ にも完全にアクセスできます)。
  2. 新しい JBoss にアップグレードすると、これは修正されますか? おそらく、4.0.4GA は「古い」(ブロッキング) Java I/O を使用していますが、新しいバージョンでは NIO を使用している可能性があります。おそらくロングショットですが、まだ信用を落とすことはできません.
  3. 両方の記事は、適切なソケット タイムアウト構成を実装する必要があることを強調しています。これにより、これらすべてが十分に緩和される可能性があります (ただし、基になる ActiveMQ の無応答やネットワークの問題には対処していません)。
    1. これは Java コードに記述するタイムアウトですか? もしそうなら、どのように、どの API を使用して? JMS? ActiveMQ クライアント側の jar はありますか?
    2. これは、OS レベルで実装するタイムアウトですか? だとしたら、どうすればいいのかわからない…
    3. これは、サーバー側 (ActiveMQ) で実装するタイムアウトですか? もしそうなら、どのように？

ここで解決策に近づいていると思いますが、ちょっと立ち往生していて、木を通して森を見るのに苦労しています. 前もって感謝します！

4

1 に答える 1

3

私はJBoss（およびGlassfish）とActiveMQの経験がありますが、これまでCamelを使用したことはありません（ただし、私が読んだMuleについてはよく知っています）。

スタックトレースは、CamelがActiveMQ（トレースの下部にあるJMSのもの）をWebエンドポイント（トレースの上部にあるHTTPのもの）にリンクしようとしているように見えます。

Camelが実行されている場所（CamelContext）について少し混乱しています。2つの仮想マシンがあります。1つはJBoss用で、もう1つはActiveMQ用です。私の場合、ActiveMQを使用するマシンでMuleESBを実行します。あなたのラクダはどこで走っていますか？

スタックトレースは、最初の投稿の問題＃1のように見えます。これは、ラクダの部分がWebエンドポイントを「見る」ことができないかのようです。WARが正しくデプロイされていること、およびWebエンドポイント（WSDL）が両方の仮想マシンから表示されていることを確認してください。エンドポイントを確認してください。おそらく、ローカルホストなどに設定されているため、別のマシンにアクセスできません。

読み取りが不完全なのか、完全に読み取れないのかを判断するのは少し難しいです。データは通過しますか？Webサーバーがゆっくりと過負荷になり、要求に対応できない可能性があります（エラーのように一部のスレッドが不足します）。応答が遅い場合や要求が多い場合は、ソケットのタイムアウトが重要になります。単純な（高速でリクエストが少ない）テストを作成できる場合は、少なくとも基本的な接続があることを確認できます。このエラーの原因となったデータ入力（テスト）は何ですか？

より多くのインプットがあれば、この答えを改善しようと喜んでお手伝いします。（申し訳ありませんが、あなたの質問にコメントしようとしましたが、まだその担当者がいないと思います...）

于 2013-03-12T10:54:53.180 に答える