問題タブ [broker]

私のプロジェクトは、 scryptを使用して資格情報チェッカーを実装しようとしています。独自の資格情報とチェッカー オブジェクトを実装しようとしましたが、pb でそれらを使用するのに多くの問題がありました。

Pb はネットワーク上で MD5 ハッシュを使用するようにハードコーディングされているようですが、これは私たちの実装では絶対に機能しません。scrypt を使用しているため、サーバー側で平文の正しいパスワードを取得する方法がありません。そのため、代わりに平文で検証されるパスワードを送信する方法が必要です。資格情報チェッカーで twisted.cred.credentials.UsernamePassword を使用してみましたが、サーバーに到達していないようです。(代わりに _PortalAuthChallenger を取得します)

http://twistedmatrix.com/trac/ticket/4398のチケットは、pb でカスタム資格情報チェッカーをサポートするために PBServerFactory サブクラスが必要であることを示しているようですが、これまでのところ、何をオーバーライドするかを完全に理解できていません。別の ICredentials 実装を使用するようにします。pb に別の資格情報クラスを使用させる方法の例 (または単なるドキュメント) はありますか?

ひねって遊んでみました。適切な Factory を使用してサーバーとクライアントを作成しようとしました。これは素晴らしいフレームワークですが、送信できるのは文字列のみです:(最初にリストまたは配列オブジェクトを送信し、後でクライアント内のサーバーからオブジェクトを使用したいと思います。しかし、現在、いくつかの簡単な質問に行き詰まっています:

1) Factory モデルでは、「clientConnectionFailed」や「clientConnectionLost」などのメソッドを使用しましたが、PB を使用して同じメソッドを取得するにはどうすればよいですか? クライアント/サーバーの問題を防ぐのに非常に役立ちました。

2) "dataReceived" や "connectionLost" または "connectionMade" などのメソッドも使用しましたが、PB を使用してこのメ​​ソッドの同じ機能を取得するにはどうすればよいですか?

ご覧のとおり、ファクトリの代わりに PB モデルを使用してコードを書き直すことから始めたいと思います。私は例を見てきましたが、工場のものとは異なり、私はそれらを理解することができません.

助けてくれてありがとう=）

JMXを介してトピックの作成/削除をテストするために、組み込みのactivemqインスタンスを作成しています。コードは次のようになります。ブローカー.connectorPortはJMXポートを設定するための私の試みでしたが、機能しません。

activemq.xmlを使用して構成する場合、次のxmlが機能します。これをbrokerURLに変換する方法がわかりません。

IBM WebSphere Message Broker (おそらく V6) を使用して、いくつかの CSV ファイルを使用し、いくつかの検証を実行してから、Java アプリケーションで使用するためにいくつかの Java オブジェクトを設定したいと考えています。これの多くは、FileInputNode を使用して csv ファイルを使用し、JavaCompute ノードを Java 関連のものに使用することで実現できると考えています。しかし、私が知りたいのは、どうすれば2つを接続できるのでしょうか? 私が考えている方法の 1 つは、csv ファイルを使用してから、Java ノードによって使用されるメッセージを作成することです。

アドバイスをいただければ幸いです。私は Message Broker についてあまり詳しくないので、無知であることをお許しください。ちなみに、WebSphere Message Broker を使用するという決定は私 (会社の標準) ではないため、これを達成する他の (より簡単な) 方法があるかもしれませんが、私は MQ Broker を使用することに固執しています。

アドバイスをいただければ幸いです。

前もって感謝します。

バズ

トピックと永続サブスクライバを備えた activemq を使用したハブアンドスポーク ネットワーク トポロジがあります。

(組み込み) ブローカーが切断された後、ローカルの保留中のメッセージを送信している間、切断期間中に送信されたメッセージを取得しません。

例: ブローカー A (組み込み) <---> 中央ブローカー (スタンドアロン) <---> ブローカー B (組み込み)

