?? 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();
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -