java編寫Http服務(wù)器下載工具
這個(gè)工具比較簡(jiǎn)單,用于配合另外一個(gè)工具進(jìn)行文件傳送,廢話少說(shuō),上代碼
import java.net.URL; import java.net.URLConnection; import java.io.File; import java.io.InputStream; import java.io.FileOutputStream; import java.io.FileNotFoundException; import java.io.IOException; import org.apache.commons.io.FileUtils; public class HttpUtil{ private String httppath = ""; public void setHttpPath(String httppath){ this.httppath = httppath; } public String getHttpPath(){ return this.httppath; } public HttpUtil(String httppath){ this.httppath = httppath; } public InputStream getStream(String url){ InputStream inStream = null; try{ URL httpurl = new URL(url); URLConnection conn = httpurl.openConnection(); inStream = conn.getInputStream(); }catch (Exception e){ e.printStackTrace(); return null; } return inStream; } public int downLoad(String url,String localName ,int lines) throws FileNotFoundException, IOException{ FileOutputStream fos = null; InputStream inStream = null; int ret = 0; try{ URL httpurl = new URL(url); URLConnection conn = httpurl.openConnection(); inStream = conn.getInputStream(); fos = new FileOutputStream(localName); byte[] b = new byte[102400]; int j = 0; while(inStream.read(b) != -1 && lines > 0){ for(int i = j; i < b.length; i++){ if(b[i] == '\n'){ fos.write(b, j, i - j + 1); lines--; if(lines <= 0){ break; } j = i + 1; continue; } } } }catch (Exception e){ e.printStackTrace(); ret = -1; }finally { fos.close(); inStream.close(); return ret; } } public static void main(String[] args){ String httppath = ""; int lines = 0; String localName = ""; try{ httppath = args[0]; localName = args[1]; lines = Integer.parseInt(args[2]); }catch (Exception e){ e.printStackTrace(); return; } try{ HttpUtil hu = new HttpUtil(httppath); hu.downLoad(hu.getHttpPath(),localName ,lines); }catch (Exception e){ e.printStackTrace(); } } }
這個(gè)工具實(shí)現(xiàn)了從HTTP服務(wù)器上下載指定行數(shù)的文件,并且不會(huì)因?yàn)榫幋a的問(wèn)題引起下載的文件內(nèi)容亂碼
三個(gè)工具已經(jīng)搞定,下一次就是把這三個(gè)工具結(jié)合起來(lái)將HTTP、FTP的文件轉(zhuǎn)移到HDFS上
以上就是本文所述的全部?jī)?nèi)容了,希望大家能喜歡。
請(qǐng)您花一點(diǎn)時(shí)間將文章分享給您的朋友或者留下評(píng)論。我們將會(huì)由衷感謝您的支持!
- Java使用NioSocket手動(dòng)實(shí)現(xiàn)HTTP服務(wù)器
- java Socket實(shí)現(xiàn)簡(jiǎn)單模擬HTTP服務(wù)器
- Java/Android 實(shí)現(xiàn)簡(jiǎn)單的HTTP服務(wù)器
- Java 如何實(shí)現(xiàn)一個(gè)http服務(wù)器
- Java模擬實(shí)現(xiàn)HTTP服務(wù)器項(xiàng)目實(shí)戰(zhàn)
- Intellij?IDEA?的maven項(xiàng)目通過(guò)Java代碼實(shí)現(xiàn)Jetty的Http服務(wù)器(推薦)
- Java創(chuàng)建非阻塞的HTTP服務(wù)器的實(shí)現(xiàn)
相關(guān)文章
分布式調(diào)度XXL-Job整合Springboot2.X實(shí)戰(zhàn)操作過(guò)程(推薦)
這篇文章主要介紹了分布式調(diào)度XXL-Job整合Springboot2.X實(shí)戰(zhàn)操作,包括定時(shí)任務(wù)的使用場(chǎng)景和常見(jiàn)的定時(shí)任務(wù),通過(guò)本文學(xué)習(xí)幫助大家該選擇哪個(gè)分布式任務(wù)調(diào)度平臺(tái),對(duì)此文感興趣的朋友一起看看吧2022-04-04Java中Comparable和Comparator兩種比較器的區(qū)別詳解
這篇文章主要介紹了Java中Comparable和Comparator兩種比較器的區(qū)別詳解,Comparable接口將比較代碼嵌入自身類中,像Integer、String等這些基本類型的JAVA封裝類都已經(jīng)實(shí)現(xiàn)了Comparable接口,這些類對(duì)象本身就支持和自己比較,需要的朋友可以參考下2023-09-09SpringBoot+RabbitMQ實(shí)現(xiàn)消息可靠傳輸詳解
消息的可靠傳輸是面試必問(wèn)的問(wèn)題之一,保證消息的可靠傳輸主要在生產(chǎn)端開(kāi)啟?comfirm?模式,RabbitMQ?開(kāi)啟持久化,消費(fèi)端關(guān)閉自動(dòng)?ack?模式。本文將詳解SpringBoot整合RabbitMQ如何實(shí)現(xiàn)消息可靠傳輸,需要的可以參考一下2022-05-05Android bdflow數(shù)據(jù)庫(kù)神器的使用
這篇文章主要介紹了Android bdflow數(shù)據(jù)庫(kù)神器的使用,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2018-03-03