ブローカー A が 30 秒 (openwire の最大無活動タイムアウト) を超えて切断された後、切断中に送信されたメッセージを中央ブローカーから取得しません。ただし、ブローカー A は保留中のすべてのメッセージを送信するため、ブローカー B はそれらすべてを受信します。

セントラル ブローカには特定のネットワーク コネクタが定義されていません。これは、どのブローカが接続する必要があるかが事前にわからないためです。

いくつかの回復ポリシーを試しましたが、どれもうまくいかないようです。

何か助けはありますか？

次のシナリオを検討してください。

• VNC クライアントは、NAT の背後にある VNC サーバーに接続しようとします。

• 上記のタスクを達成するのに役立つJavaでポートフォワーダーを作成しましたが、正常に動作します。

• ここで、どういうわけか、このフォワーダー内にコネクション ブローカリング機能を追加して、VNC クライアントとサーバーの間の通信をインターセプトし、転送ユーティリティ内でも VNC クライアントを認証できるようにする必要があります。

実際には、VNC クライアントから受け取ったパスワードをアプリでの認証に使用していると推測したかもしれません。RFB サーバーはアプリケーション レイヤーで実装できるため、この傍受は可能であると思います。上記のすべての通信で VNCAuthentication (DES 暗号化/復号化) が使用されます。転送ユーティリティ内での認証が成功したら、そのクライアントの転送を続行します。それ以外の場合は、クライアントを閉じます (転送を停止します)。

私はいくつかの実装を試しましたが、rfb サーバーの Java 実装をカスタマイズしようとしましたが、まだそこに到達できません。時間がかかることはわかっていますが、私が正しく考えているかどうかを確認する必要があります.

上記のシナリオの実装があいまいであるか、不可能であるか、または違法であるかどうかを教えてください。これが可能である場合は、いくつかのギルドラインを用意してください...

AMQ 5.5 を使用しています。

5.3 から 5.5 にアップグレードして以来、完全に機能しています。しかし、今朝、ブローカはどこからともなく、一連の永続サブスクライバーを非アクティブとして報告し始めました。つまり、それらを「サブスクリプション」フォルダーの「偽」フォルダーに配置しました。また、「サブスクリプション」の下の「耐久性」および「非耐久性」フォルダーが見つかりませんでした。さらに調査した結果、false (非アクティブ) とマークされたサブスクライバーが、実際には resp にサブスクライブされていることがわかりました。話題になり、活躍しました。一部の発行者もメッセージを発行できませんでした。

activemq.log および kahadb.log ファイルを調べてみましたが、何も見つかりませんでした。結局、ブローカーを再起動して通常の状態に戻す必要がありました。

これまでにこのような状況に遭遇したことがありますか? これが起こった原因について何か考えはありますか？

前もって感謝します。ハリ

ビューとプロシージャで SqlCacheDependency を使用したいと考えています。

Linq to Sqlを使用しています。

現在使用しているコードは、単一テーブルを使用している場合にのみ有効です:

ここで、ビュー (複数のテーブル) に sqlcachedependency を実装したいと考えています。

このクエリを使用しようとしています

ただし、基になるテーブルを変更してもキャッシュが無効にならないため、このクエリは機能しません。

あまりにも長い間グーグル検索しましたが、ビューとプロシージャまたは複数のテーブルで機能するコードが見つかりません。

2 つのブローカーで構成される ActiveMQ ネットワークを作成しようとしています。関連ガイド (http://activemq.apache.org/networks-of-brokers.html) で説明されているように、構成を行いました。

上記の XML 構成では、ネットワーク ブローカーの 1 つが host1 で実行され、もう 1 つが host2 で実行されていると想定しています。host2 で実行されているブローカーは反対の値になります。JMS は開始に失敗し、ログ ファイルに例外は生成されません。表示される唯一のメッセージは次のとおりです。

2 つ以上の ActiveMQ ブローカーのネットワークを設定できた人はいますか?