clientreceive.java

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

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 ClientReceive extends Thread {
	protected PaintClient owner;
	protected String netName = "";
	protected Socket socket;
	boolean isShutDown = false;

	public ClientReceive(PaintClient owner, Socket socket) {
		this.owner = owner;
		this.socket = socket;
	}
	/**
	 * 设置网络名称，这个名称是唯一指定的
	 * @param newNetName
	 */
	private void setNetName(String newNetName) {
		this.netName = newNetName;
		owner.setNetName(newNetName);
	}

	@Override
	public void run() {
		try {
			ObjectInputStream bis = new ObjectInputStream(socket
					.getInputStream());
			Object obj = bis.readObject();

			if (!(obj instanceof String)) {
				if (Application.DEBUG > 0)
					System.out.println("客户端欲接受名称，但是对象却不是字符串");
				return;
			} else
				setNetName((String) obj);

			while (!isShutDown) {
				obj = bis.readObject();
				owner.receiveMessage(obj);
			}
			bis.close();

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

}