romulustestserver.java

《Java案例开发》源代码( 考勤系统的完整实现！） 包括数据库 网络通讯＆uml

/*
 * RomulusTestServer.java
 *
 * Created on 2004年1月11日, 下午8:45
 */

package romulus.NET;

import java.net.*;
import java.io.*;
import java.util.*;
import java.sql.*;
import romulus.*;
import romulus.Manager.*;

/**
 * @author S
 */
public class RomulusTestServer{
    
    //The field of listen port
    private ServerSocket ListenSocket = null;
    
    /** Creates a new instance of RomulusTestServer */
    public RomulusTestServer() {
        try{
            //get properties
            Properties props = RomulusNetProtocol.getRomulusNetProtocolProperties();
            String serverport = props.getProperty(RomulusNetProtocol.AppServerPort, "1228");
            String queuelength = props.getProperty(RomulusNetProtocol.AppServerQueueLength, "20");
            int port = Integer.parseInt(serverport);
            int length = Integer.parseInt(queuelength);
            
            //initial server socket
            this.ListenSocket = new ServerSocket(port, length);
        }
        catch(IOException e){
            e.printStackTrace();
            System.exit(0);
        }
    }
    
    public void finalize() throws Throwable{
        this.ListenSocket.close();
    }
    
    public void StartListening(){
        try{
            while (true){
                //get a RomulusToolSet instance for RomulusTestServerThread
                Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
                Connection rtsConnection = java.sql.DriverManager.getConnection("jdbc:odbc:Romulus", "Romulus", "romulus");
                
                //get a ManagerToolSet instance for RomulusTestServerThread
                Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
                Connection mtsConnection = java.sql.DriverManager.getConnection("jdbc:odbc:Manager", "Romulus", "romulus");
                
                //accept a client and start a new RomulusTestServerThread
                new RomulusTestServerThread(ListenSocket.accept(), rtsConnection, mtsConnection).start();
            }
        }
        catch(Exception e){
            e.printStackTrace();
        }
        finally{
            try{
                ListenSocket.close();
            }
            catch(IOException e){
                e.printStackTrace();
            }
        }
    }
    
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        try{
            RomulusTestServer romulusServer = new RomulusTestServer();
            romulusServer.StartListening();
        }
        catch(Exception e){
            e.printStackTrace();
        }
    }
    
}