2020年 – 第3页

solr 12月 7,2020

Excel快速导入导出工具(仅提供excel2007以及更高版本的支持)

public class ExcelWriter {

    /** 日志 */
    private static Logger LOG = LoggerFactory.getLogger(ExcelWriter.class);

    /** 原生HttpServletResponse对象 */
    private HttpServletResponse response = null;

    /**
     * 用于导入excel的构造函数
     */
    private ExcelWriter() {

    }

    /**
     * 用于导出excel的构造函数 <br>
     * List(Bean)格式
     * 
     * @param clazz
     * @param response
     */
    private ExcelWriter(Class<?> clazz, HttpServletResponse response) {
        // this.clazz == clazz;
        this.response = response;
    }

    /**
     * 用于导出excel的构造函数 <br>
     * List(String[]) 格式
     * 
     * @param response
     */
    private ExcelWriter(HttpServletResponse response) {
        this.response = response;
    }

    /**
     * 用于浏览器导出excel的实例化
     *
     * @param clazz 实体Class对象
     * @param response 原生HttpServletResponse对象
     * @return ExcelUtils
     */
    public static ExcelWriter exportInit(HttpServletResponse response) {
        return new ExcelWriter(response);
    }

    /**
     * 用于浏览器导出excel的实例化
     *
     * @param clazz 实体Class对象
     * @param response 原生HttpServletResponse对象
     * @return ExcelUtils
     */
    public static ExcelWriter exportInit(Class<?> clazz, HttpServletResponse response) {
        return new ExcelWriter(clazz, response);
    }

    /**
     * 导出Excel,响应到浏览器下载(List<String[]>格式)
     * 
     * @param headers 表头
     * @param data 数据
     * @param fileName 文件名称
     * @param sheetName 工作表名
     * @return
     */
    public boolean writeExcel(List<String> headers, List<String[]> datas, String fileName, String sheetName) {
        if (response == null) {
            throw new IllegalArgumentException("请先使用exportInit(HttpServletResponse)初始化参数。");
        }
        long begin = System.currentTimeMillis();

        if (ListUtils.isEmpty(datas)) {
            LOG.error("没有检测到数据,不执行导出操作。");
            return false;
        }
        int dataSize = datas.size();
        LOG.info(String.format("即将导出excel数据 : %s条,请稍后...", dataSize));
        try {
            // 输出流
            OutputStream outputStream = response.getOutputStream();
            // 创建新的工作薄
            SXSSFWorkbook wb = PoiUtils.newSXSSFWorkbook();
            // 表头的样式
            CellStyle cellStyle = wb.createCellStyle();
            Font font = wb.createFont();
            // 对齐
            cellStyle.setAlignment(CellStyle.ALIGN_LEFT);
            font.setBoldweight(Font.BOLDWEIGHT_NORMAL);
            // 字体大小
            font.setFontHeightInPoints((short) 12);
            font.setFontName("宋体");
            // 应用标题字体到标题样式
            cellStyle.setFont(font);
            // 设置单元格文本形式
            DataFormat dataFormat = wb.createDataFormat();
            cellStyle.setDataFormat(dataFormat.getFormat("@"));

            // 表头的值
            String headerValue = null;
            // 单元格的值
            String cellValue = null;
            // 创建sheet
            SXSSFSheet sheet = PoiUtils.newSXSSFSheet(wb, sheetName);
            // 创建行表头
            SXSSFRow headerRow = PoiUtils.newSXSSFRow(sheet, 0);
            for (int i = 0, size = headers.size(); i < size; i++) {
                headerValue = headers.get(i);
                SXSSFCell cell = PoiUtils.newSXSSFCell(headerRow, i);
                cell.setCellValue(headerValue);
                cell.setCellStyle(cellStyle);
            }

            // 明细行数组
            String[] bodys = null;
            for (int i = 0; i < dataSize; i++) {
                // 创建行数据
                SXSSFRow bodyRow = PoiUtils.newSXSSFRow(sheet, i + 1);
                bodys = datas.get(i);
                for (int j = 0, len = bodys.length; j < len; j++) {
                    cellValue = bodys[j];
                    if (StringUtils.isBlank(cellValue)) {
                        // FIXME: 当值为""时,当前index的cell会失效,这里设置为null
                        cellValue = null;
                    }

                    // 创建列
                    SXSSFCell cell = PoiUtils.newSXSSFCell(bodyRow, j);
                    cell.setCellValue(cellValue);
                    cell.setCellType(SXSSFCell.CELL_TYPE_STRING);
                }
            }

            writeByBrowser(response, fileName, wb, outputStream);
            LOG.info(String.format("excel处理完成,共生成数据 : %s行,耗时 : %s seconds.", dataSize,
                    (System.currentTimeMillis() - begin) / 1000.0));
        } catch (Exception e) {
            LOG.error("导出excel失败 : " + e.getMessage(), e);
        }
        return true;
    }

