yuanbiao
/
jetlinks-official-protocol
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

优化msgid

This commit is contained in:
zhouhao 2022-08-10 09:22:11 +08:00
parent b0c94bed6b
commit cf21c84518
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/main/java/org/jetlinks/protocol/official/binary/BinaryMessageType.java
View File

@ -15,6 +15,7 @@ import org.jetlinks.core.message.property.*;
import java.time.Duration; import java.time.Duration;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.BiFunction; import java.util.function.BiFunction;
import java.util.function.Supplier; import java.util.function.Supplier;
@ -59,16 +60,22 @@ public enum BinaryMessageType {
private static class MsgIdHolder { private static class MsgIdHolder {
private int msgId = 0; private int msgId = 0;
private final BiMap<Integer, String> cached = HashBiMap.create(); private final Map<Integer, String> cached = CacheBuilder
.newBuilder()
.expireAfterWrite(Duration.ofSeconds(30))
.<Integer, String> build()
.asMap();
public synchronized int next(String id) { public synchronized int next(String id) {
if (id == null) { if (id == null) {
return -1; return -1;
} }
do {
if (msgId++ < 0) { if (msgId++ < 0) {
msgId = 0; msgId = 0;
} }
cached.put(msgId, id); } while (cached.putIfAbsent(msgId, id) != null);
return msgId; return msgId;
} }