代理服务器只能给客户端发送第一组消息 - Chinaunix

package com.liujiaqi.proxy;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.io.PrintWriter;
public class proxy {
private static File file = new File("proxy.ini"); //配置文件
private static String host = "http://localhost/"; //Web服务器地址
private static int port = 9090;
public static void createFile() { //使用默认参数创建配置文件的函数
try {
file.createNewFile();
PrintWriter writer = new PrintWriter(file);
writer.println("<host>" + host);
writer.println("<port>" + port);
writer.flush();
writer.close();
} catch (IOException e) {
e.printStackTrace();
}
}
public static void readFile() { //读取配置文件中的参数
try {
String temp = null;
BufferedReader reader = new BufferedReader(new FileReader(file));
while ((temp = reader.readLine()) != null) {
switch (temp.substring(temp.indexOf("<") + 1,
temp.lastIndexOf(">"))) {
case "host":
host = temp.substring(temp.lastIndexOf(">") + 1);
break;
case "port":
port = Integer.parseInt(temp.substring(temp
.lastIndexOf(">") + 1));
break;
default:
break;
}
}
reader.close();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
if (file.exists()) { //如果配置文件存在，则从配置文件中载入启动参数
proxy.readFile();
} else { //如果配置文件不存在，则创建配置文件，然后使用默认的参数来启动
proxy.createFile();
}
ProxyServer server = new ProxyServer(host, port);
server.start();
}
}

复制代码

package com.fangzhaoguo.proxy;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ProxyServer {
private static ServerSocket serverSocket;
private boolean isAlive = true;
private String host = null;
private int port = 0;
public ProxyServer(final String host, final int port) {
try {
this.host = host;
this.port = port;
serverSocket = new ServerSocket(this.port);
} catch (IOException e) {
e.printStackTrace();
}
}
public void start() {
ExecutorService service = Executors.newFixedThreadPool(20); //创建线程池
while (isAlive) {
try {
Socket socket = serverSocket.accept();
service.execute(new ProxyConnect(host, socket)); //使用线程池中的线程处理任务
} catch (IOException e) {
e.printStackTrace();
}
}
try {
serverSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
public void close() {
isAlive = false;
}
}

复制代码

create table if not exists Data
(
id int not null auto_increment,
name varchar(100) not null,
data blob not null,
size int not null,
log timestamp not null default now(),
primary key (id)
);

复制代码

create table if not exists Information
(
id int not null auto_increment,
url char(100) not null,
log timestamp not null default now(),
primary key (id)
);

复制代码

create table if not exists DataIndex
(
file_id int not null,
block_id int not null,
primary key (file_id,block_id),
foreign key(file_id) references Information(id),
foreign key(block_id) references Data(id)
);

复制代码

CREATE function fun_Information(address char(100))
RETURNS int
BEGIN
DECLARE file_id int;
select count(*) into file_id from Information where url=address;
if file_id < 1 then
insert into Information(url) values(address);
end if;
select id into file_id from Information where url=address;
return file_id;
END

复制代码

CREATE FUNCTION fun_Data(nValue char(100),dValue blob,sValue int,fValue int)
RETURNS int
BEGIN
DECLARE bValue int;
select count(*) into @Value from Data where name=nValue;
if @Value<1 then
insert into Data(name,data,size) values(nValue,dValue,sValue);
end if;
select id into bValue from Data where name=nValue;
select count(*) into @Value from DataIndex inner join Data on Data.id=DataIndex.block_id where Data.name=nValue and DataIndex.file_id=fValue;
if @Value<1 then
insert DataIndex(file_id,block_id) values(fValue,bValue);
end if;
return bValue;
END

复制代码

public void run() {
int file_id = -1;
int[] block_id = null;
String filename = this.read();
String sql = "{?=call fun_Information(?)}";
file_id = database.Rrocedure(sql, filename);
sql = "update Information set log=now() where id=" + file_id;
database.Write(sql);
while (isAlive) {
sql = "select Data.id,Data.size from Data inner join DataIndex on Data.id=DataIndex.block_id inner join Information on Information.id=DataIndex.file_id where Information.id="
+ file_id + " and Data.name='" + filename + "';";
rs = database.Read(sql);
try {
if (rs.next()) {
block_id = new int[rs.getRow()];
rs.beforeFirst();
int i = 0, length = 0;
while (rs.next()) {
block_id[i] = rs.getInt(1);
length += rs.getInt(2);
i++;
}
rs.close();
database.ResultSetClose();
this.SendHead(length);
for (i = 0; i < block_id.length; i++) {
this.WorkDB(block_id[i]);
try {
out.flush();
} catch (IOException e) {
e.printStackTrace();
}
}
} else {
rs.close();
database.ResultSetClose();
this.WorkNet(file_id, filename);
}
} catch (SQLException e) {
e.printStackTrace();
}
filename = this.read();
}
this.close();
}

复制代码

private String read() {
String buffer = null;
System.out.println("I am the " + Thread.currentThread().getId() + "\t"
+ Thread.currentThread().getName()); //用来显示该线程是第几个线程
try {
do {
buffer = in.readLine();
if (buffer.startsWith("Connection: ")) { //如果是以Connection开头，则记录时Keep-Alive还是Close
connection = buffer.substring(buffer.indexOf(" ") + 1);
System.out.println(connection);
if (connection.equals("close")) {
isAlive = false;
}
}
if (buffer.startsWith("null")) {
isAlive = false;
}
} while (!buffer.startsWith("GET") && isAlive);
buffer = buffer.substring(5, buffer.lastIndexOf(" "));
} catch (IOException e) {
e.printStackTrace();
}
return buffer;
}

复制代码

private void SendHead(long length) {
String status = "HTTP:/1.0 200 OK\r\n";
String mine = "MIME-Version: 1.0\r\n";
String contentType = "Content-type: text/html\r\n";
String contentLength = "Content-Length: " + length + "\r\n";
try {
out.write(status.getBytes());
out.write(mine.getBytes());
out.write(contentType.getBytes());
out.write(contentLength.getBytes());
out.write("\r\n".getBytes());
} catch (IOException e) {
e.printStackTrace();
}
}

复制代码

private void WorkNet(int file_id, String filename) {
String address = filename, sql = null;
URL url = null;
int length = 0, sum = 0, num = 0;
int[] block_id = new int[100];
try {
while (isAlive) {
sum = 0;
num = 0;
url = new URL(host + address);
is = url.openStream();
while ((length = is.read(bytes)) > 0) {
sum += length;
data = this.bytecopy(bytes, length);
sql = "{?=call fun_Data(?,?,?,?)}";
block_id[num++] = database.Rrocedure(sql, filename, data,
length, file_id);
}
this.SendHead(sum);
for (int i = 0; i < num; i++) {
this.WorkDB(block_id[i]);
}
is.close();
}
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}

复制代码

private void WorkDB(int block_id) {
String sql = "select data from Data where id=" + block_id + ";";
int length = 0;
rs = database.Read(sql);
try {
if (rs.next()) {
is = rs.getBinaryStream(1);
}
rs.close();
database.ResultSetClose();
while ((length = is.read(bytes)) > 0) {
data = this.bytecopy(bytes, length);
out.write(data);
}
is.close();
} catch (SQLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}

复制代码

I am the 10 Thread-0
Reading…… GET /starry-tales.mpd HTTP/1.0
修改前GET /starry-tales.mpd HTTP/1.0
修改后starry-tales.mpd
I am the 10 Thread-0
Reading…… Host: localhost
Reading…… User-Agent: GPAC/0.5.0-rev4065
Reading…… Accept: */*
Reading…… Connection: Keep-Alive
Reading…… Accept-Language: zh
Reading…… Icy-Metadata: 1
Reading……
Reading…… null
Exception in thread "Thread-0" java.lang.NullPointerException
at com.liujiaqi.proxy.ProxyConnect.read(ProxyConnect.java:178)
at com.liujiaqi.proxy.ProxyConnect.WorkNet(ProxyConnect.java:127)
at com.liujiaqi.proxy.ProxyConnect.Work(ProxyConnect.java:82)
at com.liujiaqi.proxy.ProxyConnect.run(ProxyConnect.java:49)
at java.lang.Thread.run(Thread.java:724)
I am the 12 Thread-1
Reading…… GET /starry-tales.mpd HTTP/1.1
修改前GET /starry-tales.mpd HTTP/1.1
修改后starry-tales.mpd
I am the 12 Thread-1
Reading…… User-Agent: Lavf52.33.0
Reading…… Accept: */*
Reading…… Range: bytes=0-
Reading…… Host: localhost:9090
Reading…… Authorization: Basic
Reading…… Connection: close
Bye
修改前starterror end
修改后error
I am Closing
Exception in thread "Thread-1" java.lang.NullPointerException
at com.liujiaqi.proxy.ProxyConnect.close(ProxyConnect.java:60)
at com.liujiaqi.proxy.ProxyConnect.run(ProxyConnect.java:51)
at java.lang.Thread.run(Thread.java:724)
I am the 13 Thread-2
Reading…… GET /starry-tales.mpd HTTP/1.1
修改前GET /starry-tales.mpd HTTP/1.1
修改后starry-tales.mpd
I am the 13 Thread-2
Reading…… User-Agent: Lavf52.33.0
Reading…… Accept: */*
Reading…… Range: bytes=0-
Reading…… Host: localhost:9090
Reading…… Authorization: Basic
Reading…… Connection: close
Bye
修改前starterror end
修改后error
I am Closing
Exception in thread "Thread-2" java.lang.NullPointerException
at com.liujiaqi.proxy.ProxyConnect.close(ProxyConnect.java:60)
at com.liujiaqi.proxy.ProxyConnect.run(ProxyConnect.java:51)
at java.lang.Thread.run(Thread.java:724)
I am the 14 Thread-3
Reading…… GET /starry-tales.mpd HTTP/1.0
修改前GET /starry-tales.mpd HTTP/1.0
修改后starry-tales.mpd
I am the 14 Thread-3
Reading…… Host: localhost
Reading…… User-Agent: GPAC/0.5.0-rev4065
Reading…… Accept: */*
Reading…… Connection: Keep-Alive
Reading…… Accept-Language: zh
Reading…… Icy-Metadata: 1
Reading……
I am the 15 Thread-4
Reading…… GET /starry-tales_dash.mp4 HTTP/1.0
修改前GET /starry-tales_dash.mp4 HTTP/1.0
修改后starry-tales_dash.mp4
I am the 15 Thread-4
Reading…… Host: localhost
Reading…… User-Agent: GPAC/0.5.0-rev4065
Reading…… Accept: */*
Reading…… Connection: Keep-Alive
Reading…… Accept-Language: zh
Reading…… Icy-Metadata: 1
Reading……
Reading…… GET /starry-tales-$RepresentationID$-$Number$1.m4s HTTP/1.0
修改前GET /starry-tales-$RepresentationID$-$Number$1.m4s HTTP/1.0
修改后starry-tales-$RepresentationID$-$Number$1.m4s
http://localhost/starry-tales-$RepresentationID$-$Number$1.m4s
com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '2-2' for key 'PRIMARY'
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:414)
at com.mysql.jdbc.Util.handleNewInstance(Util.java:411)
at com.mysql.jdbc.Util.getInstance(Util.java:386)
at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1041)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:4187)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:4119)
at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2570)
at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2731)
at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2809)
at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2758)
at com.mysql.jdbc.StatementImpl.execute(StatementImpl.java:894)
at com.mysql.jdbc.StatementImpl.execute(StatementImpl.java:732)
at com.liujiaqi.proxy.Database.Write(Database.java:44)
at com.liujiaqi.proxy.ProxyConnect.WorkNet(ProxyConnect.java:111)
at com.liujiaqi.proxy.ProxyConnect.Work(ProxyConnect.java:82)
at com.liujiaqi.proxy.ProxyConnect.run(ProxyConnect.java:49)
at java.lang.Thread.run(Thread.java:724)
I am the 15 Thread-4
Reading…… Host: localhost
Reading…… User-Agent: GPAC/0.5.0-rev4065
Reading…… Accept: */*
Reading…… Connection: Keep-Alive
Reading…… Accept-Language: zh
Reading…… Icy-Metadata: 1
Reading……

复制代码