    /**
     * 响应到浏览器下载
     * 
     * @param response
     * @param fileName
     * @param wb
     * @param out
     * @throws Exception
     */
    private static void writeByBrowser(HttpServletResponse response, String fileName, SXSSFWorkbook wb,
            OutputStream out) throws Exception {
        // response对象不为空,响应到浏览器下载
        if (response != null) {
            response.setContentType(ConstantUtils.CONTENT_TYPE);
            response.setCharacterEncoding("UTF-8");
            fileName = new String(fileName.getBytes("UTF-8"), "ISO8859-1") + ConstantUtils.XLSX_SUFFIX;
            response.setHeader("Content-Disposition", "attachment;filename=" + fileName);
            if (out == null) {
                out = response.getOutputStream();
            }
        }
        wb.write(out);
        out.flush();
        out.close();
    }

    /**
     * 保存文件到本地
     * 
     * @param headers 表头
     * @param datas 转换好的数据
     * @param filePath 路径
     * @param sheetName 工作表名
     * @param type 类型 0-转换成功 1-转换失败
     */
    public static void saveByLocal(List<String> headers, List<String[]> datas, String filePath, int type) {
        long begin = System.currentTimeMillis();

        if (ListUtils.isEmpty(datas)) {
            LOG.error("没有检测到数据,不执行导出操作。");
            return;
        }
        int dataSize = datas.size();
        LOG.info(String.format("即将保存excel数据 : %s条,请稍后...", dataSize));
        // 输出流
        FileOutputStream fileOutputStream = null;
        BufferedOutputStream bufferedOutputStream = null;
        try {
            fileOutputStream = new FileOutputStream(filePath);
            bufferedOutputStream = new BufferedOutputStream(fileOutputStream);
            String sheetName = "";
            if (type == 0) {
                sheetName = PropertyUtils.getProperty("successConversion");
            } else if (type == 1) {
                sheetName = PropertyUtils.getProperty("failConversion");
            }
            // 创建新的工作薄
            SXSSFWorkbook wb = PoiUtils.newSXSSFWorkbook();
            // 表头的样式
            CellStyle cellStyle = wb.createCellStyle();
            Font font = wb.createFont();
            // 对齐
            cellStyle.setAlignment(CellStyle.ALIGN_LEFT);
            font.setBoldweight(Font.BOLDWEIGHT_NORMAL);
            // 字体大小
            font.setFontHeightInPoints((short) 12);
            font.setFontName("宋体");
            // 应用标题字体到标题样式
            cellStyle.setFont(font);
            // 设置单元格文本形式
            DataFormat dataFormat = wb.createDataFormat();
            cellStyle.setDataFormat(dataFormat.getFormat("@"));

            // 表头的值
            String headerValue = null;
            // 单元格的值
            String cellValue = null;
            // 创建sheet
            SXSSFSheet sheet = PoiUtils.newSXSSFSheet(wb, sheetName);
            // 创建行表头
            SXSSFRow headerRow = PoiUtils.newSXSSFRow(sheet, 0);
            for (int i = 0, size = headers.size(); i < size; i++) {
                headerValue = headers.get(i);
                SXSSFCell cell = PoiUtils.newSXSSFCell(headerRow, i);
                cell.setCellValue(headerValue);
                cell.setCellStyle(cellStyle);
            }

            // 明细行数组
            String[] bodys = null;
            for (int i = 0; i < dataSize; i++) {
                // 创建行数据
                SXSSFRow bodyRow = PoiUtils.newSXSSFRow(sheet, i + 1);
                bodys = datas.get(i);
                for (int j = 0, len = bodys.length; j < len; j++) {
                    cellValue = bodys[j];
                    if (StringUtils.isBlank(cellValue)) {
                        // FIXME: 当值为""时,当前index的cell会失效,这里设置为null
                        cellValue = null;
                    }

                    // 创建列
                    SXSSFCell cell = PoiUtils.newSXSSFCell(bodyRow, j);
                    cell.setCellValue(cellValue);
                    cell.setCellType(SXSSFCell.CELL_TYPE_STRING);
                }
            }

            wb.write(bufferedOutputStream);
            LOG.info(String.format("excel处理完成,共生成数据 : %s行,耗时 : %s seconds.", dataSize,
                    (System.currentTimeMillis() - begin) / 1000.0));
        } catch (Exception e) {
            LOG.error("保存excel失败 : " + e.getMessage(), e);
        } finally {
            if (bufferedOutputStream != null) {
                try {
                    bufferedOutputStream.close();
                } catch (IOException e) {
                    LOG.error("文件流关闭异常");
                }
            }
        }
    }

}

