[收藏]ServeOneSocket.java 服务端源程序

eclipse

//ServeOneSocket.java 服务端源程序

import java.io.*&#59;
import java.net.*&#59;

public class ServeOneSocket extends Thread {

private Socket socket&#59;
private BufferedReader in&#59;
private PrintWriter out&#59;
private String content&#59;

/**
* Constructor
*/
public ServeOneSocket(Socket s,String c)throws IOException {
socket=s&#59;
content=c&#59;
in=new BufferedReader(
new InputStreamReader(
socket.getInputStream()))&#59;
//enable auto-flush
out=new PrintWriter(
new BufferedWriter(
new OutputStreamWriter(
socket.getOutputStream())),true)&#59;
start()&#59;//calls run()
}

public void run(){
try{
while (true){
String str=in.readLine()&#59;
if (str.equals("END&quot)break&#59;
System.out.println("Echoing:"+str)&#59;
out.println(str)&#59;
out.println(content)&#59;
}
System.out.println("Closing...&quot&#59;
}catch(IOException e){
}finally{
try{
socket.close()&#59;
}catch(IOException e){}
}
}
}

//SocketClientThread.java 客户端源程序

import java.net.*&#59;
import java.io.*&#59;

class SocketClientThread extends Thread{
private Socket socket&#59;
private BufferedReader in&#59;
private PrintWriter out&#59;
private static int counter=0&#59;
private int id=counter++&#59;
private static int threadcount=0&#59;
final int port=8110&#59;

public static int threadCount(){
return threadcount&#59;
}

public SocketClientThread(InetAddress addr){
System.out.println("Making client:"+id)&#59;
threadcount++&#59;
try{
socket=new Socket(addr,port)&#59;
}catch(IOException e){
}
try{
in=new BufferedReader(
new InputStreamReader(
socket.getInputStream()))&#59;
out=new PrintWriter(
new BufferedWriter(
new OutputStreamWriter(
socket.getOutputStream())),true)&#59;
start()&#59;
}catch(IOException e){
try{
socket.close()&#59;
}catch(IOException e2){}
}
}

public void run(){
try{
for (int i=0&#59;i<25&#59;i++){
out.println(&quot;Client:&quot;+id+&quot;:&quot;+i)&#59;
String str=in.readLine()&#59;
System.out.println(str)&#59;
}
out.println(&quot;END&quot&#59;
}catch(IOException e){
}finally{
try{
socket.close()&#59;
}catch(IOException e){}
threadcount--&#59;
}
}
}

public class MultiSocketClient {
static final int MAX_THREADS=10&#59;
/**
* main
* @param args
*/
public static void main(String[] args)throws IOException,InterruptedException {
InetAddress addr=InetAddress.getByName(null)&#59;
while (true){
if (SocketClientThread.threadCount()<MAX_THREADS)
new SocketClientThread(addr)&#59;
Thread.currentThread().sleep(100)&#59;
}
}
}