目標(biāo)&背景

我們以“處理訂單數(shù)據(jù)”為例，假設(shè)我們的應(yīng)用是一個(gè)分布式應(yīng)用，有"訂單應(yīng)用"，"物流應(yīng)用"，"商品應(yīng)用”等都是獨(dú)立的服務(wù)。本次我們的目的需要展示訂單列表完整數(shù)據(jù)：

1.查詢訂單列表。

2.批量查詢物流信息。

3.將物流信息填充到訂單主信息中。

假設(shè)我們定義了一個(gè)訂單類，具有幾個(gè)關(guān)鍵的屬性：訂單號(hào)，狀態(tài)，訂單價(jià)，快遞信息。如下所示：

class Order{
  String orderSeq;
  String status;
  double totalPrice;
  String expressInfo;
  // 省略get,set及hashCode等方法
} 

我們定義了一個(gè)快遞信息類，幾個(gè)關(guān)鍵的屬性：訂單號(hào)，物流公司，物流單號(hào)，物流狀態(tài)。如下所示：

class ExpressInfo{
  String orderSeq;
  String expressName;
  String expressNo;
  String createTime;
  String statusInfo;
  // 省略get,set及hashCode等方法
}

Java7 實(shí)現(xiàn)

獲取訂單列表 & 抽取訂單號(hào)

  List<Order> orderList = getOrderList();
  // 抽取 訂單號(hào)
  List<String> orderSeqList = new ArrayList<>();
  for (Order order : orderList) {
    orderSeqList.add(order.getOrderSeq());
  }

這里我們獲取了訂單列表orderList,此時(shí)expressInfo里邊是沒(méi)有數(shù)據(jù)的。這里抽取單號(hào)依然是Java傳統(tǒng)的寫(xiě)法。

批量查詢快遞信息 & 組裝 訂單-快遞信息 map

由于我們是通過(guò)調(diào)用遠(yuǎn)程服務(wù)來(lái)獲取快遞信息，為了減少網(wǎng)絡(luò)通信次數(shù)，我們采取批量查詢的方式。這也是為什么，上一步中我們要抽取訂單號(hào)

下面我們來(lái)獲取快遞信息

// 調(diào)用遠(yuǎn)程服務(wù)，
List<ExpressInfo> expressInfos = RpcGetExpressInfoBatch(orderSeqList);
// 組裝 訂單-快遞 關(guān)系map
Map<String,String> orderExpressMap = new HashMap<>();
for(ExpressInfo e: expressInfos){
  orderExpressMap.put(e.getOrderSeq(),e.getStatusInfo());
}

這里組裝map，也依然是Java7常用的寫(xiě)法。

組合數(shù)據(jù),將快遞信息填充進(jìn)訂單#

for(Order order:orderList){
  String expressInfo = orderExpressMap.get(order.getOrderSeq());
  order.setExpressInfo(expressInfo);
}

至此，我們使用Java7 的寫(xiě)法，完成了開(kāi)篇設(shè)定的目標(biāo)。下面我們看Java8的寫(xiě)法

Java8 實(shí)現(xiàn)

獲取訂單列表 & 抽取訂單號(hào)#

// 獲取列表
List<Order> orderList = getOrderList();
// 抽取單號(hào)
List<String> orderSeqs = orderList.stream()
    .map(Order::getOrderSeq)
    .collect(Collectors.toList());

這里我們使用了stream.map,在map()中，我們的寫(xiě)法是Order::getOrderSeq表示調(diào)用Order對(duì)象的getOrderSeq()方法來(lái)抽取訂單號(hào)。

這里的::叫“方法應(yīng)用”，是Java8中的新寫(xiě)法。

在map()后面緊跟的是collect收集器，他將抽取的數(shù)據(jù)toList(),于是我們得到了最終的List。

批量查詢快遞信息 & 組裝 訂單-快遞信息 map

下面我們?nèi)匀皇峭ㄟ^(guò)遠(yuǎn)程調(diào)用來(lái)獲取快遞信息，然后使用Java8的語(yǔ)法建立一個(gè) 訂單-快遞 關(guān)聯(lián)信息的map。

List<ExpressInfo> expressInfos = RpcGetExpressInfoBatch(orderSeqList);
Map<String,String> orderExpressMap =expressInfos.stream()
    .collect(Collectors.toMap(ExpressInfo::getOrderSeq,ExpressInfo::getStatusInfo));

這里代碼比Java7的要少吧，且一目了然，這里用strean().collect來(lái)收集數(shù)據(jù)，收集成什么形式呢？看名知意，Collectors.toMap收集成Map,收集什么數(shù)據(jù)呢？toMap()中，寫(xiě)了ExpressInfo::getOrderSeq及ExpressInfo::getStatusInfo，即：抽取orderSeq作為key，statusInfo作為value。

至此，訂單數(shù)據(jù)，訂單-物流關(guān)系數(shù)據(jù)map都得到了，下面我們來(lái)組合數(shù)據(jù)。

組合數(shù)據(jù),將快遞信息填充進(jìn)訂單#
經(jīng)過(guò)上面啰嗦的兩步，我們得到了符合我們要求的數(shù)據(jù)，現(xiàn)在我們需要根據(jù)顏值高低進(jìn)行排名，代碼如下：

orderList.stream().forEach(o -> o.setExpressInfo(orderExpressMap.get(o.getOrderSeq())));

你沒(méi)看錯(cuò)，就只有這么一行。

總結(jié)#
本節(jié)，我們使用Java8 Stream API，完成了數(shù)據(jù)的抽取和收集，使用了map(),和collect()來(lái)完成數(shù)據(jù)的抽取和收集，并了解了兩種收取方式toList和toMap。所以，以后如果有人問(wèn)你"Java8 stream 如何獲取對(duì)象的某個(gè)屬性list??？"，“java8 stream 如何獲取指定數(shù)據(jù)組裝成map??？”，你就可以把本文中的方法告訴他了。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評(píng)論