gamethread.java

来自「一个CS模式的网络五子棋游戏,用JAVA写的,源码版式不好,也共享出来,希望大家」· Java 代码 · 共 77 行

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.*;


public class GameThread extends Thread
{
//	网路部分
	private Socket sock = null;
	private DataInputStream in = null;
	private DataOutputStream out = null;
	int port = 6000;
	byte in_data = 5;
	byte out_data = 5;
	
	/*
	 * 3=连接
	 * 4=开始
	 * 5=结束
	 */
	private void SrvProc() throws IOException
	{
		try
		{
			String srvAddr;
			srvAddr = GameControler.getNetAddr();
			sock = new Socket(srvAddr,port);
			//开始按钮允许相应
			in = new DataInputStream(sock.getInputStream());
			out = new DataOutputStream(sock.getOutputStream());
			//如果还没结束,继续
			while((in_data = in.readByte()) != GameState.END)
			{
				//处理数据s
				GameControler.doProc(in_data);
			}
		}catch(IOException e)
		{
			System.out.println("ERROR: "+e);
		}
		finally
		{
			sock.close();
			in.close();
			out.close();
		}
	}
	
	public void run()
	{
		try
		{
			SrvProc();
		}catch(IOException e)
		{
			System.out.println("ERROR: "+e);
		}
	}
	
	public void writeData(byte data)
	{
		try
		{
			out.write((byte)data);
		}catch(IOException e)
		{
			System.out.println("ERROR: "+e);
		}
	}
	
	public GameThread()
	{
		GameControler.getThreadInstance(this);
	}
}