/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package httpsocket;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Date;
import java.util.StringTokenizer;
/**
*
* @author Marjorie
*/
class Connection implements Runnable {
private Thread thread;
private Socket socket;
private boolean requeteEstUnPost = false;
private int bodyLength;
public Connection(Socket socket) {
this.socket = socket;
thread = new Thread(this);
thread.start();
}
void sendResponseHeader(PrintStream ps, int len) {
ps.println("HTTP/1.0 200 OK");
ps.println("Date: " + new Date());
ps.println("Server: nfa016Server/1.0");
ps.println("Content-type: text/html");
ps.println("Content-length: " + len);
ps.println("");
}
String litHeaderDeLaRequete() {
String header = "";
try {
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
String line =
br.readLine();
header = line;
StringTokenizer st = new StringTokenizer(line);
requeteEstUnPost = st.nextToken().equals("POST");
System.out.println(line);
while (!line.equals("")) {
line = br.readLine();
header = header + '\n' + line;
System.out.println(line);
st = new StringTokenizer(line);
String ung;
while (st.hasMoreTokens()) {
ung = st.nextToken();
System.out.print(ung + '#');
if (ung.equals("Content-Length:")) {
requeteEstUnPost = true;
System.out.println("on est dedans");
bodyLength = Integer.parseInt(st.nextToken());
}
}
}
} catch (IOException e) {
System.err.println("I/O error " + e);
}
return header;
}
String litBodyDeLaRequete() {
// Dans le cas où la requête est un post, il faut lire la suite
// du header pour avoir par ex les paramètres "postés" par un
// formulaire !
byte[] line = new byte[bodyLength];
try {
for (int i = 0; i < bodyLength; i++) {
line[i] = (byte) socket.getInputStream().read();
}
} catch (IOException e) {
System.err.println("I/O error " + e);
}
return new String(line);
}
public void run() {
try {
System.out.println("connection reçue du client");
// out est le flux sur lequel on va écrire : un socket vers le client !
PrintStream out = new PrintStream(socket.getOutputStream());
// Préparation de la réponse
String reponse =
"<?xml version=\"1.0\" encoding=\"iso-8859-1\"?>\n<!DOCTYPE html PUBLIC \"-//W3C//DTD XHTML 1.0 Strict//EN\" \"http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd\">\n<html xmlns=\"http://www.w3.org/1999/xhtml\" xml:lang=\"fr\">\n<head>\n<title>Requete</title>\n</head>\n<body><p><pre>\n";
reponse = reponse + litHeaderDeLaRequete();
System.out.println("requête est un POST ? : " + requeteEstUnPost);
if (requeteEstUnPost) {
reponse = reponse + '\n' + litBodyDeLaRequete();
}
reponse = reponse + "\n</pre>\n</p>\n</body>\n</html>\n";
// L'en-tête de la réponse part sur le socket, direction le client !
sendResponseHeader(out, reponse.length());
// et le body !
out.print(reponse);
socket.close();
} catch (IOException e) {
System.err.println("I/O error " + e);
}
}
}
HTTP.rar （16个子文件） 
HTTP 
build.xml 4KB manifest.mf 85B src httpsocket Server.java 619B Client.java 2KB Connection.java 4KB nbproject build-impl.xml 56KB private private.xml 211B private.properties 98B project.xml 512B genfiles.properties 475B project.properties 2KB build classes .netbeans_automatic_build 0B .netbeans_update_resources 0B httpsocket Connection.class 4KB Server.class 931B Client.class 2KB资源评论
