多服务器java毫秒内的重复请求怎么处理？

用HttpClient(commonshttpclient)包，模拟一个Get请求，发送到网址1721630230/文件地址。这个文件地址不能是E/Map/123txt，必须是暴露在服务器中的应用里的。就像你写的应用里的一个jsp页面的目录。

成功发送get请求后，就会得到response，里面有流。就是你下载的文件，然后可以通过FileOutputStream，指定你输出目录，写到磁盘上。

服务器监听端口 做个无限循环 接到一个连接就创建一个通道线程，并将通道线程存储到一个list集合中

import javaioIOException;

import javaioInputStreamReader;

import javaioPrintWriter;

import javanetServerSocket;

import javanetSocket;

import javatextSimpleDateFormat;

import javautilArrayList;

import javautilDate;

import javautilList;

/

  4用socket通讯写出多个客户端和一个服务器端的通讯，

  要求客户发送数据后能够回显相同的数据（回显功能）（实用TCP方式）。

 /

public class Test4Server {

// 主入口

public static void main(String[] args) throws IOException {

scoketServer();

}

// 开启的tcp8888监听端口

public static void scoketServer() throws IOException {

ServerSocket server = new ServerSocket(8888);

while (true) {

// 未连通前线程阻塞，连通后开启一个socket通道线程后继续监听8888端口

Socket socket = serveraccept();

Systemoutprintln(socketgetInetAddress()getHostAddress()

+ "连接进入");

new SocketThread(socket)start();

}

}

}

// 一个服务器端口中监听多个客服端通道线程

class SocketThread extends Thread {

//  所有通道写入流的集合

private static List<PrintWriter> list =new ArrayList<PrintWriter>();

private BufferedReader bufferedReader;

private PrintWriter printWriter;

public SocketThread(Socket socket) throws IOException {

thisbufferedReader = new BufferedReader(new InputStreamReader(socket

getInputStream()));

thisprintWriter = new PrintWriter(socketgetOutputStream());

listadd(printWriter);

}

@Override

public void run() {

String string = null;

while (true) {

try {

// 服务器在通道中读到的信息回显给客服端

string = bufferedReaderreadLine();

Systemoutprintln("客服端信息：" + string);

for(PrintWriter printWriter:list ){

printWriterwrite("服务器回显：" + string + "\r\n");

printWriterflush();

}

} catch (IOException e) {

}

}

}

}

客服端代码   可以用在局域网中用多台来连接测试

import javaioIOException;

import javaioInputStreamReader;

import javaioPrintWriter;

import javanetSocket;

import javautilScanner;

public class Test4Client {

public static Object obj = new Object();

// 客服端的主入口

public static void main(String[] args) throws IOException {

socketClient();

}

// 与服务器连通地址本机（127001），局域网中其他机器是（服务器在局域网中的ip地址） 端口都是8888

public static void socketClient() throws IOException {

Socket socket = new Socket("127001", 8888);

if (socketisConnected()) {

// 如果连接成功了就开启写和读的进程

new writer(socket)start();

new read(socket)start();

} else {

Systemoutprintln("服务器未开启");

}

}

}

// 写入到通道的线程

class writer extends Thread {

@SuppressWarnings("unused")

private Socket socket;

private PrintWriter printWriter;

private Scanner scanner = new Scanner(Systemin);

private String str = null;

public writer(Socket socket) throws IOException {

thissocket = socket;

thisprintWriter = new PrintWriter(socketgetOutputStream());

}

@Override

public void run() {

scanneruseDelimiter("\r\n");

while (true) {

Systemoutprint("请输入信息：");

// 产生扫描器的线程阻塞

str = scannernext();

Systemoutprintln("我说："+str);

printWriterwrite(str + "\r\n");

printWriterflush();

try {

Threadsleep(200);

} catch (InterruptedException e) {

eprintStackTrace();

}

}

}

}

// 从通道中读取的线程

class read extends Thread {

private Socket socket;

private BufferedReader bufferedReader;

private String str = null;

public read(Socket socket) throws IOException {

thissocket = socket;

thisbufferedReader = new BufferedReader(new InputStreamReader(socket

getInputStream()));

}

@Override

public void run() {

while (true) {

try {

str = bufferedReaderreadLine();

Systemoutprintln(str);

} catch (IOException e) {

}

try {

Threadsleep(200);

} catch (InterruptedException e) {

eprintStackTrace();

}

}

}

}

我百度HI你好了

public class Test {

public static void main(String[] args) {

Test1 t=new Test1();

tstart(); //启动线程

}

}

/

继承一个线程类

@author Administrator

/

class Test1 extends Thread{

private ServerSocket server = null;

public Test1(){

try {

server=new ServerSocket(3333);

} catch (IOException e) {

// TODO Auto-generated catch block

Systemoutprintln("服务端初始化scoket失败！");

}

}

/

继承父类方法

/

public void run(){

Socket clientSocket = null;

DataInputStream dis =null;

DataOutputStream dos=null;

String str="";

while(true){

try {

clientSocket=serveraccept();

dis = new DataInputStream(clientSocketgetInputStream());//获取输入流，用于接收客户端发送来的数据

dos = new DataOutputStream(clientSocketgetOutputStream());//获取输出流，用于客户端向服务器端发送数据

str=disreadUTF(); //这里是客户端发送来的数据

/

这里边你就可以做你想操作的事情了

/

doswriteUTF("这里是返回到客户端的数据");//这里用来向客户端返回数据

disclose();

dosclose();

} catch (IOException e) {

// TODO Auto-generated catch block

eprintStackTrace();

}

}

}

}