server.java

java版虚拟社区,在mysql上运行.

import serverpack.Process;
import serverpack.Monitor;
import serverpack.MyMessage;

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

import javax.swing.JFrame;
import javax.swing.UIManager;
import java.awt.*;   
import java.awt.event.*;





public class Server
{

	private Process pro;
	private MyMessage mm;
	public Server()
	{
		
		
		
	}
	public static void main(String args[])
	{
		try 
		{
            // 将LookAndFeel设置成Windows样式
            UIManager.setLookAndFeel("com.sun.java.swing.plaf.windows.WindowsLookAndFeel");
        } 
		catch (Exception ex) 
        {
            ex.printStackTrace();
        }
		

		try
		{
			Monitor mo = new Monitor();		/////////////////////////////////
			mo.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);/////////////////
			mo.setVisible(true);
			
			Process pro = new Process(mo);
			MyMessage mm = new MyMessage();

			mm.SetType("Init");
			mm.SetNum(0);
			if(!pro.MessagePro(mm))
			{
				return;
			}
			
			ServerSocket s = new ServerSocket(8088);
			
			System.out.println("Server start..."+s);
			mo.appendmessage("Server start..."+"\n"+s+"\n");
			
			while(true)
		    {
				Socket socket=s.accept();
				System.out.println("Connection accept:"+socket);
				mo.appendmessage("Connection accept:"+"\n"+socket+"\n");
				try
				{
					new ServerCommunicate(socket,mo);
				}
		    	catch(IOException e)
		    	{
		    		System.out.println("exception in new servercommunicate");
		    		e.printStackTrace();
		    	}
		 
		    }
		}
		catch(IOException e)
		{
			System.out.println("exception in serversocket");
			e.printStackTrace();
		}
	}
}