serverthread.java

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

package com.ict.netcom2.trash;

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

public class ServerThread extends Thread {
    Server srv;
    Socket skt;
    int id;
    MainFrame mf;
    BufferedReader in;
    PrintWriter out;

    public ServerThread(Server srv, Socket skt, MainFrame mf) {
        this.mf = mf;
        this.skt = skt;
        this.srv = srv;
        id = srv.thdNum;
    }

    public void run() {
        try {
            in = new BufferedReader(new InputStreamReader(
                    skt.getInputStream()));
            out = new PrintWriter(skt.getOutputStream());

            while (true) {
                String str = in.readLine();
                mf.setServerInfo("[" + id + "]["+srv.port+"][RCV] " + str);

                String ack = "Received " + str + ".Do something...";
                mf.setServerInfo("[" + id + "]["+srv.port+"][SEND] " + ack);
                out.println(ack);
                out.flush();

                if (str.equalsIgnoreCase("end")) {
                    close();
                    break;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
/*
    public void send(String str) {
        out.println(str);
        out.flush();
    }

    public String receive() {
        String str = null;
        try {
            str = in.readLine();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return str;
    }
*/
    public void close() {
        try {
            out.close();
            in.close();
            skt.close();
            srv.thdNum--;
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public int getID() {
        return id;
    }

}