package test;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
/**
* @param args
*/
int max=10; //最大开启线程数
int i=0; //回复数字
int temp;
public Test(){
try {
// TODO Auto-generated catch block
e.printStackTrace();
System.
out.
println("can't initate ServerSocket!");
return;
}
System.
out.
println("waiting for connect");
try {
while((socket[i]=serverSocket.accept())!=null){
temp=i;
i++;
new Thread(this).
start(); //每侦听到一个客户端的连接,就会开启一个工作线程
}
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void main
(String[] args
) {
new Test();
}
@Override
public void run() {
System.
out.
println("accept:"+sk.
getInetAddress().
getHostAddress());
try {
is=sk.getInputStream();
os=sk.getOutputStream();
// TODO Auto-generated catch block
e.printStackTrace();
try {
sk.close();
// TODO Auto-generated catch block
e1.printStackTrace();
}
return;
}
try {
int m=0;
while((str=br.readLine())!=null){
pw.println(m);
pw.flush();
m++;
}
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
//java/6476