导读:
Http客户端程序已集成在Java语言中,可以通过URLConnection类调用。遗憾的是,由于SUN没有公布Http客户程序的源码,它实现的细节仍是一个谜。本文根据HTTP协议规范,用Java.net.Socket类实现一个HTTP协议客户端程序。
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)。
3. HTTP客户端程序:
import java.net.*;
import java.io.*;
import java.util.Properties;
import java.util.Enumeration;
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;
try {
if(client!=null) closeServer();
if(byteStream != null) {
byteStream.close(); byteStream=null;
}
InetAddress address = InetAddress.getByName(host);
client = new Socket(address,port==-1?80:port);
sender = new BufferedOutputStream(client.getOutputStream());
receiver = new BufferedInputStream(client.getInputStream());
}catch(UnknownHostException u) {
throw u;
}catch(IOException i) {
throw i;
}
}
/* 关闭与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-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( mark0) 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 enum = header.propertyNames();
String key = null;
for(int j=0; j key = (String)enum.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: myselfHttp/1.0\r\n"+
"Accept: 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;
}
}
注: 程序中只实现GET、HEAD、POST三种方法。其他几种因不常使用,暂且忽略。
Http客户端程序已集成在Java语言中,可以通过URLConnection类调用。遗憾的是,由于SUN没有公布Http客户程序的源码,它实现的细节仍是一个谜。本文根据HTTP协议规范,用Java.net.Socket类实现一个HTTP协议客户端程序。 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)。 3. HTTP客户端程序: import java.net.*; import java.io.*; import java.util.Properties; import java.util.Enumeration; 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; try { if(client!=null) closeServer(); if(byteStream != null) { byteStream.close(); byteStream=null;} InetAddress address = InetAddress.getByName(host); client = new Socket(address,port==-1?80:port); sender = new BufferedOutputStream(client.getOutputStream()); receiver = new BufferedInputStream(client.getInputStream());}catch(UnknownHostException u) { throw u;}catch(IOException i) { throw i;}}/* 关闭与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-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( mark0) 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 enum = header.propertyNames(); String key = null; for(int j=0; j=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: myselfHttp/1.0\r\n"+"Accept: 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;}} 注: 程序中只实现GET、HEAD、POST三种方法。其他几种因不常使用,暂且忽略。
本文转自
http://www.cn-java.com/www1/?action-viewnews-itemid-2520
分享到:
相关推荐
DAYTIME 协议服务器和客户端程序使用 Socket 套接字实现 知识点 1:DAYTIME 协议的定义和应用 * DAYTIME 协议是一种简单的网络协议,用于获取服务器的当前时间 *DAYTIME 协议通常使用 TCP 或 UDP 协议进行数据传输...
本文将深入解析标题为“HPSocket--UDP传输客户端应用实例”的技术要点,以及如何利用HPsocket框架实现UDP协议的客户端功能。 首先,HPSocket是一款强大的网络通信组件,它提供了丰富的接口,支持多种协议(如TCP、...
在本项目中,"C#使用SuperSocket实现自定义协议实现CS架构服务器和客户端程序设计"),开发者利用C#编程语言以及SuperSocket开源库构建了一套C/S(客户端/服务器)架构的应用。SuperSocket是一个轻量级、高度可扩展的...
Http客户端程序已集成在Java语言中,可以通过URLConnection类调用。遗憾的是,由于SUN没有公布Http客户程序的源码,它实现的细节仍是一个谜...本文根据HTTP协议规范,用Java.net.Socket类实现一个HTTP协议客户端程序。
SuperSocket 提供了一个高效、灵活的平台,使得开发者可以快速构建Socket应用程序,尤其适合需要实现客户端与服务器之间实时通信的场景。通过以上步骤,你将能够成功地搭建一个基础的SuperSocket客户端和服务端,...
Java中提供了Socket类来实现网络通信,Socket类位于java.net包中,提供了多种方法来实现Socket的操作,如connect、send、receive等。Java中的Socket可以分为两种:ServerSocket和Socket。ServerSocket用于建立服务器...
根据给定的文件标题、描述、标签以及部分内容,我们可以总结出以下关于使用Socket...通过以上分析,我们可以看出,使用Socket实现FTP客户端涉及到网络编程、C#语言特性以及对FTP协议的理解,是一项综合性较强的技能。
在Socket编程中,我们通常会使用BufferedReader和PrintWriter类来处理输入输出流,因为它们提供了方便的读写文本数据的方法。例如,服务端可以创建一个BufferedReader来读取客户端的输入,而客户端则可以创建一个...
本篇将详细探讨如何利用C语言的socket套接字实现客户端和服务器端的TCP通信。 TCP(Transmission Control Protocol)是一种面向连接的、可靠的传输协议,它通过三次握手建立连接,并在数据传输过程中进行确认和重传...
综上所述,这个"C++纯SOCKET实现FTP客户端类"项目涵盖了网络编程的基础,FTP协议的应用,以及C++面向对象编程的实践。对于学习网络编程和FTP客户端实现的初学者来说,这是一个很好的起点。通过分析和理解项目中的...
在本文中,我们将深入探讨如何使用C#编程语言通过Socket实现一个简单的聊天系统,使得服务器可以与多个客户端进行通信。Socket在计算机网络编程中扮演着重要角色,它提供了进程间通信(IPC)的能力,允许不同计算机...
通过这种方式,Java Socket编程实现了基于TCP/IP协议的服务端和客户端通信。每个报文的发送和接收都依赖于`InputStream`和`OutputStream`对象,它们分别用于读取和写入网络数据。在实际应用中,可能需要对报文进行更...
标题和描述中的知识点聚焦于如何使用C#的Socket类实现UDP协议通信,这涉及到了UDP协议的基本特性以及在C#中的具体实现方法。以下是对这一主题的深入解析: ### UDP协议简介 用户数据报协议(UDP)是互联网协议族中...
标题中的“NET5 WebApi使用SuperSocket2.0发送到桌面客户端程序源码”表明这是一个基于.NET 5框架的Web API项目,它利用SuperSocket 2.0库来实现在服务器端向桌面客户端推送消息的功能。SuperSocket是一个高度可扩展...
本项目中,我们关注的是一个使用QT库实现的简单Socket5协议客户端。QTCPsocket是Qt库中的一个关键组件,专门用于处理TCP套接字连接,而QThread则是用来实现多线程编程,提升程序性能和响应性。 首先,让我们深入...
### HTTP协议客户端编程 #### 一、概述 HTTP(HyperText Transfer Protocol)是互联网上应用最为广泛的一种网络协议,主要用于从WWW服务器传输超文本到本地浏览器的传输协议。本文主要介绍如何利用Java语言中的`...
本主题聚焦于使用Java进行基于TCP的Socket编程,通过`File_client.java`和`File_server.java`两个文件来实现服务器和客户端之间的数据交换。 首先,TCP Socket编程的基础是Java的`java.net.Socket`和`java.net....
1. 创建Socket实例:使用Socket类的构造函数初始化Socket对象,指定协议类型(如SocketType.Stream代表TCP)。 2. 连接服务器:调用Connect方法,传入服务器的IP地址和端口号。 3. 数据收发:使用Socket的Receive和...
文件列表中的"SocketServer(C#SuperSocket服务器的简易实现)---客户端源程序",暗示了这个压缩包不仅包含了一个简单的SuperSocket服务器实现,还包含了与之配合使用的客户端源代码。客户端源程序通常会包含一个或...