一、超文本传输协议及HTTP包
HTTP协议用于在Internet上发送和接收消息。HTTP协议是一种请求-应答式的协议——客户端发送一个请求，服务器返回该请求的应答，所有的请求与应答都是HTTP包。HTTP协议使用可靠的TCP连接，默认端口是80。HTTP的第一个版本是HTTP/0.9，后来发展到了HTTP/1.0，现在最新的版本是HTTP/1.1。HTTP/1.1由RFC 2616 定义。
在HTTP中，Client/Server之间的会话总是由客户端通过建立连接和发送HTTP请求包初始化，服务器不会主动联系客户端或要求与客户端建立连接。浏览器和服务器都可以随时中断连接，例如，在浏览网页时你可以随时点击“停止”按钮中断当前的文件下载过程，关闭与Web服务器的HTTP连接。
1 HTTP请求包
HTTP请求包(GET、POST等请求方法)由三个部分构成，分别是：方法-URI-协议/版本，请求头，请求正文。下面是一个HTTP请求包(GET)的例子：
Socket socket = new Socket("127.0.0.1", 8080);
OutputStream os = socket.getOutputStream();
InputStream ins = socket.getInputStream();
StringBuffer sb=new StringBuffer();
sb.append("POST /index.jsp HTTP/1.1\r\n");//注意\r\n为回车换行
sb.append("Accept-Language: zh-cn\r\n");
sb.append("Connection: Keep-Alive\r\n");
sb.append("Host: 192.168.0.106\r\n");
sb.append("Content-Length: 37\r\n");
sb.append("\r\n");
sb.append("userName=new_andy&password=new_andy\r\n");
sb.append("\r\n");
//向Web服务器发送一个HTTP请求包
os.write(sb.toString().getBytes());
os.close();
请求包的第一行是方法-URI-协议/版本：
GET就是请求方法，根据HTTP标准，HTTP请求可以使用多种请求方法。HTTP 1.1支持七种请求方法：GET、POST、HEAD、OPTIONS、PUT、DELETE和TRACE等，常用的为请求方法是GET和POST。
/index.jsp表示URI。URI指定了要访问的网络资源。
HTTP/1.1是协议和协议的版本。
最后一行userName=new_andy&password=new_andy为正文，正文与HTTP头部有一个空行(\r\n)分隔。这里需要说明的一点，其中Content-Length说明正文的长度，有的正文长度没有在头部说明，只是标明Transfer-Encoding: chunked。关于chunked类型的长度计算方法，见RFC 1626。
请求包的头部还会包含许多有关客户端环境和请求正文的有用信息，这里不再描述。
2 HTTP应答包
和HTTP请求包相似，由三个部分构成，分别是：协议-状态代码-描述，应答头，应答正文。下面是一个HTTP应答的例子：
StringBuffer buffer = new StringBuffer();
buffer.append("HTTP/1.1 200 OK\r\n");
buffer.append("Date: Tue, 14 Sep 1999 02:19:57 GMT\r\n");
buffer.append("Server: Apache/1.2.6\r\n");
buffer.append("Connection: close\r\n");
buffer.append("Content-Type: text/html\r\n");
buffer.append("\r\n");
buffer.append("<html><head><title>解读HTTP包示例</title></head><body>test</body></html>\r\n");
//bout.write(buffer.toString().getBytes());
//向Web服务器发送一个HTTP请求包
try {
this.output.write(buffer.toString().getBytes());
this.output.flush();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
HTTP应答包的第一行类似于HTTP请求的第一行，表示所用的协议是HTTP 1.1，服务器处理请求的状态码200。
应答头也和请求头一样包含许多有用的信息，例如服务器类型、日期时间、内容类型和长度等。应答的正文就是服务器返回的HTML页面。应答头和正文之间也用CRLF分隔。
二、Socket类与ServerSocket类
在Java中，通信端点由java.net.Socket类(客户端)或java.net.ServerSocket类(服务器端)表示。应用程序通过端点向网络发送或从网络读取数据。位于两台不同机器上的应用软件通过网络连接发送和接收字节流，从而实现通信。要把HTTP包发送给另一个应用，首先要知道对方的IP地址以及其通信端点的端口号。
Socket类代表的是客户端，它是一个连接远程服务器应用时临时创建的端点。
ServerSocker类代表的是服务器端，它启动后等待来自客户端的连接请求；一旦接收到请求，ServerSocket创建一个Socket实例来处理与该客户端的通信。对于服务器应用，我们不知道客户端应用什么时候会试图连接服务器，服务器必须一直处于等待连接的状态。
下面是ServerSocket提供了四个构造函数，常用的构造函数的的一种形式为：
public ServerSocket(int port, int backLog, InetAddress bindingAddress);
参数：port指定服务器端监听客户端的端口；
backlog为连接请求的最大队列长度，一旦超越这个长度，服务器端点开始拒绝客户端的连接请求。
bindingAddress是一个java.net.InetAddress的实例，指定绑定IP地址。
创建好ServerSocket实例之后，调用它的accept方法，要求它等待传入的连接请求。只有出现了连接请求时，accept方法才会返回，它的返回值是一个Socket类的实例。随后，这个Socket对象就可以用来与客户端应用通信。
Socket类有许多构造函数，常用的为：
public Socket(String host, int port)。参数是主机名称(IP地址或域名)和端口号。
参数host是远程机器的名字或IP地址，port是远程应用的端口号。
成功创建了Socket类的实例之后，我们就可以用它来发送和接收字节流形式的数据，数据一般为HTTP包。
要发送字节流，首先要调用Socket类的getOutputStream方法获得一个java.io.OutputStream对象；要从连接的另一端接收字节流，首先要调用Socket类的getInputStream方法获得一个java.io.InputStream对象。
下面的代码片断创建一个与本地HTTP服务器（127.0.0.1代表本地主机的IP地址）通信的Socket，发送一个HTTP请求包，准备接收服务器的应答。
三、读取HTTP包
以下我自己设计的一个读取HTTP包的类SocketRequest。
package com.eri.sas.sms;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class SocketRequest extends Thread
{ // 从指定的Socket的InputStream中读取数据
private InputStream input;
private OutputStream output;
private Socket msocket =null;
private String uri;
private StringBuffer request = new StringBuffer(); // 用于保存所有内容
private int CONTENT_LENGTH = 0; // 实际包内容数据长
private boolean bePost = false;
private boolean beHttpResponse = false;
private boolean beChucked = false;
private boolean beGet = false;
private byte crlf13 = (byte) 13; // '\r'
private byte crlf10 = (byte) 10; // '\n'
public SocketRequest(InputStream input) {
this.input = input;
}
public SocketRequest(Socket socket) throws IOException {
this.input = socket.getInputStream();
this.output = socket.getOutputStream();
msocket =socket;
}
public void run()
{
ReadData();
//
System.out.println("all content \r\n" + getData());
//
WirteDate();
//
close();
}
public void WirteDate() {
/**
* HTTP/1.1 200 OK
Server: Microsoft-IIS/4.0
Date: Mon, 3 Jan 2005 13:13:33 GMT
Content-Type: text/html
Last-Modified: Mon, 11 Jan 2004 13:23:42 GMT
Content-Length: 90
<html>
<head>
<title>解读HTTP包示例</title></head><body>
Hello WORLD!
</body>
</html>
*/
StringBuffer sb=new StringBuffer();
sb.append("HTTP/1.1 200 OK\r\n");//注意\r\n为回车换行
sb.append("Server: Microsoft-IIS/4.0\r\n");
sb.append("Date: Mon, 3 Jan 2005 13:13:33 GMT\r\n");
sb.append("Content-Type: text/html\r\n");
sb.append("Last-Modified: Mon, 11 Jan 2004 13:23:42 GMT\r\n");
// sb.append("Content-Length: 90\r\n");
sb.append("\r\n");
sb.append("<html>\r\n");
sb.append("<head>\r\n");
sb.append("<title>解读HTTP包示例ss</title></head><body>\r\n");
sb.append("ssssssssssss</body>\r\n");
sb.append("</html>\r\n");
StringBuffer buffer = new StringBuffer();
buffer.append("HTTP/1.1 200 OK\r\n");
buffer.append("Date: Tue, 14 Sep 1999 02:19:57 GMT\r\n");
buffer.append("Server: Apache/1.2.6\r\n");
buffer.append("Connection: close\r\n");
buffer.append("Content-Type: text/html\r\n");
buffer.append("\r\n");
buffer.append("<html><head><title>解读HTTP包示例</title></head><body>test</body></html>\r\n");
//bout.write(buffer.toString().getBytes());
//向Web服务器发送一个HTTP请求包
try {
this.output.write(buffer.toString().getBytes());
this.output.flush();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void ReadData()
{ // 解析 获得InputStream的数据
ReadHeader(); // 头部
if (beChucked) // 为Chucked
{
int ChuckSize = 0;
while ((ChuckSize = getChuckSize()) > 0) // 多个Chucked
{
readLenData(ChuckSize + 2);// 读取定长数据
}
readLenData(2); // 最后的2位
}
if (CONTENT_LENGTH > 0) {
readLenData(CONTENT_LENGTH);// 读取定长数据
}
uri = "";
parseUri(new String(request));
}
private void readLenData(int size) // 读取定长数据
{
int readed = 0; // 已经读取数
try {
int available = 0;// input.available(); //可读数
if (available > (size - readed))
available = size - readed;
while (readed < size) {
while (available == 0) { // 等到有数据可读
available = input.available(); // 可读数
}
if (available > (size - readed))
available = size - readed; // size-readed--剩余数
if (available > 2048)
available = 2048; // size-readed--剩余数
byte[] buffer = new byte[available];
int reading = input.read(buffer);
request = request.append(new String(buffer, 0, reading)); // byte数组相加
readed += reading; // 已读字符
}
} catch (IOException e) {
System.out.println("Read readLenData Error!");
}
}
private void ReadHeader() // 读取头部 并获得大小
{
byte[] crlf = new byte[1];
int crlfNum = 0; // 已经连接的回车换行数 crlfNum=4为头部结束
try {
while (input.read(crlf) != -1) // 读取头部
{
if (crlf[0] == crlf13 || crlf[0] == crlf10) {
crlfNum++;
} else {
crlfNum = 0;
} // 不是则清
request = request.append(new String(crlf, 0, 1)); // byte数组相加
if (crlfNum == 4)
break;
}
} catch (IOException e) {
System.out.println("Read Http Header Error!");
return;
}
String tempStr = (new String(request)).toUpperCase();
// 这里我只处理了GET与POST方法
String strMethod = tempStr.substring(0, 4);
if (strMethod.equals("GET ")) // 前
{
beGet = true;
} else if (strMethod.equals("POST")) {
bePost = true;
getContentlen_Chucked(tempStr);
} else {
System.out.println("不支持的HTTP包类型");
} // 其它的其它类型 暂不支持
}
private void getContentlen_Chucked(String tempStr) // 获得长度 CONTENT-LENGTH 或
// 是否为CHUNKED型
{
String ss1 = "CONTENT-LENGTH:";
String ss2 = new String("TRANSFER-ENCODING: CHUNKED");
int clIndex = tempStr.indexOf(ss1);
int chuckIndex = tempStr.indexOf(ss2); // 为CHUNKED型
byte requst[] = tempStr.getBytes();
if (clIndex != -1) { // 从clIndex+1起至\r\n
StringBuffer sb = new StringBuffer();
for (int i = (clIndex + 16);; i++) {
if (requst[i] != (byte) 13 && requst[i] != (byte) 10) {
sb.append((char) requst[i]);
} else
break;
}
CONTENT_LENGTH = Integer.parseInt(sb.toString()); // 正式的HTML文件的大小
// System.out.println("CONTENT_LENGTH== "+CONTENT_LENGTH);
}
if (chuckIndex != -1)
beChucked = true;
}
private int getChuckSize() // Chuck大小
{
byte[] crlf = new byte[1];
StringBuffer sb1 = new StringBuffer();
int crlfNum = 0; // 已经连接的回车换行数 crlfNum=4为头部结束
try {
while (input.read(crlf) != -1) // 读取头部
{
if (crlf[0] == crlf13 || crlf[0] == crlf10) {
crlfNum++;
} else {
crlfNum = 0;
} // 不是则清
sb1.append((char) crlf[0]);
request = request.append(new String(crlf, 0, 1)); // byte数组相加
if (crlfNum == 2)
break;
}
} catch (IOException e) {
System.out.println("Read Http Package Error!");
return 0;
}
return Integer.parseInt((sb1.toString()).trim(), 16); // 16进控制
}
// 通过此来进行过滤，是否为发至目标服务器的HTTP包
private String parseUri(String requestString)
{
int index1, index2;
index1 = requestString.indexOf(' ');
if (index1 != -1) {
index2 = requestString.indexOf(' ', index1 + 1);
if (index2 > index1)
return requestString.substring(index1 + 1, index2);
}
return null;
}
public String getData()
{
return request.toString();
}
/**
* close
*/
public void close() {
try {
if (input != null)
input.close();
if (msocket != null)
msocket.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
HTTP 协议实现的更多相关文章
-
HTTP协议系列(1)
一.为什么学习Http协议 首先明白我们为什么学习HTTP协议,也就是说明白HTTP协议的作用.HTTP协议是用于客户端与服务器之间的通讯.明白了HTTP协议的作用也就知道了为什么要学习H ...
-
重温Http协议--请求报文和响应报文
http协议是位于应用层的协议,我们在日常浏览网页比如在导航网站请求百度首页的时候,会先通过http协议把请求做一个类似于编码的工作,发送给百度的服务器,然后在百度服务器响应请求时把相应的内容再通过h ...
-
协议森林17 我和你的悄悄话 (SSL/TLS协议)
作者:Vamei 出处:http://www.cnblogs.com/vamei 转载请先与我联系. TLS名为传输层安全协议(Transport Layer Protocol),这个协议是一套加密的 ...
-
协议森林16 小美的桌号（DHCP协议）
作者:Vamei 出处:http://www.cnblogs.com/vamei 转载请先与我联系. DHCP协议用于动态的配置电脑的网络相关参数,如主机的IP地址,路由器出口地址.DNS域名服务器地 ...
-
简约之美Jodd-http--深入源码理解http协议
Jodd 是一个开源的 Java 工具集, 包含一些实用的工具类和小型框架.简单,却很强大! jodd-http是一个轻巧的HTTP客户端.现在我们以一个简单的示例从源码层看看是如何实现的? Http ...
-
【JavaScript】javascript中伪协议(javascript:)使用探讨
javascript:这个特殊的协议类型声明了URL的主体是任意的javascript代码,它由javascript的解释器运行. 比如下面这个死链接: <a href="javasc ...
-
SNMP简单网络管理协议
声明:以下内容是学习谌玺老师视频整理出来(http://edu.51cto.com/course/course_id-861.html) SNMP(Simple Network Management ...
-
海鑫智圣：物联网漫谈之MQTT协议
什么是MQTT协议 MQTT(消息队列遥测传输协议)是IBM在1999年专门针对物联网等应用场景来制订的轻量级双向消息传输协议,它主要是为了解决物联网上使用到的设备的互相通信的问题,以及这些设备与后端 ...
-
linux-图形化远程管理协议
远程管理控制方式: RDP(remote desktop protocol)协议: telnet: SSH(Secure Shell): RFB(Remote FrameBuffer)协议(图形化远程 ...
-
RTP与RTCP协议介绍（转载）
RTSP发起/终结流媒体.RTP传输流媒体数据 .RTCP对RTP进行控制,同步.RTP中没有连接的概念,本身并不能为按序传输数据包提供可靠的保证,也不提供流量控制和拥塞控制,这些都由RTCP来负责完 ...
随机推荐
-
codeforces346 Div.2 A.Round House
课间水一水,CCF备战 package com.company.cf346; import java.io.InputStreamReader; import java.util.Scanner; / ...
-
搞懂Path环境变量
path:环境变量 我们平时打开一个应用程序,一般是双击桌面图标或在开始菜单链接,无论是桌面的快捷图标还是菜单链接都包含了应用程序的安装位置信息,打开它们的时候系统会按照这些位置信息找到安装目录然后启 ...
-
css3学习总结6--CSS3字体
使用自己需要的字体 在新的 @font-face 规则中,您必须首先定义字体的名称(比如 myFirstFont),然后指向该字体文件. 如需为 HTML 元素使用字体,请通过 font-family ...
-
161110、彻底征服 Spring AOP 之 实战篇
Spring AOP 实战 看了上面这么多的理论知识, 不知道大家有没有觉得枯燥哈. 不过不要急, 俗话说理论是实践的基础, 对 Spring AOP 有了基本的理论认识后, 我们来看一下下面几个具体 ...
-
如何实现上下左右键盘控制焦点使之落在相邻文本框或下拉框中-Web开发/JavaScript
我用jquery只实现了文本框的移动(暂时上下移动等同于左右移动) $(function () { var cols = 1;//按一下跳几个控件 var obj = $("input[id ...
-
boost::unordered_map 和 std::map 的效率 与 内存比较
例子链接:http://blog.csdn.net/gamecreating/article/details/7698719 结论: unordered_map 查找效率快五倍,插入更快,节省一定内存 ...
-
Linux下VMWare虚拟机的使用技巧
使用技巧: 1.虚拟机安装文件:vm-workstation-full-8.0.3-703057.x86_64.bundle,./vm-workstation-full-8.0.3-703057.x8 ...
-
centos 6.5 安装 nginx+php+mysql
一.准备工作 (1)配置防火墙 1.首先检查iptables服务的状态 [root@woxplife ~]# service iptables status iptables: Firewall is ...
-
SAMBA服务和FTP服务讲解（week3_day1）--技术流ken
samba服务 Smb主要作为网络通信协议; Smb是基于cs架构: 完成Linux与windows之间的共享:linux与linux之间共享用NFS 第一步:安装samba [root@ken ~] ...
-
FJUTOJ-周赛2016-11-25
注:fjutoj基本每周都有一次周赛,欢迎大家都来参加! 网址:http://59.77.139.92/ 或 acm.fjut.edu.cn A题 题意:一年中,每个月有可能亏x 元,有可能赚y 元, ...