todayserver.java

RMI通讯

package com.vanceinfo.socket.server;

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

/**
 * @author 谷明亮
 * @description 今日焦点服务器端
 */
public class TodayServer {
	// 服务器监听主机和端口号
	public static int PORT = 8080;

	// 服务器端套接字
	private ServerSocket ss;
	private Socket server;

	// 配置信息对象及其传送器
	private ConfigInfoObject configInfoObject = null;
	private ConfigInfoSupplier configInfoSupplier = null;

	public TodayServer() {
		System.out.println("Server is listening....");
		
		//指定监听主机和端口
		try {
			ss = new ServerSocket(PORT);
		} catch (IOException e) {
			e.printStackTrace();
		}
		
		//一直在监听客户端连接
		while (true) {
			this.startListen();
		}
	}

	// 服务器端监听
	public void startListen() {
		try {
			server = ss.accept();
			
			configInfoObject=new ConfigInfoObject();
			configInfoSupplier=new ConfigInfoSupplier(server,configInfoObject);
			
			Thread thread=new Thread(configInfoSupplier);
			thread.start();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	public static void main(String[] args) {
       new TodayServer();
	}

}