gamestartmsg.java

基于尚学堂坦克大战的基础上开发,支持多人对战,在线聊天,坦克大战网络版.

import java.io.ByteArrayOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;
/**
 * 发送游戏开始的消息类
 * @author Nightelf暗夜精灵
 *
 */
public class GameStartMsg implements Msg {

	int msgType = Msg.GAME_START_MSG;

	private TankClient tc;

	public GameStartMsg(TankClient tc) {
		this.tc = tc;
	}

	public void send(DatagramSocket ds, String IP, int udpPort) {
        System.out.println("我发送出去一个GameStart的数据！");
        
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		DataOutputStream dos = new DataOutputStream(baos);
		try {
			dos.writeInt(msgType);
			dos.writeInt(tc.tank.getTankId());
			dos.writeBoolean(tc.tank.isReady());
			byte[] buf = baos.toByteArray();
			DatagramPacket dp = new DatagramPacket(buf, buf.length,
					new InetSocketAddress(IP, udpPort));
			ds.send(dp);
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	public void parse(DataInputStream dis) {
		
		System.out.println("客户端接收一份服务端发来GrameStrat的数据！");
		// 如果所有人都准备了，游戏就正式开始了
		int tankId;
		boolean ready;
		try {
			tankId = dis.readInt();
			ready = dis.readBoolean();

			for (int i = 0; i < tc.playerTanks.size(); i++) {
				Tank tank = tc.playerTanks.get(i);
				if (tankId == tank.getTankId()) {
					tank.setReady(ready);
					break;
				}
			}
			
			
			int goodCount = 0,badCount = 0;
			 
			 if(tc.tank.isGood()){
			 goodCount++;
			 }else{
			 badCount++;
			 }
			 
			for (int i = 0; i < tc.playerTanks.size(); i++) {
				Tank tank = tc.playerTanks.get(i);
				if(tank.isGood()){
					goodCount++;
				}else{
					badCount++;
				}
			}
			
			if(goodCount==0 || badCount==0) return;

			if (tc.getReadyer() == tc.playerTanks.size()) {
				tc.setVisible(true);
				tc.join.setVisible(false);
				System.out.println("游戏开始运行了");
                tc.gameStarted=true;
                //取出TankId最小值的当主机
                int min = tc.tank.getTankId();
                for(int i=0; i<tc.playerTanks.size(); i++){
                	Tank pt = (Tank)tc.playerTanks.get(i);
                	if(min<pt.getTankId()){
                		min=pt.getTankId();
                	}
                }
 
                //主机负责发送障碍物给其他客户端
                if((tc.tank.getTankId()==min && tc.gameStarted)||(tc.tank.getTankId()==min && tc.gameOver)){
                	
            		//让这个循环在游戏开始或游戏重新开始时的时候只运行一次,创建墙
                	    
            			if(tc.walls.size()==0){
            				tc.createSingleTankandWall();
            			}else{
            				tc.walls.removeAll(tc.walls);
            				tc.createSingleTankandWall();
            			}
            			System.out.println(tc.walls.size());
            			for(int i=0; i<tc.walls.size(); i++){
            				Wall wall = tc.walls.get(i);
            				System.out.println("x:"+wall.x+"  y:"+wall.y+" step"+wall.step+"  life"+wall.life);
            			}
            			Msg msg= new CreateWallsMsg(tc);
        				tc.client.send(msg);
        				System.out.println(tc.walls.size()+"发布createWall包！");
        				tc.setVisible(true);
        				
        				tc.gameOver=false;
                }
			} else {
				int count = tc.getReadyer();
				count++;
				tc.setReadyer(count);
			}
			
			//刷新页面
			tc.join.repaint();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

}