問題タブ [wso2mb]

2 つのブローカー、WKA メンバーシップ スキーム、PostgreSQL メッセージ ストアのクラスターをテストし、数日間正常に動作し、次のエラーをスローします。

Message Broker の起動は問題ないようです。エラーはありません。PostgreSQL DB への JDBC 接続は問題ありません。レジストリのマウントも問題ありません。その後、そのエラーが wso2carbon.log に数回/分表示されます。誰でもアイデアはありますか？私の知る限り、何も変わっておらず、何に接続しようとしているのかわかりません。

WSO2 MB 管理コンソールで、トピックの読み取りおよび書き込みアクセスを特定のユーザーとロールに制限しようとしていますが、WSO2 MB がこのプロトコルをサポートするように指定されているにもかかわらず、JMS のみに影響し、MQTT メッセージングには影響しないようです。

サブスクライブとパブリッシングを単一のロールに制限したいので、ユーザーはトピックをパブリッシュまたはサブスクライブできますが、両方はできません。

解決策はありますか？

オリバー

同じインスタンスで、機能として MB を備えた WSO2 ESB 5.0 を使用しています。

StorableMessage cannot be foundというエラーが表示されます:

エラー - JmsConsumer [msg-store-C-1] はストアからメッセージを受信できません。エラー: メッセージをデシリアライズできませんでした: java.lang.ClassNotFoundException: org.apache.synapse.message.store.impl.commons. andes_3.1.1でStorableMessageが見つからない

スタック トレースなしで、1 行だけです。

おそらくlibに.jarがないか、バージョンが間違っていますが、どちらが正しいかわかりません。

誰かが何が欠けている/間違っているか知っていますか?

または、何を確認すればよいですか？

ありがとう

編集:

WSO2 Message Broker を別のインスタンスとして使用すると、問題なく動作します。

同じインスタンスまたは個別のインスタンスに関係なく、MessageStore と MessageProcessor を使用しています。

サーバーがあり、このサーバーから Web サービスを呼び出すことができます。だから私はWebサービスを呼び出し、Webサービスは私に答えを送り、それに応じて答えを実行したいアプリケーションを実行します。例えば：

だから私は wso2 Enterprise Service Bus(ESB) でこのシナリオを実装したいと考えています。wso2 Message Broker(MB) を使用する必要があると思います。アドバイスありがとう。

このページのサンプル コードを試して、WSO2 メッセージ ブローカーへのメッセージの発行をテストしています。

https://docs.wso2.com/display/MB310/Sending+and+Recoming+Messages+Using+Queues

サンプル コードは、接続 -> 公開 -> 切断するように見えます。

これは、製品コードの典型的な設計ではないと思います。メッセージを発行するたびに呼び出されるコードを削減しようとしましたが (1 秒間に数回)、接続が切断され、再確立されていないようです。

javax.jms.IllegalStateException: オブジェクト org.wso2.andes.client.AMQSession_0_8@79aa1855 が閉じられました

メッセージを公開するたびに再接続する必要がありますか?

WSO2ESB クラスター (ESB1 および ESB2 ワーカー) があり、共有データベース MSSQL (MB1 および MB2 ブローカー) を使用して WSO2MB クラスターを構成しています。ESB サーバーは、WSO2MB クラスター内のブローカーからメッセージを読み書きします。私が達成したいのは、ESB1 がブローカー MB1 にメッセージを読み書きし、ESB2 がブローカー MB2 にメッセージを読み書きすることです。たとえば MB2 で障害が発生した場合、両方の ESB サーバーがメッセージを MB1 に読み書きします。ドキュメントでは、ラウンド ロビン バージョンの障害戦略のみが表示されます。これは、ESB サーバーがランダムに MB ブローカーに接続することを意味します。シングルブローカー戦略がありますが、それは私の状況に適用できますか、それとも独自の FailoverMethod インターフェイスを実装する必要がありますか? 優先度または重みに基づくフェイルオーバー戦略が必要ですが、それは ActiveMQ でしかわかりません。返信ありがとうございます。

