serverreceive.java

来自「一个简易的java画图软件」· Java 代码 · 共 57 行

package net;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.net.Socket;
import java.net.SocketException;

import app.Application;

/**
 * 服务器接收器
 * 
 * @author Thihy
 * 
 */
public class ServerReceive extends Thread {
	protected PaintServer owner;
	protected Socket socket;
	protected String netName;
	boolean isShutDown = false;

	public ServerReceive(PaintServer owner, Socket socket, String netName) {
		this.owner = owner;
		this.netName = netName;
		this.socket = socket;
	}

	@Override
	public void run() {
		System.out.println(socket);
		try {
			ObjectInputStream bis = new ObjectInputStream(socket
					.getInputStream());
			while (true) {
				Object obj = bis.readObject();
				owner.receiveMessage(obj, netName);
				if (obj == null)
					break;
			}
			bis.close();

		} catch (SocketException e) {
			// 只是socket关闭的异常
		} catch (IOException e) {
			if (Application.DEBUG > 5)
				e.printStackTrace();
		} catch (ClassNotFoundException e) {
			if (Application.DEBUG > 5)
				e.printStackTrace();
		}
		if (!isShutDown) {
			owner.receiveMessage(new NetMessage(NetMessage.MES_SHUTDOWN, null),
					netName);
		}
		System.out.println("ServerReceive End");
	}
}