synchronized (HOLDER) {
private static final Map<String, ConnectionInfo> HOLDER = new Hashtable<>();
        // 删除该客户端的所有订阅
        Set<Map.Entry<String, ConnectionInfo>> entries = HOLDER.entrySet();
        entries.stream().filter(new Predicate<Map.Entry<String, ConnectionInfo>>() {
@Override
public boolean test(Map.Entry<String, ConnectionInfo> connectionInfoEntry) {
        return connectionInfoEntry.getValue().getSessions().contains(session);
        }
        }).forEach(new Consumer<Map.Entry<String, ConnectionInfo>>() {
@Override
public void accept(Map.Entry<String, ConnectionInfo> connectionInfoEntry) {
        connectionInfoEntry.getValue().unsubscribe(session);
        }
        });
        Iterator<Map.Entry<String, ConnectionInfo>> iterator = entries.iterator();
        while (iterator.hasNext()) {
        Map.Entry<String, ConnectionInfo> next = iterator.next();
        ConnectionInfo connectionInfo = next.getValue();
        // 若该实体未被订阅  则删除HOLDER中该实体的信息
        if (connectionInfo.unsubscribe(session)) {
        iterator.remove();
        }
        }
       
        }