馬老師SpringCloud Alibaba 實(shí)戰(zhàn)與源碼深入剖析
?.aggregate(() -> new ArrayList<>(), (k, v, agg) -> {
? ? ? ? ?System.out.println("========== aggregate record ==========");
? ? ? ? ?log.info("k: {}, v: {}, agg: {}", k, v, agg);
? ? ? ? ?if (!signal.equals(v)) {
? ? ? ? ? ?agg.add(v);
? ? ? ? ?}
? ? ? ? ?aggRecordMap.put(lastMsgTimeKey, System.currentTimeMillis());
? ? ? ? ?return agg;
標(biāo)簽：
