server.java

java版的简单聊天室程序

import java.io.IOException;

import ocsf.server.AbstractServer;
import ocsf.server.ConnectionToClient;

/**
 * @author new
 */
public class Server extends AbstractServer
{
        protected void handleMessageFromClient(Object msg, ConnectionToClient client)
        {
        	/*
        	 *	Do whatever you want when receive message from client
        	 */
                this.sendToAllClients(msg);
                System.out.println("server:receive "+(String)msg+" from "+client.getName());
        }

        public Server(int port)
        {
                super(port);
        }
        public static void main(String[] args)
        {
                int port=11111;
                Server server=new Server(port);
                try
                {
                        server.listen();
                	System.out.println("Server started.");
                        
                        //Sleep 100 seconds.
                        //During this time, the server processes messages.
                        
                        Thread.sleep(100*1000);
                        server.close();
                        System.out.println("Server finished.");
                }
                catch (IOException e)
                {                        
                        e.printStackTrace();
                }
                catch (InterruptedException e)
                {
                        e.printStackTrace();
                }
        }       
}