客户端

ClientTest类：负责和服务器进行通信，建立两个线程，分别发送和接收客户端发出的命令和接收服务器端发出的命令。

ClientTest3.java

package game;

import java.io.*;  
import java.net.*;  
public class ClientTest3{  
    public static void main(String[] args){  
        try{  
            //链接sever端  
            Socket s1 = new Socket("127.0.0.1",10004);  
            System.out.println("Link in succeed...");
            System.out.println("Term 1:");
            //实例化输入流  
            InputStream is = s1.getInputStream();  
            DataInputStream dis = new DataInputStream(is);  
            //实例化输出流  
            OutputStream os = s1.getOutputStream();  
            DataOutputStream dos = new DataOutputStream(os);  
            //实例化两个进程  
            Thread mcr = new MyClientReader(dis);  
            Thread mcw = new MyClientWriter(dos);  
            //启动两个进程  
            mcr.start();  
            mcw.start();  
            //捕获异常  
        }catch(SocketException e){  
            System.out.println(e);  
        }catch(IOException e){  
            System.out.println(e);  
        }     
    }  
}  
//创建一个进程用来进行接收读取数据  
class MyClientReader extends Thread{  
    private DataInputStream dis;  
    public MyClientReader(DataInputStream dis){  
        this.dis = dis;  
    }  
    @Override  
    public void run(){  
        String msg;  
        try{  
            while(true){  
            msg = dis.readUTF();  
            System.out.println(msg);  
            if(msg.equals("bye")){  
                System.out.println("对方下线,程序退出");  
                System.exit(0);  
            }  
        }  
        }catch(IOException e){  
            System.out.println(e);  
        }  
    }  
}  
//创建一个进程用来写入并发送数据  
class MyClientWriter extends Thread{  
    private DataOutputStream dos;  
    public MyClientWriter(DataOutputStream dos){  
        this.dos = dos;  
    }  
    @Override  
    public void run(){  
        InputStreamReader isr = new InputStreamReader(System.in);  
        BufferedReader br = new BufferedReader(isr);  
        String msg;  
        try{  
        while(true){  
            msg = br.readLine();  
            dos.writeUTF(msg);  
            if(msg.equals("bye")){  
                System.out.println("自己下线,程序退出");  
                System.exit(0);  
            }  
        }   
        }catch(IOException e){  
            System.out.println(e);  
        }  
    }  
}  

Monster Card Game的设计与实现之客户端篇