server.java

用JAVA写的聊天室程序

import java.net.*;
import java.sql.*;

public class Server

{
	ServerSocket server;
	Socket fromClient;
	Thread serverThread;

	
	public Server()
	{
		if(ConToSql())
			OpenSocket();
	}
	
	//test Sql Server
	boolean ConToSql()
	{
		try
        {
        	//加载驱动程序 Class.forName(JDBC 驱动程序名);
			Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
        	//连接数据库 Connection 连接变量=DriverManager.getConnection(
        	//	"jdbc:odbc:数据源,用户帐号密码);
			Connection con=DriverManager.getConnection("jdbc:odbc:LocalServer","sa","1629");
			
        	System.out.println("SQL Server connected....");
			//执行SQL语句,Statement state=连接变量.createStatement();
			Statement state=con.createStatement();
			PreparedStatement stat;
			ResultSet rs;
			//TestBase
			rs=state.executeQuery("SELECT * FROM master..sysdatabases");
			while(rs.next())
			{//检测数据库是否存在
            	if("ChatRoom".equals(rs.getString("name").trim()))
             	{
               		break;
             	}
           	}
           	if(!rs.next())
           	{//创建数据库
				stat=con.prepareStatement("Create database ChatRoom");
				try
				{
					stat.executeUpdate();
           		//state.executeQuery("Create database ChatRoom");
	           		System.out.println("Auto create DataBase:ChatRoom....");
	           	}
	           	catch(Exception e)
	           	{
	           		System.out.println("Auto create database failed....\n"+e);
	           		return false;
	           	}

           	}
           	
           	//TestTabl
			rs=state.executeQuery("SELECT * FROM ChatRoom..sysobjects");
			
			while(rs.next())
			{//检测数据表是否存在
				if("Userlist".equals(rs.getString("name").trim())&&"U".equals(
					rs.getString("type").trim()))
				{
					break;
				}
			}
			if(!rs.next())
			{//创建数据表
				stat=con.prepareStatement("CREATE TABLE ChatRoom..Userlist(ID varchar(50) PRIMARY KEY ,Pass varchar(50))");
				try
				{
           			stat.executeUpdate();
	           		System.out.println("Auto create DataTable:Userlist...");

	           	}
				catch(Exception e)
	           	{
	           		System.out.println("Auto create datatable failed....\n"+e);
	           		return false;
	           	}
			}
        	return true;
        }
        catch(Exception e)
        {
          	System.out.println(e.getMessage());
        }
        return false;
	}
	
	void OpenSocket()
	{
		try
		{
			server=new ServerSocket(1629);
			new Socking(server);
			System.out.println("Server Socket opened....");
		}
		catch(Exception e)
		{
			System.out.println("Could not start server....\n"+e);
		}
		
	}

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