作者 east

Java 12月 7,2020

Authorization 请求头字段

response: 客户端根据算法算出的摘要值
username: 要认证的用户名
realm: 认证域,可取任意标识值
uri: 请求的资源位置
qop: 保护质量
nonce: 服务器密码随机数
nc: 16进制请求认证计数器,第一次 00000001
algorithm: 默认MD5算法
cnonce: 客户端密码随机数

Request-Digest 摘要计算过程

若算法是：MD5 或者是未指定
则 A1= <username>:<realm>:<passwd>

若 qop 未定义或者 auth：
则 A2= <request-method>:<digest-uri-value>

若 qop 为 auth
      response=MD5(MD5(A1):<nonce>:<nc>:<cnonce>:<qop>:MD5(A2)) 
若 qop 没有定义
      response=MD5(MD5(A1):<nonce>:MD5(A2))


import org.apache.commons.codec.binary.Hex;
import org.apache.commons.lang3.Validate;

import java.io.UnsupportedEncodingException;
import java.security.GeneralSecurityException;
import java.security.MessageDigest;
import java.security.SecureRandom;
import java.util.Random;

/**
 * Http Digest
 * @author zhouzhixiang
 * @date 2019-05-14
 */
public class Digests {

    private static SecureRandom random = new SecureRandom();
    /**
     * 加密遵循RFC2671规范 将相关参数加密生成一个MD5字符串,并返回
     */
    public static String http_da_calc_HA1(String username, String realm, String password,
                                          String nonce, String nc, String cnonce, String qop,
                                          String method, String uri, String algorithm) {
        String HA1, HA2;
        if ("MD5-sess".equals(algorithm)) {
            HA1 = HA1_MD5_sess(username, realm, password, nonce, cnonce);
        } else {
            HA1 = HA1_MD5(username, realm, password);
        }
        byte[] md5Byte = md5(HA1.getBytes());
        HA1 = new String(Hex.encodeHex(md5Byte));

        md5Byte = md5(HA2(method, uri).getBytes());
        HA2 = new String(Hex.encodeHex(md5Byte));

        String original = HA1 + ":" + (nonce + ":" + nc + ":" + cnonce + ":" + qop) + ":" + HA2;

        md5Byte = md5(original.getBytes());
        return new String(Hex.encodeHex(md5Byte));

    }

    /**
     * algorithm值为MD5时规则
     */
    private static String HA1_MD5(String username, String realm, String password) {
        return username + ":" + realm + ":" + password;
    }

    /**
     * algorithm值为MD5-sess时规则
     */
    private static String HA1_MD5_sess(String username, String realm, String password, String nonce, String cnonce) {
        //      MD5(username:realm:password):nonce:cnonce

        String s = HA1_MD5(username, realm, password);
        byte[] md5Byte = md5(s.getBytes());
        String smd5 = new String(Hex.encodeHex(md5Byte));

        return smd5 + ":" + nonce + ":" + cnonce;
    }

    private static String HA2(String method, String uri) {
        return method + ":" + uri;
    }

    /**
     * 对输入字符串进行md5散列.
     */
    public static byte[] md5(byte[] input) {
        return digest(input, "MD5", null, 1);
    }

