需求: 获取3个有一定关联的业务接口的数据并返回
接口返回数据格式:
A: {“msg”:“操作成功”,“success”:true,“AStatus”:7}
B: {“msg”:“操作成功”,“success”:true,“BStatus”:1}
C: {“msg”:“操作成功”,“C2Status”:null,“success”:true,“CStatus”:“1”}
主要需求就是获取几个状态
主代码
public RefreshMemberResult refreshMember(RefreshMember refreshMember)
{
return Arrays.asList(
A_URL,
B_URL,
C_URL)
.parallelStream()
// 发送请求获取结果, post方法就是发送一个http的请求返回请求结果
.map(url -> this.post(url, refreshMember))
// 转换成 JSONObject
.map(JSONUtil::parseObj)
// 获取执行成功的结果, 这里忽略失败的请求
.filter(jsonObject -> jsonObject.getBool("success", false))
// 合并 JSONObject
.reduce(this::putAll)
// 转换为自己 bean 对象
.map(jsonObject -> jsonObject.toBean(RefreshMemberResult.class))
// 获取结果,抛出异常
.orElseThrow(() -> new RuntimeException("刷新失败"));
}
RefreshMemberResult类
@Data
public class RefreshMemberResult implements Serializable
{
/** 信息提示*/
private String msg;
/** 执行状态*/
private Boolean success;
private String AStatus;
private String BStatus;
private String C2Status;
private String CStatus;
}
合并JSONObject
/**
* 合并JSONObject
* @param firstJson 被合并的第一个JSONObject
* @param theSecondJson 被合并的第二个JSONObject
* @return 合并后的JSONObject
*/
private JSONObject putAll(JSONObject firstJson, JSONObject theSecondJson)
{
firstJson.putAll(theSecondJson);
return firstJson;
}
这里使用并行而非异步,主要因为感觉异步执行三个请求,再等待三个请求执行完成,再做相应的操作比较麻烦