anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

消息id分表错误问题

Browse Source
This commit is contained in:
heavyrain lee
2019-05-06 08:18:01 +08:00
parent a2eadf5a78
commit 64c7da70e7
1 changed files with 13 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/win/liyufan/im/MessageShardingUtil.java
+13 -8
View File
@@ -8,6 +8,7 @@
package win.liyufan.im;
import java.util.Calendar;
import java.util.Date;
public class MessageShardingUtil {
@@ -55,8 +56,10 @@ public class MessageShardingUtil {
mid >>= (nodeIdWidth + rotateIdWidth);
Date date = new Date(mid + T201801010000);
int month = date.getMonth();
int year = date.getYear();
Calendar calendar = Calendar.getInstance();
calendar.setTime(date);
int month = calendar.get(Calendar.MONTH);
int year = calendar.get(Calendar.YEAR);
year %= 3;
return "t_messages_" + (year * 12 + month);
}
@@ -68,13 +71,15 @@ public class MessageShardingUtil {
mid >>= (nodeIdWidth + rotateIdWidth);
Date date = new Date(mid + T201801010000);
int month = date.getMonth();
int year = date.getYear();
Calendar calendar = Calendar.getInstance();
calendar.setTime(date);
int month = calendar.get(Calendar.MONTH);
int year = calendar.get(Calendar.YEAR);
year %= 3;
month = month + 1;
if (month == 12) {
month = 0;
year = (year + 3 -1)%3;
month = month - 1;
if (month == -1) {
month = 11;
year = (year + 3 - 1)%3;
}
return "t_messages_" + (year * 12 + month);
}