問題タブ [consumer]

現在、古い Report Generator を置き換える方法を研究しています。

私が勤務している会社はマイクロソフトのパートナーであるため、Report Builder 3.0 の使用を望んでいます。

問題は、データベースに直接接続するのではなく、独自のビジネス オブジェクトに接続することです。適用されたフィルター、並べ替え、編集などが原因です。

レポート ビルダーを使用してビジネス オブジェクトに接続できるように、独自の OLE DB アダプターを作成することは可能だと思います。MSDN で「OLE DB の紹介」を読んだところ、

「データ ストアからコンシューマーにデータを提供するプロバイダーのデータ ソース オブジェクトと、データを含むがデータ ソース オブジェクトを介してのみコンシューマーと対話するデータ ストア自体とを区別することが重要です。たとえば、データstore は、コンマ区切り値 (CSV) テキスト ファイル、SQL DBMS、またはアプリケーション内のメモリ内配列である可能性があります。"

これは、方法を理解する必要があるアプリケーションに接続できることを意味すると思います。誰でもこれを確認し、サンプルを提供できますか? (C# が望ましいですが、C++ でも同様です)

2 番目の質問

OLE DB はプロバイダーとコンシューマーの外に存在します。レポートビルダーを使用したいので、レポートビルダーがプロバイダーへの接続を作成するのを見て、独自のコンシューマーを作成する必要はないと思います。間違っている場合は修正してください。

これは私のチャンネル構成です:

次のシナリオがあります。2 人のユーザーが、同じブラウザーを使用して同じマシンからアプリケーションにログインしますが、インスタンスは異なります。ユーザーの 1 人がログアウトし、最終的にチャネルが切断された場合、2 番目のユーザーは、障害ハンドラーでこのメッセージ「The client has no active subscriptions over endpoint 'my-polling-amf'」メッセージを受け取り、切断して再接続します。ただし、ユーザー 1 が firefox を使用し、ユーザー 2 が IE を使用しているなど、両方のユーザーが異なる種類のブラウザーを使用している場合は正常に動作し、奇妙なことは何も表示されません。

例外は次のとおりです。

シーンの説明： 私のプログラムはflex + java + blazeDS + activeMQによって実装され、flex ConsumerによってactiveMQからのjmsメッセージをサブスクライブします。現在、同じサーバーで2つのTomcatを配信しています。これらはすべて私のプログラムを含み、ActiveMQは別のサーバーにあります。サーバー、今度はIEやChromeなどの同じ種類のブラウザで2つのアプリケーションを開きます。URLはhttp： // localhost：8080 /HelloWord/index.html、http：// localhost：8181 /のようになります。 HelloWord / index.html

問題： 最初のアプリケーションのURLはhttp：// localhost：8080 /HelloWord/index.htmlです。つまり、メッセージをサブスクライブできますが、URLがhttp：//である2番目の2番目のアプリケーションを開くとlocalhost：8181 /HelloWord/index.htmlつまり、事故が発生し、2つのアプリケーションがメッセージをサブスクライブできません。

エラーログ： 1.flexクライアントログ（flash.log）： 通常、リモートホストがセッションCookieを無効にしているため、重複するHTTPベースのFlexSessionが検出されました。クライアント接続を正しく管理するには、セッションCookieを有効にする必要があります 。2.javaコンソールログ： flex.messaging.client.FlexClientNotSubscribedException：クライアントにはエンドポイント「my-polling-amf」に対するアクティブなサブスクリプションがありません。 flex.messaging.client.FlexClient.throwNotSubscribedException（FlexClient.java:1789）at flex.messaging.client.FlexClient.pollWithWait（FlexClient.java:967）at flex.messaging.endpoints.BasePollingHTTPEndpoint.handleFlexClientPoll（BasePollingHTTPEndpoint.java:538 ）at flex.messaging.endpoints.AbstractEndpoint.handleFlexClientPollCommand（AbstractEndpoint.java：1151）at flex.messaging.endpoints.AbstractEndpoint.serviceMessage（AbstractEndpoint.java:965）at flex.messaging.endpoints.AbstractEndpoint $$ FastClassByCGLIB $$1a3ef066 org.springframework.aop.framework.Cglib2AopProxy $ CglibMethodInvocation.invokeJoinpoint（Cglib2AopProxy.java:692）のnet.sf.cglib.proxy.MethodProxy.invoke（MethodProxy.java:191）のinvoke（） framework.ReflectiveMethodInvocation。proceed（ReflectiveMethodInvocation.java:150）at org.springframework.flex.core.MessageInterceptionAdvice.invoke（MessageInterceptionAdvice.java:66）at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed（ReflectiveMethodInvocation.java:172）at org.springframework .aop.framework.adapter.ThrowsAdviceInterceptor.invoke（ThrowsAdviceInterceptor.java:124）at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed（ReflectiveMethodInvocation.java:172）at org.springframework.aop.framework.Cglib2AopProxy （Cglib2AopProxy.java:576）at flex.messaging.endpoints.AMFEndpoint $$ EnhancerByCGLIB $$ 3ae4b8ad.serviceMessage（）at flex.messaging.endpoints.amf.MessageBrokerFilter.invoke（MessageBrokerFilter.java:103）at flex.messaging.endpoints 。amf.LegacyFilter.invoke（LegacyFilter.java:158）at flex.messaging.endpoints.amf.SessionFilter.invoke（SessionFilter.java:44）at flex.messaging.endpoints.amf.BatchProcessFilter.invoke（BatchProcessFilter.java:67） flex.messaging.endpoints.amf.SerializationFilter.invoke（SerializationFilter.java:166）at flex.messaging.endpoints.BaseHTTPEndpoint.service（BaseHTTPEndpoint.java:291）at flex.messaging.endpoints.AMFEndpoint $$ EnhancerByCGLIB $$ 3ae4b8ad .service（）at org.springframework.flex.servlet.MessageBrokerHandlerAdapter.handle（MessageBrokerHandlerAdapter.java:108）at org.springframework.web.servlet.DispatcherServlet.doDispatch（DispatcherServlet.java:771）at org.springframework.web.servlet org.springframework.web.servletの.DispatcherServlet.doService（DispatcherServlet.java:716）。FrameworkServlet.processRequest（FrameworkServlet.java:647）at org.springframework.web.servlet.FrameworkServlet.doPost（FrameworkServlet.java:563）at javax.servlet.http.HttpServlet.service（HttpServlet.java:641）at javax.servlet .http.HttpServlet.service（HttpServlet.java:722）at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter（ApplicationFilterChain.java:304）at org.apache.catalina.core.ApplicationFilterChain.doFilter（ApplicationFilterChain.java:210） ）org.apache.catalina.core.StandardWrapperValve.invoke（StandardWrapperValve.java:240）at org.apache.catalina.core.StandardContextValve.invoke（StandardContextValve.java:164）atorg.apache.catalina.authenticator.AuthenticatorBase。 org.apache.catalina.core.StandardHostValveでinvoke（AuthenticatorBase.java:462）。invoke（StandardHostValve.java:164）at org.apache.catalina.valves.ErrorReportValve.invoke（ErrorReportValve.java:100）at org.apache.catalina.valves.AccessLogValve.invoke（AccessLogValve.java:563）at org.apache .catalina.core.StandardEngineValve.invoke（StandardEngineValve.java:118）at org.apache.catalina.connector.CoyoteAdapter.service（CoyoteAdapter.java:403）at org.apache.coyote.http11.Http11AprProcessor.process（Http11AprProcessor.java ：286）org.apache.coyote.http11.Http11AprProtocol $ Http11ConnectionHandler.process（Http11AprProtocol.java:272）at org.apache.tomcat.util.net.AprEndpoint $ SocketProcessor.run（AprEndpoint.java:1730）atjava。 util.concurrent.ThreadPoolExecutor $ Worker.runTask（ThreadPoolExecutor.java:886）at java.util.concurrent.ThreadPoolExecutor$Worker。run（ThreadPoolExecutor.java:908）

私が行ったテスト： 1.FlexClient.getInstance（）。id = UIDUtil.createUID（）; 無効な2.FlexClient.getInstance（）。id = null; 無効3.異なる種類のブラウザを使用します。1つはIeを使用し、もう1つはChromeを使用して、2つのアプリケーションを開きます。4. 1台のサーバー1台のTomcat、同じ種類のブラウザを使用します。つまり、それらを開くために、それらは大丈夫です。5. flex MXMLでカスタマーAMFChannelを使用するか、flex-config.xmlでデフォルトのAMFChannel定義を使用します。無効です。

ネットワークの友達の進歩： 1.http：//blogs.adobe.com/lin/2011/05/duplication-session-error.html 2.http：//stackoverflow.com/questions/7659775/duplicate-session-error-when -perform-proxy-lookup2つは無効です。

以前にこの状況に遭遇した人はいますか？アドバイスをいただければ幸いです。

私のアプリケーションでは、実行するアクションの数が設定されています。アクションを実行するスレッドの特定の量を指定したいと思います。一部のアクションは他のアクションよりも時間がかかり、応答を待つ可能性があるため、スレッドが終了したら、キューに戻って次のアクションを開始します。したがって、10個のスレッドの1つが解放されると、新しいアクションが取得され、キューが空になるまで続きます。続行する前に、すべてのアクションが完了するのを待つ必要があります。

そこで、「ああ、このアプリケーションでは.Net 2.0に制限されている」ということを思い出す前に、うまく機能していたTPLを使用して調査とテストを行いました。.Net 2.0のみを使用して再構築しようとしましたが、うまくいきません。私はスレッディングの経験がほとんどありません。

このロジックを.Net2.0に変換するのを手伝ってくれる人はいますか？

いくつかのWebAPIを作成しましたが、エラーが発生すると、APIはCreateErrorResponseメッセージで作成されたHttpResponseMessageを返します。このようなもの：

私の問題は、コンシューマーアプリケーションでメッセージ（この場合は「顧客が見つかりませんでした。 」）を取得する方法がわからないことです。

消費者のサンプルは次のとおりです。

どんな助けでも大歓迎です。

akka camel コンシューマーの autoAck はブール値の true または false を返します。

autoAck = true の場合、メッセージがコンシューマーのメールボックスに入るとき、コンシューマーがメッセージを処理する前に、コンシューマーはどのように行動しますか?

MyConsumer1 はキャメル コンシューマーの一般的な形式です。

質問: receive() 内の msg は、呼び出し前または receive() 後に最初にキューから取り出されますか? エンドポイント プロトコルと autoAck は、デキュー動作にどのように影響しますか?

通常のAkkaアクターは、メールボックスとディスパサー（スレッドプール）に関連付けられており、構成またはプログラムで設定できます。パスを介して通常の俳優を検索できます。通常のアクターは、最初にメールボックスからメッセージをデキューし、次にメッセージを処理します。

キャメルの消費者俳優にも同じことができますか？通常の俳優とラクダの消費者俳優の違いは何ですか？

簡単に並列化できる単純なタスクがあります。基本的に、同じ操作を（大きな数Gbの）入力ファイルの各行で繰り返し実行する必要があります。これのマルチスレッドバージョンを作成しているときに、I/Oがボトルネックであることに気付きました。私は、循環バッファにできるだけ速く進んで直接読み取る単一の「ファイルリーダー」スレッドを含むユーティリティクラスを構築することにしました。次に、複数のコンシューマーがこのクラスを呼び出して、「次の行」を取得できます。n個のスレッドが与えられた場合、各スレッドiの開始行はファイル内の行iであり、そのスレッドの後続の各行はnを追加することによって検出されます。これにはロックは必要ないことがわかりました。不変条件を保持するには、いくつかの主要なアトミック操作で十分です。

私はコードをテストしました、そしてそれはより速いようです、しかし考え直して、私は理由がわかりません。大きなファイルをn個の入力ファイルに分割し（同じファイルを「シーク」して同じことを実現し、前処理を最小限に抑えることができます）、各プロセスでiostream::readLineを呼び出すのも同じくらい速いのではないでしょうか。独自のチャンク？（iostreamは独自のバッファーにも読み込むため）。ワーカーは実際には同じデータ行を操作していないため、複数のスレッド間で単一のバッファーを共有することには固有の利点はないようです。さらに、同じ行で機能するように並列化することを考えない良い方法はありません。私は自分が見ているパフォーマンスの向上を理解し、それが「フルーキー」なのか、プラットフォーム間でスケーラブル/再現可能なのかを知りたいだけです...

ラクダのドキュメントでは、CamelContext がそのコンシューマのスレッドを管理すると述べています。Akka は Camel 拡張機能を介して Camel を統合しました。Akka には独自のスレッド プール (ディスパッチャー) があることがわかっています。問題は、誰が Akka Camel のコンシューマ/アクター スレッドを管理しているのかということです。CamelContext がスレッドを管理する場合、cfg ファイルまたはコードでスレッド プールを構成するにはどうすればよいですか?