mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-05-27 04:02:38 +00:00
perf[net]: Message增加了其它默认的实例
This commit is contained in:
@@ -27,7 +27,7 @@ public class Message implements IPacket {
|
||||
public static final transient short PROTOCOL_ID = 100;
|
||||
|
||||
public static final Message SUCCESS = valueSuccess(null);
|
||||
public static final Message FAIL = valueSuccess(null);
|
||||
public static final Message FAIL = valueFail(null);
|
||||
|
||||
private byte module;
|
||||
|
||||
@@ -58,12 +58,6 @@ public class Message implements IPacket {
|
||||
return Message.valueOf(packet, code, null);
|
||||
}
|
||||
|
||||
public static Message valueOf(String message) {
|
||||
var mess = new Message();
|
||||
mess.message = message;
|
||||
return mess;
|
||||
}
|
||||
|
||||
public static Message valueFail(String message) {
|
||||
var mess = new Message();
|
||||
mess.code = 0;
|
||||
|
||||
@@ -17,6 +17,7 @@ import com.zfoo.protocol.IPacket;
|
||||
import java.util.concurrent.ConcurrentNavigableMap;
|
||||
import java.util.concurrent.ConcurrentSkipListMap;
|
||||
import java.util.concurrent.atomic.AtomicLong;
|
||||
import java.util.function.BiConsumer;
|
||||
|
||||
/**
|
||||
* @author jaysunxiao
|
||||
@@ -67,4 +68,9 @@ public class ConcurrentHeapMap<V extends IPacket> implements LpMap<V> {
|
||||
public long getIncrementIndex() {
|
||||
return maxIndexAtomic.incrementAndGet();
|
||||
}
|
||||
|
||||
@Override
|
||||
public void forEach(BiConsumer<Long, V> biConsumer) {
|
||||
map.forEach(biConsumer);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -198,6 +198,10 @@ public abstract class TimeUtils {
|
||||
return DATE_FORMAT_FOR_DAY.get().format(new Date(time));
|
||||
}
|
||||
|
||||
public static String dateFormatForDayTimeString(long time) {
|
||||
return DATE_FORMAT.get().format(new Date(time));
|
||||
}
|
||||
|
||||
/**
|
||||
* 判断两个日期是否是同一周,设置周一为一周的第一天
|
||||
* <p>
|
||||
|
||||
Reference in New Issue
Block a user