server.java

利用Java Socket写的一段通讯协议

package com.ict.netcom2.trash;

import java.io.*;
import java.net.*;

public class Server extends Thread{
    int port;
    MainFrame mf;
    int thdNum;
    ServerSocket sskt;

    public Server(int port, MainFrame mf) {
        this.mf = mf;
        this.port = port;
        thdNum = 0;
    }

    public void run() {
        try {
            sskt = new ServerSocket(port);
            String msg = "Listening on port "+port;
            mf.setServerInfo(msg);

            while (true) {
                Socket skt = sskt.accept();
                thdNum++;
                msg = "Accepted connection: " +
                      skt.getInetAddress()+"  ID: "+thdNum;
                mf.setServerInfo(msg);
                (new ServerThread(this, skt, mf)).start();
            }
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }

    public void close() {
        try {
            sskt.close();
        }
        catch (IOException e) {
            e.printStackTrace();
        }
    }

}