clientconnection.java

五子棋java源代码

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

public class ClientConnection extends Thread
{
	PrintWriter out;
	BufferedReader in;
	Socket socket;
	ServerFrame server_frame;
	
	public ClientConnection(ServerFrame sf,Socket s)
	{
		server_frame = sf;
		socket = s;
		
		try
		{
			out = new PrintWriter(s.getOutputStream(),true);
			in = new BufferedReader(new InputStreamReader(s.getInputStream()));
		}
		catch(IOException e){
			e.printStackTrace();
			}
	}
	
	public void run()
	{
		String str=new String();
		StringTokenizer st=new StringTokenizer(str);
		
		
		try
		{
			while(true)
			{

				System.out.println(str+">>>>>>>>>>>>>>>>>>>>>>");
				str=in.readLine();
				st = new StringTokenizer(str);
				switch(Integer.parseInt(st.nextToken()))
				{
					
					case MsgType.REGISTER:
						server_frame.do_reg(this,st);
						break;
					case MsgType.LOGON:
						server_frame.do_logon(this,st);
						break;
					case MsgType.LOGOUT:
						server_frame.do_logout(st);
						break;
					case MsgType.REQUEST:
						server_frame.do_request(st);
						break;
					case MsgType.ACCEPT:
						server_frame.do_accept(st);
						break;
					case MsgType.REFUSE:
						server_frame.do_refuse(st);
						break;
					case MsgType.PUTCHESS:
						server_frame.do_putchess(st);
						break;
					case MsgType.CHAT:
						server_frame.do_chat(st,str.substring(3,str.length()));
						break;

						case MsgType.DRAW:
						server_frame.do_draw(st);
						break;
					case MsgType.DRAWOK:
						server_frame.do_drawok(st);
						break;
					case MsgType.DRAWFAIL:
						server_frame.do_drawfail(st);
						break;
					case MsgType.WIN:
						server_frame.do_win(st);
						break;
					case MsgType.LOSS:
						server_frame.do_loss(st);
						break;
					default:
						break;					
				} 
			}
		}catch(IOException e)
			{
			//	server_frame.catchname(st);
				server_frame.updateList();
				try
				{		
					socket.close();	
				}
				catch(Exception ev){}
				//	System.out.println(st.nextToken());
					
				//	server_frame.user_map.get().socket.close();
				}
	}
}