作業とデータorderly.Iは注文例をfollwedている消費されていません。 https://rocketmq.apache.org/docs/order-example/RocketMQ注文メッセージングは、私がRocketMQを使用して生成したいのです
しかし、消費者のリスナーに、メッセージが整然とした来ていません。 この注文メッセージがどのように機能しているかは誰にでも分かりますか?
作業とデータorderly.Iは注文例をfollwedている消費されていません。 https://rocketmq.apache.org/docs/order-example/RocketMQ注文メッセージングは、私がRocketMQを使用して生成したいのです
しかし、消費者のリスナーに、メッセージが整然とした来ていません。 この注文メッセージがどのように機能しているかは誰にでも分かりますか?
トピックを作成したときに「-o true」オプションを設定しましたか? たとえば、次のようになります。
sh mqadmin updateTopic -c Default_Cluster -n 192.168.1.2:9876 -t TopicTest -o true -r 8 -w 8
私の場合、トピックはcmd.Andではなく自動的に作成されていました実際には私の理解は間違っていました。つまり、メッセージはキューベースで整然としたものになります。つまり、トピックは注文メッセージングのために1つのキューしか使用しません。 – Santanu
コードを表示して、どこが間違っているかを教えてください。 RocketMQは同じキュー内でのみ順序を保証できるので、セレクタに実装する必要がある同じキューに順序付けされたメッセージを入れる必要があります – Jaskey