receiver.java

来自「用java的net包写的一个小的点到点的聊天软件。用了2小时写的」· Java 代码 · 共 48 行

package jsm;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Receiver extends Thread {
	public final static int PORT = 2004;

	private static Receiver single = new Receiver();

	MessageHandler mh = MessageHandler.getMH();

	public static Receiver getReceiver() {
		return single;
	}

	private Receiver() {

	}

	public void run() {
		ServerSocket monitor = null;
		try {
			// 暂时不设置监听端口的等待队列
			monitor = new ServerSocket(PORT);
			while (true) {
				Socket connection = monitor.accept();
				// System.out.println("socket connected");
				connection.setSoTimeout(30000);
				mh.handleInConnection(connection);
			}
		} catch (IOException e) {

			e.printStackTrace();
		} finally {
			try {
				monitor.close();
			} catch (IOException e) {

				e.printStackTrace();
			}
		}

	}

}