ServeOneSocket.java 服务端源程序

王朝java/jsp·作者佚名  2006-01-08
窄屏简体版  字體: |||超大  

//ServeOneSocket.java 服务端源程序

import java.io.*;

import java.net.*;

public class ServeOneSocket extends Thread {

private Socket socket;

private BufferedReader in;

private PrintWriter out;

private String content;

/**

* Constructor

*/

public ServeOneSocket(Socket s,String c)throws IOException {

socket=s;

content=c;

in=new BufferedReader(

new InputStreamReader(

socket.getInputStream()));

//enable auto-flush

out=new PrintWriter(

new BufferedWriter(

new OutputStreamWriter(

socket.getOutputStream())),true);

start();//calls run()

}

public void run(){

try{

while (true){

String str=in.readLine();

if (str.equals("END"))break;

System.out.println("Echoing:"+str);

out.println(str);

out.println(content);

}

System.out.println("Closing...");

}catch(IOException e){

}finally{

try{

socket.close();

}catch(IOException e){}

}

}

}

//SocketClientThread.java 客户端源程序

import java.net.*;

import java.io.*;

class SocketClientThread extends Thread{

private Socket socket;

private BufferedReader in;

private PrintWriter out;

private static int counter=0;

private int id=counter++;

private static int threadcount=0;

final int port=8110;

public static int threadCount(){

return threadcount;

}

public SocketClientThread(InetAddress addr){

System.out.println("Making client:"+id);

threadcount++;

try{

socket=new Socket(addr,port);

}catch(IOException e){

}

try{

in=new BufferedReader(

new InputStreamReader(

socket.getInputStream()));

out=new PrintWriter(

new BufferedWriter(

new OutputStreamWriter(

socket.getOutputStream())),true);

start();

}catch(IOException e){

try{

socket.close();

}catch(IOException e2){}

}

}

public void run(){

try{

for (int i=0;i<25;i++){

out.println("Client:"+id+":"+i);

String str=in.readLine();

System.out.println(str);

}

out.println("END");

}catch(IOException e){

}finally{

try{

socket.close();

}catch(IOException e){}

threadcount--;

}

}

}

public class MultiSocketClient {

static final int MAX_THREADS=10;

/**

* main

* @param args

*/

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

InetAddress addr=InetAddress.getByName(null);

while (true){

if (SocketClientThread.threadCount()<MAX_THREADS)

new SocketClientThread(addr);

Thread.currentThread().sleep(100);

}

}

}

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航