console.java

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

package com.ict.netcom2.net;

import java.io.*;
import java.net.InetAddress;
import java.net.Socket;
import java.util.*;

public class Console {

	public static void main(String[] args) {

	    Socket skt;
	    PrintWriter pw;
	    Scanner sin;
    
        try {
            skt = new Socket(InetAddress.getLocalHost(), 8899);
            sin = new Scanner(skt.getInputStream());
            pw = new PrintWriter(skt.getOutputStream(), true);
            BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
            String str;
            while (true) {
            	str = in.readLine();
            	pw.println(str);
            	
            	if (str.equals("exit")) {
            		pw.close();
            		in.close();
            		skt.close();
            		in.close();
            		break;
            	}
            	
            	while (sin.hasNextLine()) {
            		str = sin.nextLine();
            		if (str.equalsIgnoreCase("eof"))
            			break;
            		System.out.print("# ");
            		System.out.println(str);
            	}
            	
            }
        }
        catch(Exception e) {
        	e.printStackTrace();
        }
	}
	
}