http urll 接口的写法

时间 2019-12-01
原文原文链接
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;
import java.nio.charset.Charset;

/**
 * TODO 代码仅做为示例，未作优化和代码复用等处理；<br />
 * TODO 使用时需根据实际状况进行优化和改造
 */
public class HttpClientDemo {

    private static Logger logger = LoggerFactory.getLogger(HttpClientDemo.class);

    /**
     * app的应用id，开发和上线前联系前海一方获取，须要保密存储
     */
    private final static String APP_KEY = "db3a7jajk-dasd-a34d-ffs1-d32123fsfe43s";

    /**
     * app的密钥，开发和上线前联系前海一方获取，须要保密存储
     */
    private final static String APP_SECRET = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCxw6V3m50E2xGN7OZSG/t9qOpfi/VBUFJaIgEFc+sZhadiR7kqcWb3niadyS5okny/SLmN4oM676B4SlaW1BI4TVZ2oh4bP2c63dw0MzA+nTrBrfXVLGE83+66uv8z6d33XCMfxKmE/XnVdwrsj/3veVjNOGuCG2dMzTEIYAjGBQIDAQAB";

    public static void main(String[] args) {
// TODO 使用的post请求，若是是GET请求，需使用HttpGet，PUT使用HttpPut，DELETE使用HttpDelete
        HttpPost post = null;
        try {
            String token = getToken(); // 获取token
            HttpClient httpClient = HttpClients.createDefault();
            post = new HttpPost("http://192.168.138.193:6060/api/kingdee/payment/info");
            // 构造消息头
            post.setHeader("Content-type", "application/json; charset=utf-8");
            post.setHeader("Connection", "Close");
            // 每一个业务接口调用时，都必须提供token，前海一方将根据token检测请求是否来自合法的三方
            // token有过时时间，在过时时间以后token须要从新获取
            post.setHeader("token", token);

            String requestParameter = "{\"baoliNo\":\"BL-1903-000005\",\"billDate\":\"2019-03-11 14:29:57\",\"applyAmount\":1,\"payee\":\"江苏优创公关策划有限公司\",\"payProviderGUID\":\"447c9c78-884a-e811-80bd-90e2babd62d1\",\"applyDesc\":\"支付优创案名发布会费用\",\"contractCode\":\"住宅开发常州公司-常州天宁区刘塘浜地块（联合操盘）-一期-2018-07-000852\",\"contractName\":\"苏南公司--璞樾门第项目--案名发布会\",\"applyCode\":\"dccz-2018-10-7427\",\"companyName\":\"常州亿泰房地产开发有限公司\",\"payeeBank\":\"中国银行股份有限公司常州新城支行\",\"payeeAccount\":\"496263424668\"}"; // 请求参数，按照不一样的接口参数构造json字符串
            // 对请求参数进行加密
            String rsaParameter = rsaEncryptedString(requestParameter);

            // 构建消息实体
            StringEntity entity = new StringEntity(rsaParameter, Charset.forName("gbk"));
            entity.setContentEncoding("gbk");
            // 发送Json格式的数据请求
            entity.setContentType("application/json");
            
            
            //https://data.riskstorm.com/v1/news/57e0fdbcd266387351d0e5a4?apikey=BvAXwAfqr0b3QMg2OCuSrA  这样类型的url
            post.setEntity(entity);

            HttpResponse response = httpClient.execute(post);

// 检验返回码
            int statusCode = response.getStatusLine().getStatusCode();
            if (statusCode != HttpStatus.SC_OK) {
                logger.error("请求出错: " + statusCode);
            } else {
// TODO 这里参考getToken方法中解析响应数据
            }
        } catch (Exception e) {
// TODO 按需处理异常
            e.printStackTrace();
        } finally {
            if (post != null) {
                try {
                    post.releaseConnection();
                    Thread.sleep(500);
                } catch (InterruptedException e) {
// TODO 按需处理异常
                    e.printStackTrace();
                }
            }
        }
    }

    /**
     * 获取访问凭证的示例方法<br />
     * 建议实际使用时，作好token的缓存和检测（当发现token超时后自动从新获取）；token在过时前可缓存使用
     *
     * @return　token
     */
    static String getToken() {
        HttpClient httpClient = HttpClients.createDefault();
        HttpPost post = null;
        try {
            post = new HttpPost("http://192.168.138.193:6060/api/auth/access/token");

            // 设置http请求头的信息，目前仅限定了请求协议为json，编码为utf-8
            // 构造消息头
            post.setHeader("Content-type", "application/json; charset=utf-8");
            post.setHeader("Connection", "Close");
            // 构造请求的json参数，能够经过fastjson、gson等框架来构造该字符串

            String requestParameter = "{\"appKey\":\"" + APP_KEY + "\",\"appSecret\":\"" + APP_SECRET + "\"}";

            // 构建消息实体
            StringEntity entity = new StringEntity(requestParameter, Charset.forName("gbk"));
            entity.setContentEncoding("gbk");
            // 发送Json格式的数据请求
            entity.setContentType("application/json");
            post.setEntity(entity);

            HttpResponse response = null;
            response = httpClient.execute(post);
            // 检验返回码
            int statusCode = response.getStatusLine().getStatusCode();
            if (HttpStatus.SC_OK != statusCode) {
                throw new RuntimeException("获取token的HTTP请求响应失败，响应代码：" + statusCode);
            }
            HttpEntity resultEntity = response.getEntity();
            if (resultEntity != null) {
                // TODO 如下为解析响应的json结构，可按需优化为定义一个POJO对象，并直接从json转换为json对象
                String resultString = EntityUtils.toString(resultEntity, "gbk");
                JSONObject resultJsonObject = JSON.parseObject(resultString);
                if (!resultJsonObject.containsKey("data")) {
                    throw new RuntimeException("响应数据结构有误,响应数据为：" + resultString);
                }
                JSONObject dataJsonObject = resultJsonObject.getJSONObject("data");
                if (!dataJsonObject.containsKey("token")) {
                    throw new RuntimeException("响应数据结构有误(未包含token),响应数据为：" + resultString);
                }
                // long expireTime = dataJsonObject.getLongValue("expireTime"); // 过时时间，表明多少毫秒后token将过时
                return dataJsonObject.getString("token");
            }
        } catch (IOException e) {
            // TODO 按需处理异常
            // e.printStackTrace();
            logger.error("获取token出错，这里须要按照业务须要实现本身的错误处理逻辑", e);
        }
        return null;
    }

    /**
     * 加密请求参数
     *
     * @param jsonData 要加密的json参数
     * @return 加密后的参数字符串
     */
    static String rsaEncryptedString(String jsonData) {

        try {

            return RsaUtils.encryptedString(jsonData, APP_SECRET);
        } catch (Exception e) {
            // TODO 按需处理异常
            e.printStackTrace();
        }
        return null;
    }


}