serverprocessor.java

做了一大堆J2EE WEB应用之后

package net.socket;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.List;

import net.datagram.IconInfo;
import net.datagram.MoveInfo;
import net.datagram.PlayerInfo;
import net.datagram.SpriteInfo;

public class ServerProcessor implements Runnable{

	private boolean loop = true;

	private Socket socket;

	private Server server;
	
	private PlayerInfo clientInfo;
	
	public ServerProcessor(Server server,Socket socket) {
		super();
		this.socket = socket;
		this.server = server;
	}
 
	
	public void send(Object obj){
		
		try {
			ObjectOutputStream out = new ObjectOutputStream(socket.getOutputStream());
			out.writeObject(obj);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	private void listen() throws Exception{
		
		ObjectInputStream in = new ObjectInputStream( socket.getInputStream());
		Object obj = in.readObject();
		//System.out.println("read"+obj.getClass());
		
		if(obj instanceof PlayerInfo){
			
			
			clientInfo =(PlayerInfo) obj;
			//把所在用户列表发送到当前用户
			for(PlayerInfo playerInfo:server.playerList){
				System.out.println("playerInfo:"+playerInfo.getServerName());
				send(playerInfo);
				  
			}
			//把当前用户信息发送给所有的用户列表
			server.joinPlayer(clientInfo);
			server.playerList.add(clientInfo);
			 
			
		}else if(obj instanceof MoveInfo){
			
			 
			MoveInfo moveInfo =(MoveInfo) obj;
			server.batchSend(this,moveInfo);
			server.clientListener.onMove(new ClientEvent(moveInfo));
			
		}else if(obj instanceof IconInfo){
		
			IconInfo iconInfo =(IconInfo) obj;
			server.batchSend(this,iconInfo);
			if(iconInfo.getAction()==1){
				server.clientListener.onBuild(new ClientEvent(iconInfo));				
			}else{
				server.clientListener.onReadyBuild(new ClientEvent(iconInfo));
			}
		
		}else if(obj instanceof SpriteInfo){
		
			SpriteInfo spriteInfo =(SpriteInfo) obj;
			server.batchSend(this,spriteInfo);
			if(spriteInfo.getAction()==1){
				server.clientListener.onRemoveTile(new ClientEvent(spriteInfo));				
			} 
		
		}

	}

	/**
	 * 如果此客户端报出异常,则通知所有用户删除此客户端
	 */
	public void run() {
		
		while(loop){
			
			try {
				
				listen();
				
			} catch (Exception e) {
				e.printStackTrace();
				//System.err.println(e.getMessage());
				server.removeClient(this);
				break;
			}
		}
	}
	
	public void move(List<SpriteInfo> sprites, int tx, int ty){
		
		try {
			ObjectOutputStream out = new ObjectOutputStream(socket.getOutputStream());
			out.writeObject(new MoveInfo(sprites,tx,ty));
			
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	public void close(){
		try {
			socket.close();
			loop = false;
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	public void start(){
		new Thread(this).start();
	}


	public PlayerInfo getClientInfo() {
		return clientInfo;
	}
	
	
}