:メッセージ消費に関するFAQ

次の設定が有効かどうかを確認します。

• エンドポイントが正しく指定されているかどうかを確認します。 エンドポイントは、ApsaraMQ for RocketMQコンソールの インスタンスの詳細 ページで取得できます。

• telnet Endpoint from the domain name and port numberコマンドを実行して、ネットワーク接続を確認します。

  • アプリケーションがオンプレミスマシンにデプロイされている場合、または複数のリージョンでApsaraMQ for RocketMQにアクセスするが、Cloud Enterprise network (CEN) を使用してネットワークを構築できない場合は、パブリックエンドポイントを使用してApsaraMQ for RocketMQインスタンスにアクセスする必要があります。 パブリックエンドポイントを使用してApsaraMQ for RocketMQインスタンスにアクセスする場合、アウトバウンドインターネットトラフィックに対して課金されます。 詳細については、「ApsaraMQ For RocketMQ 4.xインスタンスのインターネットアクセス料金」または「ApsaraMQ for RocketMQ 5.xインスタンスのインターネットアクセス料金」をご参照ください。

  • アプリケーションがAlibaba Cloud Elastic Compute Service (ECS) インスタンスにデプロイされている場合、仮想プライベートクラウド (VPC) エンドポイントを使用して、VPC内のApsaraMQ for RocketMQインスタンスにアクセスできます。 この場合、ECSインスタンスがApsaraMQ for RocketMQインスタンスと同じリージョンにあることを確認する必要があります。

• ApsaraMQ for RocketMQ 5.0インスタンスのインターネットアクセス機能を有効にした場合、IPアドレスホワイトリストが設定されているかどうかを確認します。 インターネットアクセス機能を有効にすると、デフォルトで任意のIPアドレスからApsaraMQ for RocketMQにアクセスできます。 IPアドレスホワイトリストを指定した場合、ホワイトリストのIPアドレスからのみApsaraMQ for RocketMQにアクセスできます。

• トピック名が正しく指定されているか確認してください。 トピックがApsaraMQ for RocketMQコンソールで作成され、トピック名に余分なスペースや特殊文字が含まれていないことを確認してください。

• ユーザー名とパスワードが正しく指定されているかどうかを確認します。

  • ApsaraMQ for RocketMQ 5.0インスタンス: インスタンスのユーザー名とパスワードを指定する必要があります。 ApsaraMQ for RocketMQコンソールの [インスタンスの詳細] ページで、インスタンスのユーザー名とパスワードを取得できます。

  • ApsaraMQ for RocketMQ 4.0インスタンス: Alibaba CloudアカウントまたはResource Access Management (RAM) ユーザーのAccessKey IDとAccessKeyシークレットを指定する必要があります。 RAMユーザーを使用する場合は、RAMユーザーに必要な権限が付与されていることを確認してください。 AccessKeyペアの取得方法については、「AccessKeyペアの作成」をご参照ください。

次の原因でメッセージが蓄積されることがあります。

• メッセージ消費ロジックで例外が発生しました。

• メッセージを生成するアプリケーションでトラフィックのスパイクが発生しました。 この場合、メッセージ生成の速度は、メッセージ消費の速度をはるかに超え、メッセージの蓄積を引き起こす。

• コンシューマが依存するダウンストリームサービスの処理期間が延長され、消費スレッドがブロックされます。

• 不十分な消費スレッドは、低レベルの消費同時性を引き起こす。 その結果、メッセージ消費はメッセージ生成よりも遅れる。

いいえ。 メッセージをサブスクライブするときにタグを指定するために使用するパラメーターを空のままにすると、コンシューマーはメッセージを使用できません。 トピック内のすべてのメッセージをサブスクライブする場合は、パラメーターを * に設定する必要があります。 サンプルコード：

String topic = "Your Topic";
// Use tags to filter messages and subscribe to all messages. 
FilterExpression filterExpression = new FilterExpression("*", FilterExpressionType.TAG);
pushConsumer.subscribe(topic, filterExpression);