diff --git a/broker/src/main/java/win/liyufan/im/MessageShardingUtil.java b/broker/src/main/java/win/liyufan/im/MessageShardingUtil.java
index 974521fe..65b97b82 100644
--- a/broker/src/main/java/win/liyufan/im/MessageShardingUtil.java
+++ b/broker/src/main/java/win/liyufan/im/MessageShardingUtil.java
@@ -13,7 +13,7 @@ import java.util.Date;
 
 public class MessageShardingUtil {
     private static SpinLock mLock = new SpinLock();
-    private static int rotateId = 0;
+    private static volatile int rotateId = 0;
     private static int nodeId = 0;
 
     private static int rotateIdWidth = 15;