From 11fdf101f0c88e9dd10d6e97814af62df64419d7 Mon Sep 17 00:00:00 2001
From: terry-xiaoyu <506895667@qq.com>
Date: Fri, 26 Jul 2019 15:13:58 +0800
Subject: [PATCH] Configurable rpc client number

---
 src/emqx_rpc.erl | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/emqx_rpc.erl b/src/emqx_rpc.erl
index 96adf6605..5d0370240 100644
--- a/src/emqx_rpc.erl
+++ b/src/emqx_rpc.erl
@@ -32,7 +32,8 @@ cast(Node, Mod, Fun, Args) ->
     filter_result(?RPC:cast(rpc_node(Node), Mod, Fun, Args)).
 
 rpc_node(Node) ->
-    {Node, erlang:system_info(scheduler_id)}.
+    {ok, ClientNum} = application:get_env(gen_rpc, tcp_client_num),
+    {Node, rand:uniform(ClientNum)}.
 
 rpc_nodes(Nodes) ->
     rpc_nodes(Nodes, []).