ICode9

精准搜索请尝试: 精确搜索
首页 > 编程语言> 文章详细

利用java8的并行流实现多个接口同时请求,并合并结果

2021-04-24 19:01:13  阅读:580  来源: 互联网

标签:String success JSONObject 并行 private 接口 msg java8 请求


需求: 获取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;
    }

这里使用并行而非异步,主要因为感觉异步执行三个请求,再等待三个请求执行完成,再做相应的操作比较麻烦

标签:String,success,JSONObject,并行,private,接口,msg,java8,请求
来源: https://blog.csdn.net/weixin_45799178/article/details/116100115

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有