chatserver.java

java应用开发详解

import java.io.*;
import java.net.*;
import java.util.Date;

public class ChatServer
{
    //声明一个静态的同步栈
    public static SynchroStack theStack = null;
    
    //声明一个广播对象
    public static Broadcast broadcast = null;

    public ChatServer()
    {
    }

    public static void main(String args[])
    {
        System.out.println("ChatServer started... ");
        try
        {
            
            theStack = new SynchroStack();
            broadcast = new Broadcast();
            boolean listening = true;
            
            //在指定端口开启服务监听
            ServerSocket serversocket = new ServerSocket(1111, 20);
            
            while(listening)
            {
                Socket socket = serversocket.accept();
                
                Date date1 = new Date();
                String s = String.valueOf(date1) + " Connecting " + socket.getInetAddress().getHostName() + "\r";
                System.out.println(s);
          
                //实例化一个代理
                Angent angent = new Angent(socket);
                //实例化一个服务线程
                ServerThread serverthread = new ServerThread();
                //将客户代理推入同步栈
                theStack.push(angent);
                //启动服务线程
                serverthread.start();
            }
            
            //关闭服务
            serversocket.close();
            
        }
        catch(IOException e)
        {
            System.err.println(e.getMessage());
        }
    }

}