slg游戏之多人对战版

package Caocao; import java.net.*; import java.io.*; import java.util.*; import org.xsocket.connection.*; public class LufyServer { private IServer srv2 = null; private ServerSocket server; private Boolean serverStop = true; private RPGManager bMan = new RPGManager(); private int ServerCount = 0; //private HashMap userList = new HashMap(); private HashMap userNameList = new HashMap(); private ArrayList<User> userlist = new ArrayList<User>(); private static String lock = ""; private int roomCount = 9; private int runIndex = 0; public LufyServer() { } private HashMap<String,String> strToHash(String value){ HashMap<String,String> result = new HashMap<String,String>(); String[] arrValue = value.split("&"); for(int i=0;i<arrValue.length;i++){ String[] keyvalue = arrValue[i].split("="); if(keyvalue.length == 1){ result.put(keyvalue[0], ""); }else{ result.put(keyvalue[0], keyvalue[1]); } } return result; } void startServer() { try { srv2 = new Server(843,new CheckSafe()); srv2.start(); server = new ServerSocket(8210); System.out.println("startServer ExplosionServer is run!"); while (true) { Socket socket = server.accept(); Chat_Thread chatThread = new Chat_Thread(socket, "socket" + ServerCount); chatThread.start(); //userList.put("socket" + ServerCount, chatThread); bMan.add(socket); ServerCount++; //bMan.sendToSocket(socket, "socketId:socket" + (ServerCount++)); bMan.sendClientInfo(); if(!serverStop){ break; } } } catch (Exception e) { System.out.println(e); } } public static void main(String[] args) { LufyServer server = new LufyServer(); server.startServer(); } class Chat_Thread extends Thread { String msg; User user = new User(); Socket socket; //Socket socket_0; /* String socketId; String socketName; int roomId; int x; int y; */ private BufferedReader reader; // private PrintWriter writer; private BufferedWriter writer; private String xml = "<cross-domain-policy><allow-access-from domain=\"*\" to-ports=\"8210\"/></cross-domain-policy>\0"; Chat_Thread(Socket socket) { this.socket = socket; //this.socket = socket; } Chat_Thread(Socket socket, String socketidvalue) { this.socket = socket; //this.socketId = socketidvalue; } public void run() { try { reader = new BufferedReader(new InputStreamReader(socket .getInputStream(), "utf8")); writer = new BufferedWriter(new OutputStreamWriter(socket .getOutputStream(), "UTF-8")); while ((msg = reader.readLine()) != null) { if(msg.compareTo("<policy-file-request/>") == 1){ System.out.println("Server run "); bMan.sendToAll(xml); writer.flush(); } HashMap<String,String> result = strToHash(msg); System.out.println("RPGServer run msg = " + msg); if ("login".equals(result.get("type"))) { if("123".equals(result.get("pass"))){ if (userNameList.get(result.get("name")) != null) { String returnName = result.get("name"); result.remove("name"); result.put("name", returnName + ServerCount); } user.setName(result.get("name")); user.setSocket(this.socket); userNameList.put(user.getName(), user.getName()); String roomStr = ""; String roomAdd = ""; bMan.sendToSocket(this.socket,"type=in"); bMan.sendToAll("type=talk&name=" + user.getName() + "&msg=@“o˜^¬Œ÷I"); if(userlist.size() > 0){ String userlistStr = ""; String addStr = ""; for(int i=0;i<userlist.size();i++){ User thisuser = userlist.get(i); userlistStr += (addStr + thisuser.getRoomIndex() + ":" + thisuser.getId() + ":" + thisuser.getName()); addStr = ","; } bMan.sendToSocket(this.socket,"type=isin&userlist=" + userlistStr); } } }else if ("startin".equals(result.get("type"))) { user.setId(Integer.parseInt(result.get("id"))); for(int i=0;i<userlist.size();i++){ if(userlist.get(i).getName() == user.getName()){ bMan.sendToAll("type=removeselect&index=" + userlist.get(i).getRoomIndex()); userlist.remove(i); } } user.setRoomIndex(Integer.parseInt(result.get("index"))); bMan.sendToAll("type=select&name=" + user.getName() + "&index=" + user.getRoomIndex() + "&id=" + user.getId()); userlist.add(user); if(userlist.size() == 4){ ArrayList<User> ourlist = new ArrayList<User>(); ArrayList<User> enemylist = new ArrayList<User>(); ArrayList speedlist = new ArrayList(); speedlist.add(13); speedlist.add(10); speedlist.add(11); speedlist.add(12); for(int i=0;i<userlist.size();i++){ int index = userlist.get(i).getRoomIndex(); int intspeed = Integer.parseInt(speedlist.get(index).toString()); userlist.get(i).setSpeed(intspeed); if(userlist.get(i).getRoomIndex() < 2){ ourlist.add(userlist.get(i)); }else{ enemylist.add(userlist.get(i)); } } userlist.clear(); userlist.add(ourlist.get(0)); userlist.add(enemylist.get(1)); userlist.add(enemylist.get(0)); userlist.add(ourlist.get(1)); String startXml = "<data>" + "<Map>1</Map>" + "<DataMap>" + "<list>1,1,1,1,1,0,0,0,0,1,1,1,1,1,1,1,1,1,1,1</list>" + "<list>3,1,1,1,1,1,0,0,0,1,1,1,1,1,1,1,1,1,1,1</list>" + "<list>3,3,1,1,1,1,0,0,0,0,1,1,1,1,1,1,1,1,1,1</list>" + "<list>3,3,3,1,1,1,1,0,0,0,1,1,1,1,1,1,1,1,3,3</list>" + "<list>3,3,3,3,1,1,1,0,0,0,0,1,1,1,1,1,1,3,3,3</list>" + "<list>3,3,3,3,3,1,1,0,0,0,0,0,1,1,1,1,1,3,3,3</list>" + "<list>3,3,3,3,3,4,4,4,4,0,0,4,4,4,4,1,1,3,3,3</list>" + "<list>3,3,3,3,3,4,6,0,0,0,0,0,0,6,4,1,3,3,3,3</list>" + "<list>3,3,3,3,3,4,6,0,0,0,0,0,0,6,4,1,3,3,3,3</list>" + "<list>3,3,3,3,0,4,6,0,0,0,0,0,0,0,4,1,3,3,3,3</list>" + "<list>3,3,3,0,0,0,0,0,0,4,4,0,0,0,4,3,3,3,3,3</list>" + "<list>3,3,0,0,0,0,0,0,0,5,7,0,0,0,4,3,3,3,3,3</list>" + "<list>3,0,0,0,0,4,0,0,0,0,0,0,0,0,4,3,3,3,3,3</list>" + "<list>0,0,0,0,0,4,6,6,0,0,0,0,0,7,4,0,3,3,3,3</list>" + "<list>0,0,0,0,0,4,4,4,4,0,0,4,4,4,4,0,1,1,3,3</list>" + "<list>0,0,1,1,1,0,0,0,0,0,0,0,0,0,0,0,0,1,1,3</list>" + "<list>1,1,1,1,1,1,0,0,0,0,0,0,0,0,0,0,0,0,1,1</list>" + "<list>1,1,1,1,1,1,0,0,0,0,0,0,0,0,0,0,0,1,1,1</list>" + "<list>1,1,1,1,1,1,1,0,0,0,0,0,0,0,0,0,1,1,1,1</list>" + "<list>1,1,1,1,1,1,1,1,1,0,0,0,0,0,0,1,1,1,1,1</list>" + "</DataMap>" + "<Our>" + "<List x@\"9\" y@\"12\" speed@\"" + ourlist.get(0).getSpeed() + "\" username@\"" + ourlist.get(0).getName() + "\">" + ourlist.get(0).getId() + "</List>" + "<List x@\"10\" y@\"13\" speed@\"" + ourlist.get(1).getSpeed() + "\" username@\"" + ourlist.get(1).getName() + "\">" + ourlist.get(1).getId() + "</List>" + "</Our>" + "<Enemy>" + "<List x@\"8\" y@\"13\" speed@\"" + enemylist.get(0).getSpeed() + "\" username@\"" + enemylist.get(0).getName() + "\">" + enemylist.get(0).getId() + "</List>" + "<List x@\"11\" y@\"13\" speed@\"" + enemylist.get(1).getSpeed() + "\" username@\"" + enemylist.get(1).getName() + "\">" + enemylist.get(1).getId() + "</List>" + "</Enemy>" + "</data>"; bMan.sendToAll("type=start&xml=" + startXml); bMan.sendToAll("type=charatorun&name=" + userlist.get(runIndex++).getName()); } }else if ("getrunchara".equals(result.get("type"))) { if(runIndex >= userlist.size()){