myconnection.java

网络象棋对战程序,模拟vista的国际象棋功能,可以自动寻找路径,棋子随同鼠标移动.另有网络聊天功能. ps:里面用的登陆服务器地址,需要稍做修改,修改成你想登陆的服务器. 开发工具eclipse

/**
 * 
 */
package client;

/**
 * @author Justok
 *
 */
public class MyConnection extends Thread
{
	int port = 5000;
	String host = new String("59.66.153.233");
	
	
	public static java.io.ObjectInputStream myinput;
	public static java.io.ObjectOutputStream myoutput;
	public static String message;
	boolean threadlive = true;
	public static java.net.Socket socket;
	
	public MyConnection()
	{
		System.out.println("MyConnection:client connect to "+host+":"+port);
		try
		{
			socket = new java.net.Socket(host,port);			
			System.out.println("Client: Connection Sucess");
				

			myoutput = new java.io.ObjectOutputStream(socket.getOutputStream());
			myinput = new java.io.ObjectInputStream(socket.getInputStream());

			System.out.println("before do");
			
			do
			{
				System.out.println("before read");
				message = (String)myinput.readObject();
				
				System.err.println(message);
				

				System.out.println("after read");
				threadlive = MessageProcess.analyse(message);
				Main.boardthread.repaint();					
			}while(threadlive);
				
			
		}//try
		catch(Exception e)
		{
			System.err.println("error in Connection");
			
			ChessBoard.initChessman();
			
			//e.printStackTrace();

			try{socket.close();}catch(java.io.IOException ee){return;}
		}//catch
		
		
		System.out.println("OK: MyConncection()");
	}
	
	
	public static void sendMessage(String amessage)
	{
		System.out.println("sendMessage("+amessage+")");
		try
		{
			myoutput.writeObject(amessage);
			myoutput.flush();
		}
		catch(Exception e)
		{
			System.err.println("error when sendMessage("+amessage+")");
			e.printStackTrace();
			
			try{
			myoutput = new java.io.ObjectOutputStream(socket.getOutputStream());
			myinput = new java.io.ObjectInputStream(socket.getInputStream());
			myoutput.writeObject(message);
			}
			catch(Exception ee)
			{
				ee.printStackTrace();
			}
		}
	}
}