1、前言

某个功能要求需要对一个list对象里数据按照股票分组，并且取分组涨跌幅最大的，返回一个新的list对象，并且按照涨跌幅字段进行排序，这么一连串的要求，如果按照传统的写法，我们需要写一大坨的代码，代码很是啰嗦，我们可以选择使用java8中的Collectors.groupingBy和Collectors.maxBy 来按照某个字段先进行分组，在取分组中某个最大值，最后收集到一个列表中。话不多说，上代码！
2、主要内容

实体

@Builder
@Data
@ApiModel("个股行情")
public class StockHq implements Serializable {private static final long serialVersionUID = 5061852660593543033L;/*** 表id*/@ApiModelProperty("表id")@TableId(value = "id", type = IdType.AUTO)private Long id;/*** 交易日期*/@ApiModelProperty("交易日期 ")@TableField("trade_date")private Integer tradeDate;/*** 证券id*/@ApiModelProperty("证券id")@TableField("stock_id")private Integer stockId;/*** 股票代码*/@ApiModelProperty("交易日期  ")@TableField("stock_code")private String stockCode;/*** 股票名称*/@ApiModelProperty("股票名称")@TableField("stock_name")private String stockName;@ApiModelProperty("上榜日涨幅")@TableField("price_chg")private BigDecimal priceChg;@ApiModelProperty("收盘价")@TableField("price_now")private BigDecimal priceNow;@ApiModelProperty("成交数量")@TableField("trade_amount")private Integer tradeAmount;@NumberField(type = 1)@ApiModelProperty("成交金额")@TableField("trade_money")private BigDecimal tradeMoney;
}

使用collect方法，结合collect中的Collectors.groupingBy和Collectors.maxBy

      List<StockHq> stockHqList = new ArrayList<>();stockHqList.add(StockHq.builder().stockCode("603386").stockId(100603386).stockName("骏亚科技").priceChg(new BigDecimal("10.3")).tradeDate(20200101).build());stockHqList.add(StockHq.builder().stockCode("603386").stockId(100603386).stockName("骏亚科技").priceChg(new BigDecimal("9.3")).tradeDate(20200111).build());stockHqList.add(StockHq.builder().stockCode("000737").stockId(200000737).stockName("北方铜业").priceChg(new BigDecimal("1.3")).tradeDate(20240711).build());stockHqList.add(StockHq.builder().stockCode("000737").stockId(200000737).stockName("北方铜业").priceChg(new BigDecimal("134.2")).tradeDate(20240611).build());List<StockHq> lastStockHqList = stockHqList.stream().collect(Collectors.groupingBy(StockHq::getStockCode, Collectors.maxBy(Comparator.comparing(StockHq::getPriceChg)))).values().stream().map(Optional::get).sorted(Comparator.comparing(StockHq::getPriceChg).reversed())//降序.collect(Collectors.toList());//返回一个list

代码就用一行，代码简单名了，特此写文章作为笔记，希望能对你有所帮助。