同じ VM で本番セットアップ (WSO2 MB 3.1.0 および WSO2 ESB 4.9.0) を作成しようとしました。実稼働環境を保護するために、管理者ユーザーのデフォルトの管理者 psw をより安全なものに変更しました。同時に、ESB jndi.properties で「技術ユーザー」として使用する新しい MB ユーザー (ESB) を作成しました。

サーバーを再起動すると、MB に接続しようとした ESB で次の例外を受け取り始めました: [2016-10-07 16:47:31,427] ERROR - AMQStateManager Notifying Waiters([org.wso2.andes.client.state .StateWaiter@654a6148]) エラーの場合: 許可されていません [2016-10-07 16:47:31,427] 情報 - AMQConnection tcp://localhost:5673 org.wso2.andes.client.AMQAuthenticationException でブローカーに接続できません: not許可 [エラー コード 530: 許可されていません] org.wso2.andes.client.handler.ConnectionCloseMethodHandler.methodReceived(ConnectionCloseMethodHandler.java:79) で org.wso2.andes.client.handler.ClientMethodDispatcherImpl.dispatchConnectionClose(ClientMethodDispatcherImpl.java:192) ) org.wso2.andes.client.state.AMQStateManager の org.wso2.andes.framing.amqp_0_91.ConnectionCloseBodyImpl.execute(ConnectionCloseBodyImpl.java:140) で。methodReceived(AMQStateManager.java:111) at org.wso2.andes.client.protocol.AMQProtocolHandler.methodBodyReceived(AMQProtocolHandler.java:517)

問題をさかのぼって ADMIN psw の変更にたどり着きました。デフォルトの ADMIN:ADMIN に戻すと、すべて正常に動作するようになりました。

理由はありますか？どうやら、この記事に従ったすべての場所で psw が変更されていないようですhttps://docs.wso2.com/display/MB220/Changing+User+Passwords
私の構成 xml には管理者 psw が含まれていません。

事前にどうもありがとうございました。

wso2mb (wso2 メッセージ ブローカー バージョン 3.1.0) に基づいて、php クライアント ( php-amqplib libを使用) をサーバーに接続しようとしています。

amqp_consumer.php を使用し、常にこのエラーでロックされている場合、私は成功できませんでした:

情報 {org.wso2.andes.server.protocol.AMQProtocolEngine} - 処理中に SASL サーバーを作成できません: AMQPLAIN:[ConnectionStartOkBodyImpl: clientProperties={product=[LONG_STRING: AMQPLib]、プラットフォーム=[LONG_STRING: PHP]、バージョン=[ LONG_STRING: 2.6]、information=[LONG_STRING:]、copyright=[LONG_STRING:]、capabilities=[FIELD_TABLE: {authentication_failure_close=[BOOLEAN: true]、publisher_confirms=[BOOLEAN: true]、consumer_cancel_notify=[BOOLEAN: true]、exchange_exchange_bindings =[BOOLEAN: true]、basic.nack=[BOOLEAN: true]、connection.blocked=[BOOLEAN: true]}]}、メカニズム=AMQPLAIN、response=[5, 76, 79, 71, 73, 78, 83 、0、0、0、5、97、100、109、105、110、8、80、65、83、83、87、79、82、68、83、0、0、0、5、97、100 、109、105、110]、locale=en_US] [2016-11-04 08:05:26,901] INFO {org.wso2.andes.server.protocol.AMQProtocolEngine} - 次の理由により接続を閉じています: org.wso2.andes.AMQConnectionException: SASL サーバーを作成できません: AMQPLAIN [エラー コード 506: リソース エラー]

confing.php で thos params を conexions params として使用しています

私の質問: 1. いくつかの php コードと wso2mb の間の通信を確立するために、任意の php ライブラリ/チュートリアルをお勧めできますか? 2. wso2mb で許可されている接続方法は何ですか? (プレーン、AMQプレーン...?) 3. 助けてください:)