和大家一起来交流socket,响应多个socket请求的ServerSocket

jamesbang2003

/*
* Created on 2005-1-10
*
* To change the template for this generated file go to
* Window&ampreferences&Java&Code Generation&Code and Comments
*/
import java.io.*;
import java.net.*;

/**
* @author Administrator
*
* To change the template for this generated type comment go to
* Window&ampreferences&Java&Code Generation&Code and Comments
*/
public class MutiSocketTest
{
        public static void main(String args[])
        {
                try
                {
                        int i = 1;
                        ServerSocket s = new ServerSocket(8189);                       
                       
                        for(;
                        {
                                Socket incoming = s.accept();
                                System.out.println("The " + i + "th connection";
                                Thread t = new MutiThread(incoming,i);
                                t.start();
                                i++;
                        }
                }
                catch (Exception e)
                {
                        e.printStackTrace();
                }
        }
}

class MutiThread extends Thread
{
        public MutiThread(Socket i, int c)
        {
                incoming = i ;
                counter = c;
        }
       
        public void run()
        {
                try
                {
                        BufferedReader in = new BufferedReader(new InputStreamReader(incoming.getInputStream()));
                        PrintWriter out = new PrintWriter(incoming.getOutputStream());
                       
                        out.println("Hello! Enter bye to exit.";

                        boolean done = false;
                        while(!done)
                        {
                                String str = in.readLine();
                                System.out.println(str);
                                if (str == null)
                                        done = true;
                                else
                                {
                                        out.println("Echo("+counter+":"+str);
                                       
                                        if (str.trim().equals("bye")
                                        {
                                                done = true;
                                                out.println("Over...";
                                        }
                                }
                                out.flush();
                        }
                        incoming.close();
                }
                catch (Exception e)
                {
                        e.printStackTrace();
                }
        }
       
        private Socket incoming;
        private int counter;
}

测试方法,进入命令行,用telnet ip 8189,就可以了,欢迎大家来指点,希望能和大家一起进步啊!

Joohnnie

记得close socket

jamesbang2003

有啊incoming.close();