`
free_bird816
  • 浏览: 205878 次
  • 性别: Icon_minigender_1
  • 来自: 济南
社区版块
存档分类
最新评论

http客户端 转

    博客分类:
  • java
阅读更多
import java.net.*;   
  
import java.io.*;   
  
import java.util.Properties;   
  
import java.util.Enumeration;   
  
  
/**  
 
 Http客户端程序已集成在Java语言中,可以通过URLConnection类调用。遗憾的  
 
 是,由于SUN没有公布Http客户程序的源码,它实现的细节仍是一个谜。本文根据HTTP  
 
 协议规范,用Java.net.Socket类实现一个HTTP协议客户端程序.  
 
 
 <pre>  
 
 
 1.Socket类:  
 
 了解TCP/IP协议集通信的读者知道,协议间的通信是通过Socket完成的。在  
 
 Java.net包中,Socket类就是对Socket的具体实现。它通过连接到主机后,返回一个  
 
 I/O流,实现协议间的信息交换。  
 
 
 2 . HTTP协议  
 
 HTTP协议同其它TCP/IP协议集中的协议一样,是遵循客户/服务器模型工作的。客  
 
 户端发往服务端的信息格式如下:  
 
 ------------------------------  
 
 请求方法 URL HTTP协议的版本号  
 
 提交的元信息  
 
 **空行**  
 
 实体  
 
 ------------------------------  
 
 请求方法是对这次连接工作的说明,目前HTTP协议已经发展到1.1版,它包括GET、  
 
 HEAD、POST、DELETE、OPTIONS、TRACE、PUT七种。元信息是关于当前请求的信息。通  
 
 过分析元信息,可以检查实体数据是否完整,接收过程是否出错,类型是否匹配等。元  
 
 信息的引入使HTTP协议通信更加稳妥可靠。实体是请求的具体内容。  
 
 将上述报文发往Web服务器,如果成功,应答格式如下:  
 
 --------------------------------  
 
 HTTP协议的版本号 应答状态码 应答状态码说明  
 
 接收的元信息  
 
 **空行**  
 
 实体  
 
 --------------------------------  
 
 以上报文发向客户端,并且接收成功,彼此间关闭连接,完成一次握手。  
 
 下面用最常用的GET方法,来说明具体的报文应用  
 
 ----------------------------------  
 
 GET http://www.youhost.com HTTP/1.0  
 
 accept: www/source; text/html; image/gif; image/jpeg; */*  
 
 User_Agent: myAgent  
 
 **空行**  
 
 -----------------------------------  
 
 这个报文是向www.youhost.com主机请求一个缺省HTML文档。客户端HTTP协议版本  
 
 号是1.0版,元信息包括可接收的文件格式,用户代理,每一段之间用回车换行符分  
 
 隔,最后以一个空行结束。发向服务器后,如果执行过程正常,服务器返回以下代码:  
 
 ------------------------------------  
 
 HTTP/1.1 200 OK  
 
 Date: Tue, 14 Sep 1999 02:19:57 GMT  
 
 Server: Apache/1.2.6  
 
 Connection: close  
 
 Content-Type: text/html  
 
 **空行**  
 
 <html><head>...</head><body>...</body></html>  
 
 ------------------------------------  
 
 HTTP/1.1表示这个HTTP服务器是1.1版,200是服务器对客户请求的应答状态码,OK  
 
 是对应答状态码的解释,之后是这个文档的元信息和文档正文。(相关应答状态码和元  
 
 信息的解释请参阅Inetrnet标准草案:RFC2616)。  
 
 
 注: 程序中只实现GET、HEAD、POST三种方法。其他几种因不常使用,暂且忽略。  
 
 
 </pre>  
 
 
 */  
  
public class Http{   
  
    protected Socket client;   
  
    protected BufferedOutputStream sender;   
  
    protected BufferedInputStream receiver;   
  
    protected ByteArrayInputStream byteStream;   
  
    protected URL target;   
  
    private int responseCode = -1;   
  
    private String responseMessage = "";   
  
    private String serverVersion = "";   
  
    private Properties header = new Properties();   
  
  
    public Http(){}   
  
  
    public Http(String url){   
  
        GET(url);   
  
    }   
  
  
    /* GET方法根据URL,会请求文件、数据库查询结果、程序运行结果等多种内容 */  
  
    public void GET(String url){   
  
        try{   
  
            checkHTTP(url);   
  
            openServer(target.getHost(),target.getPort());   
  
            String cmd = "GET " + getURLFormat(target) + " HTTP/1.0\r\n" +   
  
            getBaseHeads() + "\r\n";   
  
            sendMessage(cmd);   
  
            receiveMessage();   
  
        }   
  
        catch(ProtocolException p){   
  
            p.printStackTrace();   
  
            return;   
  
        }   
  
        catch(UnknownHostException e){   
  
            e.printStackTrace();   
  
            return;   
  
        }   
  
        catch(IOException i){   
  
            i.printStackTrace();   
  
            return;   
  
        }   
  
    }   
  
  
    /*  
 
     * HEAD方法只请求URL的元信息,不包括URL本身。若怀疑本机和服务器上的  
 
     * 文件相同,用这个方法检查最快捷有效。  
 
     */  
  
    public void HEAD(String url){   
  
        try{   
  
            checkHTTP(url);   
  
            openServer(target.getHost(),target.getPort());   
  
            String cmd = "HEAD " + getURLFormat(target) + " HTTP/1.0\r\n" +   
  
            getBaseHeads() + "\r\n";   
  
            sendMessage(cmd);   
  
            receiveMessage();   
  
        }   
  
        catch(ProtocolException p){   
  
            p.printStackTrace();   
  
            return;   
  
        }   
  
        catch(UnknownHostException e){   
  
            e.printStackTrace();   
  
            return;   
  
        }   
  
        catch(IOException i){   
  
            i.printStackTrace();   
  
            return;   
  
        }   
  
    }   
  
  
    /*  
 
     * POST方法是向服务器传送数据,以便服务器做出相应的处理。例如网页上常用的  
 
     * 提交表格。  
 
     */  
  
    public void POST(String url,String content){   
  
        try{   
  
            checkHTTP(url);   
  
            openServer(target.getHost(),target.getPort());   
  
            String cmd = "POST " + getURLFormat(target) + " HTTP/1.0\r\n" +   
  
            getBaseHeads();   
  
            cmd += "Content-type: application/x-www-form-urlencoded\r\n";   
  
            cmd += "Content-length: " + content.length() + "\r\n\r\n";   
  
            cmd += content + "\r\n";   
  
            sendMessage(cmd);   
  
            receiveMessage();   
  
        }   
  
        catch(ProtocolException p){   
  
            p.printStackTrace();   
  
            return ;   
  
        }   
  
        catch(UnknownHostException e){   
  
            e.printStackTrace();   
  
            return ;   
  
        }   
  
        catch(IOException i){   
  
            i.printStackTrace();   
  
            return ;   
  
        }   
  
  
    }   
  
  
    protected void checkHTTP(String url) throws ProtocolException{   
  
        try{   
  
            URL target = new URL(url);   
  
            if(target == null ||   
  
               !target.getProtocol().toUpperCase().equals("HTTP")){   
  
                throw new ProtocolException("这不是HTTP协议");   
  
            }   
  
            this.target = target;   
  
        }   
  
        catch(MalformedURLException m){   
  
            throw new ProtocolException("协议格式错误");   
  
        }   
  
    }   
  
  
    /*  
 
     * 与Web服务器连接。若找不到Web服务器,InetAddress会引发UnknownHostException  
 
     * 异常。若Socket连接失败,会引发IOException异常。  
 
     */  
  
    protected void openServer(String host,int port) throws UnknownHostException,   
  
    IOException{   
  
        header.clear();   
  
        responseMessage = "";   
  
        responseCode = -1;   
  
  
        if(client != null){   
  
            closeServer();   
  
        }   
  
        if(byteStream != null){   
  
            byteStream.close();   
  
            byteStream = null;   
  
        }   
  
  
        InetAddress address = InetAddress.getByName(host);   
  
        client = new Socket(address,port == -1 ? 80 : port);   
  
        client.setSoTimeout(5000);   
  
        sender = new BufferedOutputStream(client.getOutputStream());   
  
        receiver = new BufferedInputStream(client.getInputStream());   
  
    }   
  
  
    /* 关闭与Web服务器的连接 */  
  
    protected void closeServer() throws IOException{   
  
        if(client == null){   
  
            return;   
  
        }   
  
        try{   
  
            client.close();   
  
            sender.close();   
  
            receiver.close();   
  
        }   
  
        catch(IOException i){   
  
            throw i;   
  
        }   
  
  
        client = null;   
  
        sender = null;   
  
        receiver = null;   
  
    }   
  
  
    protected String getURLFormat(URL target){   
  
        String spec = "http://" + target.getHost();   
  
        if(target.getPort() != -1){   
  
            spec += ":" + target.getPort();   
  
        }   
  
  
        return spec += target.getFile();   
  
    }   
  
  
    /* 向Web服务器传送数据 */  
  
    protected void sendMessage(String data) throws IOException{   
  
        sender.write(data.getBytes(),0,data.length());   
  
        sender.flush();   
  
    }   
  
  
    /* 接收来自Web服务器的数据 */  
  
    protected void receiveMessage() throws IOException{   
  
        byte data[] = new byte[1024];   
  
        int count = 0;   
  
        int word = -1;   
  
        // 解析第一行   
  
        while( (word = receiver.read()) != -1){   
  
            if(word == '\r' || word == '\n'){   
  
                word = receiver.read();   
  
                if(word == '\n') {   
  
                    word = receiver.read();   
  
                }   
  
                break;   
  
            }   
  
            if(count == data.length) {   
  
                data = addCapacity(data);   
  
            }   
  
            data[count++] = (byte) word;   
  
        }   
  
        String message = new String(data,0,count);   
  
        int mark = message.indexOf(32);   
  
        serverVersion= message.substring(0,mark);   
  
        while(mark < message.length() && message.charAt(mark + 1) == 32) {   
  
            mark++;   
  
        }   
  
        responseCode = Integer.parseInt(message.substring(mark + 1,mark += 4));   
  
        responseMessage = message.substring(mark,message.length()).trim();   
  
  
        // 应答状态码和处理请读者添加   
  
        switch(responseCode){   
  
            case 400:   
  
                throw new IOException("错误请求");   
  
            case 404:   
  
                throw new FileNotFoundException(getURLFormat(target));   
  
            case 503:   
  
                throw new IOException("服务器不可用");   
  
        }   
  
        if(word == -1){   
  
            throw new ProtocolException("信息接收异常终止");   
  
        }   
  
        int symbol = -1;   
  
        count = 0;   
  
        // 解析元信息   
  
        while(word != '\r' && word != '\n' && word > -1){   
  
            if(word == '\t') {   
  
                word = 32;   
  
            }   
  
            if(count == data.length) {   
  
                data = addCapacity(data);   
  
            }   
  
            data[count++] = (byte) word;   
  
            parseLine:{   
  
                while( (symbol = receiver.read()) > -1){   
  
                    switch(symbol){   
  
                        case '\t':   
  
                            symbol = 32;   
  
                            break;   
  
                        case '\r':   
  
                        case '\n':   
  
                            word = receiver.read();   
  
                            if(symbol == '\r' && word == '\n'){   
  
                                word = receiver.read();   
  
                                if(word == '\r') {   
  
                                    word = receiver.read();   
  
                                }   
  
                            }   
  
                            if(word == '\r' || word == '\n' || word > 32){   
  
                                break parseLine;   
  
                            }   
  
                            symbol = 32;   
  
                            break;   
  
                    }   
  
                    if(count == data.length) {   
  
                        data = addCapacity(data);   
  
                    }   
  
                    data[count++] = (byte) symbol;   
  
                }   
  
                word = -1;   
  
            }   
  
            message = new String(data,0,count);   
  
            mark = message.indexOf(':');   
  
            String key = null;   
  
            if(mark > 0) {   
  
                key = message.substring(0,mark);   
  
            }   
  
            mark++;   
  
            while(mark < message.length() && message.charAt(mark) <= 32) {   
  
                mark++;   
  
            }   
  
            String value = message.substring(mark,message.length());   
  
            header.put(key,value);   
  
            count = 0;   
  
        }   
  
        // 获得正文数据   
  
        while( (word = receiver.read()) != -1){   
  
            if(count == data.length) {   
  
                data = addCapacity(data);   
  
            }   
  
            data[count++] = (byte) word;   
  
        }   
  
        if(count > 0) {   
  
            byteStream = new ByteArrayInputStream(data,0,count);   
  
        }   
  
        data = null;   
  
        closeServer();   
  
    }   
  
  
    public String getResponseMessage(){   
  
        return responseMessage;   
  
    }   
  
  
    public int getResponseCode(){   
  
        return responseCode;   
  
    }   
  
  
    public String getServerVersion(){   
  
        return serverVersion;   
  
    }   
  
  
    public InputStream getInputStream(){   
  
        return byteStream;   
  
    }   
  
  
    public synchronized String getHeaderKey(int i){   
  
        if(i >= header.size()){   
  
            return null;   
  
        }   
  
        Enumeration enumss = header.propertyNames();   
  
        String key = null;   
  
        for(int j = 0; j <= i; j++){   
  
            key = (String) enumss.nextElement();   
  
        }   
  
        return key;   
  
    }   
  
  
    public synchronized String getHeaderValue(int i){   
  
        if(i >= header.size()){   
  
            return null;   
  
        }   
  
        return header.getProperty(getHeaderKey(i));   
  
    }   
  
  
    public synchronized String getHeaderValue(String key){   
  
        return header.getProperty(key);   
  
    }   
  
  
    protected String getBaseHeads(){   
  
        String inf = "User-Agent: ZealHttp/1.0\r\nAccept: www/source; text/html; image/gif; */*\r\n";   
  
        return inf;   
  
    }   
  
  
    private byte[] addCapacity(byte rece[]){   
  
        byte temp[] = new byte[rece.length + 1024];   
  
        System.arraycopy(rece,0,temp,0,rece.length);   
  
        return temp;   
  
    }   
  
}  

 

分享到:
评论

相关推荐

    HTTP客户端,HTTP服务器,RMI客户端和服务器

    本实验课主要涵盖了HTTP客户端与服务器以及RMI客户端和服务器的使用,旨在帮助学习者理解网络通信的基本原理和实现方式。 首先,我们来详细探讨HTTP(超文本传输协议)。HTTP是互联网上应用最广泛的一种网络协议,...

    Vuejs的HTTP客户端

    Vue.js的HTTP客户端是开发者在构建前端应用时与服务器进行数据交互的重要工具。Vue.js官方推荐使用axios库作为HTTP客户端,但在此之前,Vue.js社区曾广泛使用vue-resource,这是一个专门为Vue.js设计的轻量级HTTP库...

    C++实现http客户端连接服务端及客户端json数据的解析

    此代码用c++实现了http客户端的编写,其中包括了多字节转utf8(已在ExecuteRequest函数中实现,不用再引用所给的编码转换),get和post两种请求方式,后面有json数据的解析以及实现,详情可去博客...

    http客户端组件

    在IT行业中,HTTP客户端组件是实现网络通信的关键部分,它允许程序通过HTTP协议与服务器进行交互,执行诸如发送GET和POST请求、上传和下载文件等操作。以下是对这些知识点的详细解释: 首先,`HttpClient.cpp`是...

    Http.rar_cookies_http post get_http post图片_post vc_vc http客户端

    ...能自动提取和保存返回的cookies,在发送数据包时能自动添加保存好的cookies。能自动识别网站的编码,在接收数据后,自动将编码转换。在发送数据时,自动转换为网站需要...使用此类,能方便地开发HTTP客户端模拟工具。

    Qt http server client 服务器客户端源代码

    接下来,我们转向Qt中的HTTP客户端(qhttpclient)。QHttpClient是Qt网络模块的一部分,用于发起HTTP请求并与服务器进行通信。关键特性包括: 1. **请求构造**:开发者可以轻松构建GET、POST、PUT、DELETE等各种...

    具有HTTP请求接口的OPC-DA客户端

    标题中的“具有HTTP请求接口的OPC-DA客户端”指的是一个软件工具,它允许用户通过HTTP(超文本传输协议)接口与OPC DA(OLE for Process Control - Data Access)服务器进行交互。OPC DA是工业自动化领域的一个标准...

    .NET/C#文字转语音文件并客户端播放

    服务端生成语音文件后,我们可以通过HTTP服务或其他通信方式将其发送到客户端。在客户端,可以使用Web浏览器的HTML5 Audio API或者专门的音频播放库来播放接收到的语音文件。 例如,如果在Web应用中,客户端的HTML...

    Android Http (Json) 服务器端和客户端通信

    ### Android Http (Json) 服务器端和客户端通信详解 在当今移动互联网时代,客户端与服务器之间的数据交换变得至关重要。特别是对于Android应用开发而言,能够高效、安全地与服务器进行通信,是实现应用功能的关键...

    HTTP命令行客户端HTTPPrompt.zip

    HTTPPrompt是一款强大的命令行HTTP客户端工具,它提供了一个交互式且功能丰富的环境,方便开发者测试、调试和操作HTTP服务。这个工具是基于两个知名的开源库——HTTPie(一个现代化的、用户友好的命令行HTTP客户端)...

    C# http方式文件上传客户端

    8. **异常处理与资源释放**:确保在完成请求后释放所有打开的资源,如文件流和HTTP客户端。 ```csharp fileStream.Dispose(); httpClient.Dispose(); ``` 以上就是使用C#实现HTTP文件上传客户端的基本步骤。根据...

    一个基于接口和注解的Java HTTP客户端.docx

    ### 基于接口和注解的Java HTTP客户端——easy-http #### 一、概述 在现代软件开发中,特别是微服务架构下,HTTP客户端扮演着至关重要的角色。它们不仅负责与外部系统通信,还直接影响到应用的性能、可维护性和可...

    Android Http客户端源码.rar

    在Android开发中,HTTP客户端是应用与服务器进行数据交互的重要组成部分。这个压缩包"Android Http客户端源码.rar"很可能包含了实现Android平台上的HTTP请求的源代码。以下是对Android HTTP客户端相关知识点的详细...

    STM32 LWIP TCP客户端访问WEB实验(http格式)

    本DEMO为工作项目的部分内容,STM32f107 作为TCP客户端访问WEB站点 ,使用http/1.1格式上传并获取WEB数据。附件WORD文档为项目的接口格式说明。 应用层:HTTP数据格式解析 MAX层:stm32f107 传输层:LWIP协议栈

    Java灵活易用自封装http客户端

    在Java开发中,高效、灵活的HTTP客户端库是不可或缺的一部分,尤其在进行Web服务调用或者API集成时。本主题将深入探讨如何自封装一个Java HTTP客户端,使其变得简单易用,仅需三行代码就能完成请求并处理响应。这个...

    webservice客户端生成工具

    客户端生成工具是实现Web服务交互的关键组件,它能够帮助开发者自动创建与WebService接口进行通信的客户端代码,大大简化了开发流程。本文将详细介绍关于Web服务客户端生成工具的相关知识点。 1. **Web服务标准与...

    短信发送客户端软件

    这些API可能支持HTTP、HTTPS、SOAP或RESTful等不同的通信协议,提供发送短信、接收短信、查询状态等功能。 4. **用户界面设计**:客户端软件应有一个用户友好的界面,使用户能方便地输入短信内容、选择收件人、查看...

    hbase用于查询客户端工具

    2. **HBase REST Gateway**:REST(Representational State Transfer)接口使得非Java客户端能以HTTP协议与HBase通信,使用JSON格式交换数据。这使得Web应用、Python、Ruby等其他语言的客户端可以轻松地与HBase集成...

    HTTP调试客户端

    HTTP调试客户端是一款强大的工具,主要用于帮助开发者和网络技术人员分析、调试和优化HTTP协议通信。它允许用户查看、编辑和发送HTTP请求,同时接收并解析服务器返回的响应,从而深入理解网络应用的工作原理。 1. *...

    php实现websocket客户端

    WebSocket是一种在客户端与服务器之间建立长连接的协议,它提供了双向通信的能力,即服务器和客户端都可以主动发送数据。在Web开发中,WebSocket极大地优化了实时性需求的应用,比如在线聊天、股票报价、游戏等场景...

Global site tag (gtag.js) - Google Analytics