源，流的转化落地

 

 

inputStream（来源文件）/outStream（待写入）是文件的话都已目标文件为参数,这两个都是抽象类实例化的时候需要具体的实现类赋值，

特殊结构的类要包入一般的流，即再包一层

 OutputStream oo = new FileOutputStream(new File("C:\\Users\\yy\\tst\\20271109.zip"));

ZipOutputStream zip = new ZipOutputStream(oo);

byte 是纽带

转化：  input 用来read

string > byte >  byteArrayInputStream (Stream)  (文件可以直接变为stream)/  file >  fileInputStream

 

写入：out 用来写

byte > byteArrayOutStream > 对应的OutputStream     / file > fileOutputStream

 

 

public void steamIput(){

 

       String str = "aaaaaaaaa\nbbbbbbbbbbb";

       InputStream in = new ByteArrayInputStream(str.getBytes());

       BufferedInputStream bips = new BufferedInputStream(in);

       int len;

       byte[] b = new byte[1024];

 

       OutputStream out = null;

 

       try{

          out = new OutPutStream(new File("C:\\Users\\yy\\hb1009\\out.txt"));

  while((len = bips.read(b,0,1024))>-1){

  out.write(b,0,len);

  bips.close();

  out.close();

  

  }

       

       }catch(IOException e){

       

       

       }

 

 

 

 

 

 

}

 

 

 

  @Test

    public void  zip() {

        File file = new File("C:\\Users\\yy\\tst\\20271104.zip");

        byte[] b = null;

        try {

            OutputStream oo = new FileOutputStream(new File("C:\\Users\\yy\\tst\\20271109.zip"));

            ByteArrayOutputStream bos = new ByteArrayOutputStream();

            ZipInputStream zin=   new ZipInputStream(new FileInputStream(file));

            ZipOutputStream zip = new ZipOutputStream(oo);

            ZipEntry entry;

            while ((entry = zin.getNextEntry()) != null) {

                ZipEntry cacheEntry = new ZipEntry(entry.getName());

                if(entry.getSize()==-1l){

                    cacheEntry.setSize(0l);

                }else{

                    cacheEntry.setSize(entry.getSize());

                }

 

                zip.putNextEntry(cacheEntry);

                ByteArrayOutputStream baos = new ByteArrayOutputStream();

                byte[] buf = new byte[1024];

                int num;

                while ((num = zin.read(buf, 0, buf.length)) != -1) {

                    baos.write(buf, 0, num);

                }

                String s = new String(baos.toByteArray(), "UTF-8");

                System.out.println(s);

                zip.write(baos.toByteArray());//zip流生成zip

                zip.closeEntry();

            }

//            b = bos.toByteArray();  传递zip流

//            process(b);

            zip.close();

            bos.close();

        } catch (Exception ex) {

            ex.printStackTrace();

 

        }

    }

 

  private void process (byte[] a) {

        try (ByteArrayInputStream bis = new ByteArrayInputStream(a);

             ZipInputStream zip = new ZipInputStream(bis)) {

            ZipEntry entry;

            while ((entry = zip.getNextEntry()) != null) {

                String fileName = entry.getName();

                try (ByteArrayOutputStream baos = new ByteArrayOutputStream()) {

                    byte[] buf = new byte[1024];

                    int num;

                    while ((num = zip.read(buf, 0, buf.length)) != -1) {

                        baos.write(buf, 0, num);

                    }

                    String s = new String(baos.toByteArray(), "UTF-8");

                    System.out.println(s);

//     processText(baos.toByteArray(), 0, fileName);

                }

            }

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

 

 

字节流需要通过字节字符流桥梁再用字符流读取器转化成字符流，包装在读取器中

 

 BufferedReader in =  new BufferedReader(new InputStreamReader(conn.getInputStream())); 

 

 

public static String sendGet(String url){

              

      HttpUrlCoonnection conn=null;

      BufferedReader in=null;

      Stringbuilder resulStr =null;

      try{

          URL realUrl = new URL(url);

  conn.setConnectionTimeOut(300000);

  conn = realUrl.openConnection();

   in =  new BufferedReader(new InputStreamReader(conn.getInputStream())); 

   String inputLine=null;

   while((inputLine = in.readLine())!=null){

   

       realStr.append(inputLine);

   }

      

      }catch(Exception e){

      

      }finally{

          try{

  if(in !=null){

  in.close();

  

  }

  if(conn!=null){

     conn.close();

  }

  

  }catch(Exception e){

  

  }

      

      

      

      }

 

 

 

}

 

//https的post请求

public static String post(String url, String content){

LOGGER.info("------ HTTP POST request url =>  " + url);

LOGGER.info("------ HTTP POST request params =>  " + content);

String resultStr = null;

try {

SSLContext sc = SSLContext.getInstance("SSL");

sc.init(null, new TrustManager[] { new TrustAnyTrustManager() }, new java.security.SecureRandom());

 

URL console = new URL(url);

HttpsURLConnection conn = (HttpsURLConnection) console.openConnection();

conn.setSSLSocketFactory(sc.getSocketFactory());

conn.setHostnameVerifier(new TrustAnyHostnameVerifier());//解决https需要验证的问题

conn.setRequestProperty("Content-Type", "application/json; charset=utf-8");

conn.setRequestProperty("Content-Length",String.valueOf(content.getBytes().length));

conn.setRequestMethod("POST");

conn.setDoInput(true);   //打开conn的outputStream.write()

conn.setDoOutput(true);  //打开conn的inputStream.read();

conn.setUseCaches(false);

byte[] bytes = content.getBytes("utf-8");

conn.getOutputStream().write(bytes);

conn.getOutputStream().flush(); //要求缓存区的数据立即写入目标对象

conn.getOutputStream().close();

InputStream inputStream = conn.getInputStream();

BufferedReader in = new BufferedReader(new InputStreamReader(inputStream));

String line;

while ((line = in.readLine()) != null) {

resultStr = line;

}

} catch (Exception e) {

LOGGER.error("HTTP POST 异常 : ", e);

}

LOGGER.info("------ HTTP POST response result =>  " + resultStr);

return resultStr;

}

 

/**

     * 功能：Java读取文件的内容

     *

     * @param filePath  路径

     * @param fencoding 编码格式  --  对于字符流才有编码方式

     */

    public static String readFileContent(String filePath, String fencoding) throws Exception{

        StringBuffer sbr = new StringBuffer();

        String encoding = "GBK";

        if (!StringUtils.isBlank(fencoding)) {

            encoding = fencoding;

        }

        File file = new File(filePath);

        if (file.isFile() && file.exists()) { //判断文件是否存在

            InputStreamReader read = new InputStreamReader(

                    new FileInputStream(file), encoding);//考虑到编码格式---对于字符流才有编码方式

            BufferedReader bufferedReader = new BufferedReader(read);

            String lineTxt = null;

            while ((lineTxt = bufferedReader.readLine()) != null) {

                sbr.append(lineTxt);

            }

            read.close();

        } else {

            return null;

        }

        return sbr.toString();

    }

 

 

 

public static boolean isNull(String str) {

boolean b = false ;

if(str==null||str.trim().equals("")) {

b = true ;

}

return b ;

}

 

 

  /**

     * 断空

     */

    public static boolean isBlank(String str) {

        int strLen;

        if (str == null || (strLen = str.length()) == 0) {

            return true;

        }

        for (int i = 0; i < strLen; i++) {

            if ((Character.isWhitespace(str.charAt(i)) == false)) {

                return false;

            }

        }

        return true;

    }