myconnection.java

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

package server;


public class MyConnection extends Thread
{
	int port = 5000;
	public static java.io.ObjectInputStream myinput;
	public static java.io.ObjectOutputStream myoutput;
	public String message;
	boolean threadlive = true;

	public static java.net.ServerSocket server;
	public static java.net.Socket socket;
	

	public MyConnection()
	{
		int count = 0;
		while(count <1000){
		System.out.println("ServerConncection()");
		try
		{
			server = new java.net.ServerSocket(port);			
			socket = server.accept();
			
			System.out.println("Server: get a connection");

			myoutput = new java.io.ObjectOutputStream(socket.getOutputStream());
			myinput = new java.io.ObjectInputStream(socket.getInputStream());
			//important output must before input
			
			myoutput.writeObject(Passwords.TALK+"Server: connect success");				
			myoutput.flush();		
			
			System.out.println("before do");
			
			do
			{
				System.out.println("before read");
				message = (String)myinput.readObject();
				System.err.println(message);
				threadlive = MessageProcess.analyse(message);
				Main.boardthread.repaint();					
			}while(threadlive);
			
		
		}//try
		catch(Exception e)
		{
			System.err.println("error in Connection Server");
			e.printStackTrace();
			
			try
			{

				ChessBoard.initChessman();
				Main.boardthread.repaint();					
				myinput.close();
				myoutput.close();
				socket.close();
				server.close();
				
			}
			catch(Exception ee){}
			
			
			count++;
			
			//break;
		}//catch
	}//while(count < 1000)
		
		//System.out.println("OK: MyConncection()");
	}//MyConnection
	
	public static void sendMessage(String amessage)
	{
		System.out.println("sendMessage("+amessage+")");
		try
		{
			myoutput.writeObject(amessage);
			myoutput.flush();
		}
		catch(Exception e)
		{
			try{
				myoutput = new java.io.ObjectOutputStream(socket.getOutputStream());
				myinput = new java.io.ObjectInputStream(socket.getInputStream());
				myoutput.writeObject(amessage);
				}
				catch(Exception ee)
				{
					ee.printStackTrace();
				}
		}
	}

	
}