H
hekinami
Unregistered / Unconfirmed
GUEST, unregistred user!
要求是用多线程写一个Web服务器，即是要求其能同时响应几个客户端对它提出的请求，并向客户端发送网页。本来Web服务器的实现倒是不难，但我对JAVA下的多线程不是很熟，请各位给个例子我，不胜感激。请写成应用程序，小程序就不要了。再次感谢。
7
7syw
Unregistered / Unconfirmed
GUEST, unregistred user!
/**
* Created by IntelliJ IDEA.
* User: administrator
* Date: Aug 14, 2003
* Time: 10:33:24 AM
* To change this template use Options | File Templates.
*/
import java.io.*;
import java.net.*;
public class WebServer {
public static void main(String args[]) {
int i=1, PORT=8080;
ServerSocket server=null;
Socket client=null;
try
{
server=new ServerSocket(PORT);
System.out.println("Web Server is listening on port "+server.getLocalPort());
for (;
{
client=server.accept();
//接受客户机的连接请求
new ConnectionThread(client,i).start();
i++;
}
}
catch (Exception e) {System.out.println(e);}
}
}
/* ConnnectionThread类完成与一个Web浏览器的通信 */
class ConnectionThread extends Thread {
Socket client;
//连接Web浏览器的socket字
int counter;
//计数器
String webRootPath="c://temp//";
///你的web服务器的主目录
public ConnectionThread(Socket cl,int c) {
client=cl;
counter=c;
}
public void run() //线程体
{
try {
String destIP=client.getInetAddress().toString();
//客户机IP地址
int destport=client.getPort();
//客户机端口号
System.out.println("Connection "+counter+":connected to "+destIP+" on port "+destport+".");
PrintStream outstream=new PrintStream(client.getOutputStream());
DataInputStream instream=new DataInputStream(client.getInputStream());
String inline=instream.readLine();
//读取Web浏览器提交的请求信息
System.out.println("Received:"+inline);
if (getrequest(inline)) { //如果是GET请求
String filename=getfilename(inline);
System.out.println(filename);
filename=webRootPath+filename;
File file=new File(filename);
if (file.exists()) { //若文件存在，则将文件送给Web浏览器
System.out.println(filename+" requested.");
outstream.println("HTTP/1.0 200 OK");
outstream.println("MIME_version:1.0");
outstream.println("Content_Type:text/html");
int len=(int)file.length();
outstream.println("Content_Length:"+len);
outstream.println("");
sendfile(outstream,file);
//发送文件
outstream.flush();
} else
{ //文件不存在时
String notfound="<html><head><title>Not Found</title></head>"+
"<body><h1>Error 404-file not found</h1></body></html>";
//////
outstream.println("HTTP/1.0 404 no found");
outstream.println("Content_Type:text/html");
outstream.println("Content_Length:"+notfound.length()+2);
////
// outstream.println("HTTP/1.0 200 OK");
// outstream.println("MIME_version:1.0");
// outstream.println("Content_Type:text/html");
// int len=(int)file.length();
// outstream.println("Content_Length:"+len);
///
//outstream.println(notfound);
byte[] s=notfound.getBytes();
System.out.println(notfound);
outstream.write(s,0,s.length);
sendfile(outstream,new File(webRootPath+"//err.html"));
//发送文件
outstream.flush();
}
}
long m1=1;
while (m1<11100000) {m1++;} //延时
client.close();
} catch (IOException e) {
System.out.println("Exception:"+e);
}
}
/* 获取请求类型是否为“GET” */
boolean getrequest(String s) {
if (s.length()>0)
{
if (s.substring(0,3).equalsIgnoreCase("GET")) return true;
}
return false;
}
/* 获取要访问的文件名 */
String getfilename(String s) {
String f=s.substring(s.indexOf(' ')+1);
f=f.substring(0,f.indexOf(' '));
try {
if (f.charAt(0)=='/')
f=f.substring(1);
} catch (StringIndexOutOfBoundsException e) {
System.out.println("Exception:"+e);
}
if (f.equals("")) f="index.html";
return f;
}
/*把指定文件发送给Web浏览器 */
void sendfile(PrintStream outs,File file) {
try
{
DataInputStream in=new DataInputStream(new FileInputStream(file));
int len=(int)file.length();
byte buf[]=new byte[len];
in.readFully(buf);
outs.write(buf,0,len);
outs.flush();
in.close();
}
catch (Exception e)
{
System.out.println("Error retrieving file.");
System.exit(1);
}
}
}
* Created by IntelliJ IDEA.
* User: administrator
* Date: Aug 14, 2003
* Time: 10:33:24 AM
* To change this template use Options | File Templates.
*/
import java.io.*;
import java.net.*;
public class WebServer {
public static void main(String args[]) {
int i=1, PORT=8080;
ServerSocket server=null;
Socket client=null;
try
{
server=new ServerSocket(PORT);
System.out.println("Web Server is listening on port "+server.getLocalPort());
for (;
{client=server.accept();
//接受客户机的连接请求
new ConnectionThread(client,i).start();
i++;
}
}
catch (Exception e) {System.out.println(e);}
}
}
/* ConnnectionThread类完成与一个Web浏览器的通信 */
class ConnectionThread extends Thread {
Socket client;
//连接Web浏览器的socket字
int counter;
//计数器
String webRootPath="c://temp//";
///你的web服务器的主目录
public ConnectionThread(Socket cl,int c) {
client=cl;
counter=c;
}
public void run() //线程体
{
try {
String destIP=client.getInetAddress().toString();
//客户机IP地址
int destport=client.getPort();
//客户机端口号
System.out.println("Connection "+counter+":connected to "+destIP+" on port "+destport+".");
PrintStream outstream=new PrintStream(client.getOutputStream());
DataInputStream instream=new DataInputStream(client.getInputStream());
String inline=instream.readLine();
//读取Web浏览器提交的请求信息
System.out.println("Received:"+inline);
if (getrequest(inline)) { //如果是GET请求
String filename=getfilename(inline);
System.out.println(filename);
filename=webRootPath+filename;
File file=new File(filename);
if (file.exists()) { //若文件存在，则将文件送给Web浏览器
System.out.println(filename+" requested.");
outstream.println("HTTP/1.0 200 OK");
outstream.println("MIME_version:1.0");
outstream.println("Content_Type:text/html");
int len=(int)file.length();
outstream.println("Content_Length:"+len);
outstream.println("");
sendfile(outstream,file);
//发送文件
outstream.flush();
} else
{ //文件不存在时
String notfound="<html><head><title>Not Found</title></head>"+
"<body><h1>Error 404-file not found</h1></body></html>";
//////
outstream.println("HTTP/1.0 404 no found");
outstream.println("Content_Type:text/html");
outstream.println("Content_Length:"+notfound.length()+2);
////
// outstream.println("HTTP/1.0 200 OK");
// outstream.println("MIME_version:1.0");
// outstream.println("Content_Type:text/html");
// int len=(int)file.length();
// outstream.println("Content_Length:"+len);
///
//outstream.println(notfound);
byte[] s=notfound.getBytes();
System.out.println(notfound);
outstream.write(s,0,s.length);
sendfile(outstream,new File(webRootPath+"//err.html"));
//发送文件
outstream.flush();
}
}
long m1=1;
while (m1<11100000) {m1++;} //延时
client.close();
} catch (IOException e) {
System.out.println("Exception:"+e);
}
}
/* 获取请求类型是否为“GET” */
boolean getrequest(String s) {
if (s.length()>0)
{
if (s.substring(0,3).equalsIgnoreCase("GET")) return true;
}
return false;
}
/* 获取要访问的文件名 */
String getfilename(String s) {
String f=s.substring(s.indexOf(' ')+1);
f=f.substring(0,f.indexOf(' '));
try {
if (f.charAt(0)=='/')
f=f.substring(1);
} catch (StringIndexOutOfBoundsException e) {
System.out.println("Exception:"+e);
}
if (f.equals("")) f="index.html";
return f;
}
/*把指定文件发送给Web浏览器 */
void sendfile(PrintStream outs,File file) {
try
{
DataInputStream in=new DataInputStream(new FileInputStream(file));
int len=(int)file.length();
byte buf[]=new byte[len];
in.readFully(buf);
outs.write(buf,0,len);
outs.flush();
in.close();
}
catch (Exception e)
{
System.out.println("Error retrieving file.");
System.exit(1);
}
}
}