    /**
     * 对字符串进行散列, 支持md5与sha1算法.
     */
    private static byte[] digest(byte[] input, String algorithm, byte[] salt, int iterations) {
        try {
            MessageDigest digest = MessageDigest.getInstance(algorithm);

            if (salt != null) {
                digest.update(salt);
            }

            byte[] result = digest.digest(input);

            for (int i = 1; i < iterations; i++) {
                digest.reset();
                result = digest.digest(result);
            }
            return result;
        } catch (GeneralSecurityException e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 随机生成numBytes长度数组
     * @param numBytes
     * @return
     */
    public static byte[] generateSalt(int numBytes) {
        Validate.isTrue(numBytes > 0, "numBytes argument must be a positive integer (1 or larger)", (long)numBytes);
        byte[] bytes = new byte[numBytes];
        random.nextBytes(bytes);
        return bytes;
    }

    @Deprecated
    public static String generateSalt2(int length) {
        String val = "";
        Random random = new Random();
        //参数length，表示生成几位随机数
        for(int i = 0; i < length; i++) {
            String charOrNum = random.nextInt(2) % 2 == 0 ? "char" : "num";
            //输出字母还是数字
            if( "char".equalsIgnoreCase(charOrNum) ) {
                //输出是大写字母还是小写字母
                int temp = random.nextInt(2)%2 == 0 ? 65 : 97;
                val += (char)(random.nextInt(26) + temp);
            } else if( "num".equalsIgnoreCase(charOrNum) ) {
                val += String.valueOf(random.nextInt(10));
            }
        }
        return val.toLowerCase();
    }


    //测试
    public static void main(String[] args) throws UnsupportedEncodingException {
        // String s = http_da_calc_HA1("povodo", "realm@easycwmp", "povodo",
        //                             "c10c9897f05a9aee2e2c5fdebf03bb5b0001b1ef", "00000001", "d5324153548c43d8", "auth",
        //                             "GET", "/", "MD5");
        // System.out.println("加密后response为:" + s);

        // String s = new String(generateSalt(8),"UTF-8");

        // System.out.println(s);
    }
}

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLConnection;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**

Http Digest Request contains POST、GET、PUT
@author zhouzhixiang
@date 2019-05-14
*/
public class HttpRequestUtils { private static final Logger logger = LoggerFactory.getLogger(HttpRequestUtils.class); public static void main(String[] args) {
// String url = “http://192.168.200.117:8087/v2/servers/defaultServer/vhosts/defaultVHost/applications/live/publishers”;
// String url = “http://192.168.200.117:8087/v2/servers/defaultServer/vhosts/defaultVHost/applications/Relay/streamfiles/1234566/actions/connect?&vhost=defaultVHost&appType=live&appName=Relay&appInstance=definst&connectAppName=Relay&connectAppInstance=definst&streamFile=1234566.stream&mediaCasterType=liverepeater”;
String param = “”;
String username = “xxxxxx”;
String password = “xxxxxx”;
// String json = “{ \”password\”: \”plmo13579123\”, \”publisherName\”: \”4\”, \”serverName\”: \”defaultServer\”, \”description\”: \”\”, \”saveFieldList\”: [ \”\” ], \”version\”: \”v1.0\” }”;
// String s = sendPost(url, param, username, password, json); // String s = sendPost(url, param, username, password, json); // -----------------GET-success------------------ String getUrl = "http://192.168.200.117:8087/v2/servers/_defaultServer_/vhosts/_defaultVHost_/applications"; // String s = sendGet(getUrl, param, username, password, null); // -----------------GET-success------------------ // -----------------PUT-success------------------ String putUrl = "http://192.168.200.117:8087/v2/servers/_defaultServer_/vhosts/_defaultVHost_/applications/Relay/streamfiles/6D07D7E7623B95889C33DC5901307461_0/actions/connect"; String putJson = "{ \"vhost\":\"_defaultVHost_\", \"mediaCasterType\":\"liverepeater\" }"; // String s = sendPUT(putUrl, param, username, password, putJson, null); // -----------------PUT-success------------------ // -----------------POST-success------------------ String postUrl = "http://192.168.200.117:8087/v2/servers/_defaultServer_/users"; String postJson = "{ \"password\": \"123456\", \"serverName\": \"_defaultServer_\", \"description\": \"\", \"groups\": [ \"\" ], \"saveFieldList\": [ \"\" ], \"userName\": \"test6\", \"version\": \"v1.0\" }"; // String s = sendPost(postUrl, param, username, password, postJson, null); // -----------------POST-success------------------ // -----------------POST-success------------------ String postUrl2 = "http://192.168.200.117:8087/v2/servers/_defaultServer_/publishers"; String postJson2 = "{ \"password\": \"1579655633@qq.com\", \"name\": \"test11\", \"serverName\": \"_defaultServer_\", \"description\": \"test\", \"saveFieldList\": [ \"\" ], \"version\": \"v1.0\" }"; // String s = sendPost(postUrl2, param, username, password, postJson2, null); // -----------------POST-success------------------ // -----------------DELETE-success------------------ String deleteUrl = "http://192.168.200.117:8087/v2/servers/_defaultServer_/users/test5"; // String deleteJson = "{ \"password\": \"1579655633@qq.com\", \"name\": \"test11\", \"serverName\": \"_defaultServer_\", \"description\": \"test\", \"saveFieldList\": [ \"\" ], \"version\": \"v1.0\" }"; String s = sendDelete(deleteUrl, param, username, password, null, null); // -----------------DELETE-success------------------ System.out.println(s); } static int nc = 0; //调用次数
private static final String GET = “GET”;
private static final String POST = “POST”;
private static final String PUT = “PUT”;
private static final String DELETE = “DELETE”; /**
- 向指定URL发送DELETE方法的请求
- @param url 发送请求的URL
- @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
- @param username 验证所需的用户名
- @param password 验证所需的密码
- @param json 请求json字符串
- @param type 返回xml和json格式数据，默认xml，传入json返回json数据
- @return URL 所代表远程资源的响应结果
  */
  public static String sendDelete(String url, String param, String username, String password, String json, String type) { StringBuilder result = new StringBuilder();
  BufferedReader in = null;
  try {
  String wwwAuth = sendGet(url, param); //发起一次授权请求
  if (wwwAuth.startsWith(“WWW-Authenticate:”)) {
  wwwAuth = wwwAuth.replaceFirst(“WWW-Authenticate:”, “”);
  } else {
  return wwwAuth;
  }
  nc ++;
  String urlNameString = url + (StringUtils.isNotEmpty(param) ? “?” + param : “”);
  URL realUrl = new URL(urlNameString);
  // 打开和URL之间的连接
  HttpURLConnection connection = (HttpURLConnection)realUrl.openConnection(); // 设置是否向connection输出，因为这个是post请求，参数要放在 // http正文内，因此需要设为true connection.setDoOutput(true); // Read from the connection. Defaultis true. connection.setDoInput(true); // 默认是 GET方式 connection.setRequestMethod(DELETE); // 设置通用的请求属性 setRequestProperty(connection, wwwAuth, realUrl, username, password, DELETE, type); if (!StringUtils.isEmpty(json)) { byte[] writebytes =json.getBytes(); connection.setRequestProperty("Content-Length",String.valueOf(writebytes.length)); OutputStream outwritestream = connection.getOutputStream(); outwritestream.write(json.getBytes()); outwritestream.flush(); outwritestream.close(); } if (connection.getResponseCode() == 200) { in = new BufferedReader(new InputStreamReader(connection.getInputStream())); String line; while ((line = in.readLine()) != null) { result.append(line); } } else { String errResult = formatResultInfo(connection, type); logger.info(errResult); return errResult; } nc = 0; } catch (Exception e) {
  nc = 0;
  throw new RuntimeException(e);
  } finally {
  try {
  if (in != null) in.close();
  } catch (Exception e2) {
  e2.printStackTrace();
  }
  }
  return result.toString();
  }
/**
- 向指定URL发送PUT方法的请求
- @param url 发送请求的URL
- @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
- @param username 验证所需的用户名
- @param password 验证所需的密码
- @param json 请求json字符串
- @param type 返回xml和json格式数据，默认xml，传入json返回json数据
- @return URL 所代表远程资源的响应结果
  */
  public static String sendPUT(String url, String param, String username, String password, String json, String type) { StringBuilder result = new StringBuilder();
  BufferedReader in = null;
  try {
  String wwwAuth = sendGet(url, param); //发起一次授权请求
  if (wwwAuth.startsWith(“WWW-Authenticate:”)) {
  wwwAuth = wwwAuth.replaceFirst(“WWW-Authenticate:”, “”);
  } else {
  return wwwAuth;
  }
  nc ++;
  String urlNameString = url + (StringUtils.isNotEmpty(param) ? “?” + param : “”);
  URL realUrl = new URL(urlNameString);
  // 打开和URL之间的连接
  HttpURLConnection connection = (HttpURLConnection)realUrl.openConnection(); // 设置是否向connection输出，因为这个是post请求，参数要放在 // http正文内，因此需要设为true connection.setDoOutput(true); // Read from the connection. Defaultis true. connection.setDoInput(true); // 默认是 GET方式 connection.setRequestMethod(PUT); // Post 请求不能使用缓存 connection.setUseCaches(false); // 设置通用的请求属性 setRequestProperty(connection, wwwAuth,realUrl, username, password, PUT, type); if (!StringUtils.isEmpty(json)) { byte[] writebytes =json.getBytes(); connection.setRequestProperty("Content-Length",String.valueOf(writebytes.length)); OutputStream outwritestream = connection.getOutputStream(); outwritestream.write(json.getBytes()); outwritestream.flush(); outwritestream.close(); } if (connection.getResponseCode() == 200) { in = new BufferedReader(new InputStreamReader(connection.getInputStream())); String line; while ((line = in.readLine()) != null) { result.append(line); } } else { String errResult = formatResultInfo(connection, type); logger.info(errResult); return errResult; } nc = 0; } catch (Exception e) {
  nc = 0;
  throw new RuntimeException(e);
  } finally {
  try {
  if (in != null) in.close();
  } catch (Exception e2) {
  e2.printStackTrace();
  }
  }
  return result.toString();
  }
/**
- 向指定URL发送POST方法的请求
- @param url 发送请求的URL
- @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
- @param username 验证所需的用户名
- @param password 验证所需的密码
- @param json 请求json字符串
- @param type 返回xml和json格式数据，默认xml，传入json返回json数据
- @return URL 所代表远程资源的响应结果
  */
  public static String sendPost(String url, String param, String username, String password, String json, String type) { StringBuilder result = new StringBuilder();
  BufferedReader in = null;
  try {
  String wwwAuth = sendGet(url, param); //发起一次授权请求
  if (wwwAuth.startsWith(“WWW-Authenticate:”)) {
  wwwAuth = wwwAuth.replaceFirst(“WWW-Authenticate:”, “”);
  } else {
  return wwwAuth;
  }
  nc ++;
  String urlNameString = url + (StringUtils.isNotEmpty(param) ? “?” + param : “”);
  URL realUrl = new URL(urlNameString);
  // 打开和URL之间的连接
  HttpURLConnection connection = (HttpURLConnection)realUrl.openConnection(); // 设置是否向connection输出，因为这个是post请求，参数要放在 // http正文内，因此需要设为true connection.setDoOutput(true); // Read from the connection. Defaultis true. connection.setDoInput(true); // 默认是 GET方式 connection.setRequestMethod(POST); // Post 请求不能使用缓存 connection.setUseCaches(false); // 设置通用的请求属性 setRequestProperty(connection, wwwAuth,realUrl, username, password, POST, type); if (!StringUtils.isEmpty(json)) { byte[] writebytes =json.getBytes(); connection.setRequestProperty("Content-Length",String.valueOf(writebytes.length)); OutputStream outwritestream = connection.getOutputStream(); outwritestream.write(json.getBytes()); outwritestream.flush(); outwritestream.close(); } if (connection.getResponseCode() == 200 || connection.getResponseCode() == 201) { in = new BufferedReader(new InputStreamReader(connection.getInputStream())); String line; while ((line = in.readLine()) != null) { result.append(line); } } else { String errResult = formatResultInfo(connection, type); logger.info(errResult); return errResult; } nc = 0; } catch (Exception e) {
  nc = 0;
  throw new RuntimeException(e);
  } finally {
  try {
  if (in != null) in.close();
  } catch (Exception e2) {
  e2.printStackTrace();
  }
  }
  return result.toString();
  }
/**
- 向指定URL发送GET方法的请求
- @param url 发送请求的URL
- @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
- @param username 验证所需的用户名
- @param password 验证所需的密码
- @param type 返回xml和json格式数据，默认xml，传入json返回json数据
- @return URL 所代表远程资源的响应结果
  */
  public static String sendGet(String url, String param, String username, String password, String type) { StringBuilder result = new StringBuilder();
  BufferedReader in = null;
  try {
  String wwwAuth = sendGet(url, param); //发起一次授权请求
  if (wwwAuth.startsWith(“WWW-Authenticate:”)) {
  wwwAuth = wwwAuth.replaceFirst(“WWW-Authenticate:”, “”);
  } else {
  return wwwAuth;
  }
  nc ++;
  String urlNameString = url + (StringUtils.isNotEmpty(param) ? “?” + param : “”);
  URL realUrl = new URL(urlNameString);
  // 打开和URL之间的连接
  HttpURLConnection connection = (HttpURLConnection)realUrl.openConnection();
  // 设置通用的请求属性
  setRequestProperty(connection, wwwAuth,realUrl, username, password, GET, type);
  // 建立实际的连接
  // connection.connect();
  in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
  String line;
  while ((line = in.readLine()) != null) {
  result.append(line);
  }
  nc = 0;
  } catch (Exception e) {
  nc = 0;
  throw new RuntimeException(e);
  } finally {
  try {
  if (in != null) in.close();
  } catch (Exception e2) {
  e2.printStackTrace();
  }
  }
  return result.toString();
  }
/**
- 生成授权信息
- @param authorization 上一次调用返回401的WWW-Authenticate数据
- @param username 用户名
- @param password 密码
- @return 授权后的数据, 应放在http头的Authorization里
- @throws IOException 异常
  */
  private static String getAuthorization(String authorization, String uri, String username, String password, String method) throws IOException { uri = StringUtils.isEmpty(uri) ? “/” : uri;
  // String temp = authorization.replaceFirst(“Digest”, “”).trim();
  String temp = authorization.replaceFirst(“Digest”, “”).trim().replace(“MD5″,”\”MD5\””);
  // String json = “{\”” + temp.replaceAll(“=”, “\”:”).replaceAll(“,”, “,\””) + “}”;
  String json = withdrawJson(authorization);
  // String json = “{ \”realm\”: \”Wowza\”, \” domain\”: \”/\”, \” nonce\”: \”MTU1NzgxMTU1NzQ4MDo2NzI3MWYxZTZkYjBiMjQ2ZGRjYTQ3ZjNiOTM2YjJjZA==\”, \” algorithm\”: \”MD5\”, \” qop\”: \”auth\” }”; JSONObject jsonObject = JSON.parseObject(json);
  // String cnonce = new String(Hex.encodeHex(Digests.generateSalt(8))); //客户端随机数
  String cnonce = Digests.generateSalt2(8);
  String ncstr = (“00000000” + nc).substring(Integer.toString(nc).length()); //认证的次数,第一次是1，第二次是2…
  // String algorithm = jsonObject.getString(“algorithm”);
  String algorithm = jsonObject.getString(“algorithm”);
  String qop = jsonObject.getString(“qop”);
  String nonce = jsonObject.getString(“nonce”);
  String realm = jsonObject.getString(“realm”); String response = Digests.http_da_calc_HA1(username, realm, password,
  nonce, ncstr, cnonce, qop,
  method, uri, algorithm); //组成响应authorization
  authorization = “Digest username=\”” + username + “\”,” + temp;
  authorization += “,uri=\”” + uri
  + “\”,nc=\”” + ncstr
  + “\”,cnonce=\”” + cnonce
  + “\”,response=\”” + response+”\””;
  return authorization;
  }
/**
- 将返回的Authrization信息转成json
- @param authorization authorization info
- @return 返回authrization json格式数据如：String json = “{ \”realm\”: \”Wowza\”, \” domain\”: \”/\”, \” nonce\”: \”MTU1NzgxMTU1NzQ4MDo2NzI3MWYxZTZkYjBiMjQ2ZGRjYTQ3ZjNiOTM2YjJjZA==\”, \” algorithm\”: \”MD5\”, \” qop\”: \”auth\” }”;
  */
  private static String withdrawJson(String authorization) {
  String temp = authorization.replaceFirst(“Digest”, “”).trim().replaceAll(“\””,””);
  // String noncetemp = temp.substring(temp.indexOf(“nonce=”), temp.indexOf(“uri=”));
  // String json = “{\”” + temp.replaceAll(“=”, “\”:”).replaceAll(“,”, “,\””) + “}”;
  String[] split = temp.split(“,”);
  Map map = new HashMap<>();
  Arrays.asList(split).forEach(c -> {
  String c1 = c.replaceFirst(“=”,”:”);
  String[] split1 = c1.split(“:”);
  map.put(split1[0].trim(), split1[1].trim());
  });
  return JSONObject.toJSONString(map);
  }
/**
- 向指定URL发送GET方法的请求
- @param url 发送请求的URL
- @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
- @return URL 所代表远程资源的响应结果
  */
  public static String sendGet(String url, String param) {
  StringBuilder result = new StringBuilder();
  BufferedReader in = null;
  try { String urlNameString = url + (StringUtils.isNotEmpty(param) ? "?" + param : ""); URL realUrl = new URL(urlNameString); // 打开和URL之间的连接 URLConnection connection = realUrl.openConnection(); // 设置通用的请求属性 connection.setRequestProperty("accept", "*/*"); connection.setRequestProperty("connection", "Keep-Alive"); connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); connection.connect(); //返回401时需再次用用户名和密码请求 //此情况返回服务器的 WWW-Authenticate 信息 if (((HttpURLConnection) connection).getResponseCode() == 401) { Map<String, List<String>> map = connection.getHeaderFields(); return "WWW-Authenticate:" + map.get("WWW-Authenticate").get(0); } in = new BufferedReader(new InputStreamReader(connection.getInputStream())); String line; while ((line = in.readLine()) != null) { result.append(line); } } catch (Exception e) {
  throw new RuntimeException(“get请求发送失败”,e);
  }
  // 使用finally块来关闭输入流
  finally {
  try {
  if (in != null) in.close();
  } catch (Exception e2) {
  e2.printStackTrace();
  }
  }
  return result.toString();
  }
/**
- HTTP set request property
  *
- @param connection HttpConnection
- @param wwwAuth 授权auth
- @param realUrl 实际url
- @param username 验证所需的用户名
- @param password 验证所需的密码
- @param method 请求方式
- @param type 返回xml和json格式数据，默认xml，传入json返回json数据
  */
  private static void setRequestProperty(HttpURLConnection connection, String wwwAuth, URL realUrl, String username, String password, String method, String type)
  throws IOException { if (type != null && type.equals(“json”)) {
  // 返回json
  connection.setRequestProperty(“accept”, “application/json;charset=UTF-8”);
  connection.setRequestProperty(“Content-Type”,”application/json;charset=UTF-8″);
  connection.setRequestProperty(“connection”, “Keep-Alive”);
  connection.setRequestProperty(“user-agent”,
  “Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)”);
  } else {
  // 返回xml
  if (!method.equals(GET)) {
  connection.setRequestProperty(“Content-Type”,”application/json;charset=UTF-8″);
  }
  connection.setRequestProperty(“accept”, “/“);
  connection.setRequestProperty(“connection”, “Keep-Alive”);
  // connection.setRequestProperty(“Cache-Control”, “no-cache”);
  connection.setRequestProperty(“user-agent”,
  “Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)”); }
  //授权信息
  String authentication = getAuthorization(wwwAuth, realUrl.getPath(), username, password, method);
  connection.setRequestProperty(“Authorization”, authentication);
  }
/**
- 格式化请求返回信息，支持json和xml格式
- @param connection HttpConnection
- @param type 指定返回数据格式，json、xml，默认xml
- @return 返回数据
  */
  private static String formatResultInfo(HttpURLConnection connection, String type) throws IOException {
  String result = “”;
  if (type != null && type.equals(“json”)) {
  result = String.format(“{\”errCode\”:%s, \”message\”:%s}”,connection.getResponseCode(),connection.getResponseMessage());
  } else {
  result = String.format(” “
  + ” ” + ” %d” + ” %s” + ” “,connection.getResponseCode(),connection.getResponseMessage());
  }
  return result;
  }

}

作者 east

年度归档2020