server.java

实例精华

//package Chat;
import java.io.*;
import java.net.*;
public class Server extends Thread
{
    ServerSocket server;

    public Server()
    {
        try {
            server = new ServerSocket(1234);
        } catch (IOException ex) {
            System.out.println("Server no't Start!!");
        }
        System.out.println("Server Starting...........");
        this.start();


    }
    public void run()
    {
        try {
            while (true) {
                Socket sk = server.accept();
                //定义一个线程类
                Service sc = new Service(sk);
            }
        } catch (IOException ex) {
        }
    }

    class Service extends Thread
    {
        String data,data1;
        BufferedReader br,brr;
        PrintStream ps;
        Socket so;
        InetAddress ia;
        public Service(Socket sk)
        {

            this.so = sk;

            try {
                br = new BufferedReader(new InputStreamReader(so.getInputStream()));
                brr = new BufferedReader(new InputStreamReader(System.in));
                ps = new PrintStream(so.getOutputStream());
            } catch (IOException ex) {
            }

            this.start();


        }
        public void run()
        {
            try {
                while (true) {

                    data = br.readLine();
                    if (data == null)break;
                    System.out.println("Client say:" + data);
                    data1 = brr.readLine();
                    ps.println(data1);

                }
            } catch (IOException ex) {
                System.out.println(ia.getHostName()+"下线了");
                ex.printStackTrace();

            }
            try {
                so.close();
            } catch (IOException ex1) {
            }
        }
    }
    public static void main(String[] args)
    {
        new Server();
    }
}