commit 30b19640759ccf79168a60a2c42d68fe1b610a2b
author weilin <zhaoxuyao.zxy@alibaba-inc.com> Tue Jun 17 13:01:47 2025 +0800
committer weilin <zhaoxuyao.zxy@alibaba-inc.com> Tue Jun 17 13:01:47 2025 +0800
tree f076e51c0c3185dd973428ad69734c27128ca11d
parent 3505ecf8d88d471adcb0715a68fa4a8617ed86bd

feat: add random shuffle for name server addresses

src/transport/TcpRemotingClient.cpp

diff --git a/src/transport/TcpRemotingClient.cpp b/src/transport/TcpRemotingClient.cpp
index a077406..fa60e3c 100644
--- a/src/transport/TcpRemotingClient.cpp
+++ b/src/transport/TcpRemotingClient.cpp
@@ -24,6 +24,8 @@
 #include "MemoryOutputStream.h"
 #include "TopAddressing.h"
 #include "UtilAll.h"
+#include <algorithm>
+#include <random>
 
 namespace rocketmq {
 
@@ -150,6 +152,11 @@
 
   vector<string> out;
   UtilAll::Split(out, addrs, ";");
+
+  std::random_device rd;
+  std::mt19937 g(rd());
+  std::shuffle(out.begin(), out.end(), g);
+  
   for (auto addr : out) {
     UtilAll::Trim(addr);