chatserverthread.java

java 开源游戏源码 RISK 联机对战 战棋类

// Yura Mamyrin, Group D

package risk.engine;

import java.net.*;
import java.io.*;

import java.util.LinkedList;

/**
 * <p> Chat Server Thread </p>
 * @author Yura Mamyrin
 */

// The main child thread waits for new information in the ChatArea, and 
// sends it out to the eagerly waiting clients

public class ChatServerThread extends Thread {

    LinkedList m_lList = new LinkedList();

    private Socket socket = null;
    int myIndex;
    ChatReader myReaderThread; 
    ChatArea myChatArea;

    public ChatServerThread(Socket socket, ChatArea cArea, int me) {
           super("ChatServerThread");
           this.socket = socket;
           myChatArea = cArea;
           myIndex= me;
           //System.out.println("Creating Thread "+myIndex);
    }

	public void run() {

		String outputLine;

		try {

			// First create the Streams associated with the Socket

			// Outbound Stream (actually a PrintWriter)

			PrintWriter outChat = new PrintWriter(
                           socket.getOutputStream(), true);

			// Inbound Stream (actually a BufferedReader)

			BufferedReader inChat = new BufferedReader(
                               new InputStreamReader(
                                   socket.getInputStream()));


			// got a connection from the client and do a read right away to get the version

			String version = inChat.readLine();

			if (version.equals(risk.engine.core.RiskGame.SAVE_VERSION)) {

				// Create a separate thread to handle the incomming socket data      
				myReaderThread = new ChatReader(inChat, myChatArea, myIndex);
				myReaderThread.start();

				// meanwhile, this thread will wait for new chatArea data and when
				// received, it will be dispersed to the connected client. 

				do  {
					outputLine = myChatArea.waitForString(myIndex);
					if (outputLine != null)
						outChat.println(outputLine);
				}
				while (outputLine != null);  
			}
			else {

				outChat.println( "ERROR version missmatch, server: "+risk.engine.core.RiskGame.SAVE_VERSION+", and client: "+version );

			}

			// seems to get stuck if called here
			//inChat.close();
			//outChat.close();

			socket.shutdownInput();
			socket.shutdownOutput();

			socket.close();

			inChat.close();
			outChat.close();

		}
		catch (IOException e) {
                       //System.out.println("ChatServerThread IOException: "+
                       //e.getMessage());
                       //e.printStackTrace();
		}
		//@todo does not get here if player presses leave, only goes here when they close the app
		//System.out.println("ChatServerThread Terminating: " + myIndex);

	}
}