一个聊天室中遇到的问题!

王朝java/jsp·作者佚名  2006-01-09
窄屏简体版  字體: |||超大  

这个聊天室是用java写的,其中一部分的源代码是这样的,但是调试运行不了, 还请各位大侠指点:

import java.awt.event.*;

import java.net.*;

import java.io.*;

import java.util.*;

import javax.swing.Timer;

public class AppServer implements Runnable

{

ServerSocket server;

Socket fromClient;

Thread serverThread;

public AppServer()

{

System.out.println("FunChat server start......");

try

{

server=new ServerSocket(1001);

serverThread=new Thread(this);

serverThread.start();

}

catch(Exception e)

{

System.out.println("cannot start the thread:"+e);

}

}//end of AppServer

public static void main(String args[])

{

new AppServer();

}

public void run()

{

try

{

while(true)

{

fromClient=server.accept();

Connect con=new Connect(fromClient);

}

}

catch(Exception e)

{

System.out.println("cannot listen to the client"+e);

}//end of catch

}//end of run

}//end of AppServer

class Connect

{

ObjectOutputStream streamToClient;

int ctr=0;

BufferedReader streamFromClient;

static Vector vector;

static Vector vctrList;

String message="";

static String str=new String("UsrList");

static

{

vector=new Vector(1,1);

vctrList=new Vector(1,1);

vctrList.addElement((String)str);

}

int verify(String mesg)

{

try

{

RandomAccessField RAS = new RandomAccessFile("UsrPwd.txt","r");

int i = 0;

Sting str = "";

while((RAS.getFilePointer())!=(RAS.length()))

{

str = RAS.readLine();

if(str.equals(mesg))

{

ctr=1;

break;

}

}

RAS.close();

}

catch(Exception e)

{

System.out.print("Exception Occurred:"+e);

}

return ctr;

}

int checkFile(String mesg)

{

int chk =1;

try

{

RandomAccessFile RS = new RandomAccessFile("UsrPwd.txt","r");

int i = 0;

String str = "";

String colon = new String(":");

int index = ((String)mesg).lastIndexof(colon);

String userName = (String)mesg.substring(0,index);

while((RS.getFukeOiubter())!=(int)(RS.length()))

{

str = RS.readLine();

int index1 = ((String)str).lastIndexof(colon);

String usrName = (String)str.substring(0,index1);

if(usrName.equals(userName))

{

chk = 0;

break;

}

}

}

catch(Exception e)

{

System.out.print("Exception Occurred:"+e);

}

return chk;

}

public Connect(Socket inFromClient)

{

String msg = "";

String mesg ="";

try

{

streamFromClient = new BufferedReader(new InputStreamReader(inFromClient.getInputStream()));

streamToClient = new ObjectOutputStream(inFromClient.getOutputStream());

msg = streamFromClient.rreadLine();

if((msg.equals("From Timer")))

{

streamToClient.writeObject.writeObject(vector);

streamToClient.writeObject(vctrList);

}

else if(msg.equals("LoginInfo"))

{

msg = streamFromClient.readLine();

int ver = verify(msg);

if(ver==1)

{

String colon = new String(":");

int index = ((String)msg).lastIndexOf(colon);

String userName = (String)msg.substring(0,index);

if(!(vctrList.indexOf((String)userName)0))

{

streamToClient.writeObject("Welcome");

vctrList.addElement((String)userName);

}

}

else

{

streamToClient.writeObject("Ligin denied");

}

}

else if(msg.equals("RegisterInfo"))

{

msg = streamFromClient.readLine();

int ret = checkFile(msg);

if(ret==0)

streamToClient.writeObject("User Exists");

if(ret==1)

{

FileOutputStream out = new FileOutputStream("UsrPwd.txt",true);

PrintStream p = new PrintStream(out);

p.println();

p.println(msg);

p.close();

streamToClient.writeObject("Registered");

}

}

else if (msg.equals("User Logout"));

{

String remUser = streamFromClient.readLine();

boolean b = vctrList.removeElement((String)remUser);

}

else

{

message = message+msg;

vector.addElement((String)message);

streamToClient.writeObject(vector);

}

}

catch(Exception e)

{

System.out.println("cannot get the client stream connect"+ e);

}

finally

{

try

{

inFromClient.close();

}

catch(IOException e)

{

System.out.println("Exception Occurred:"+e);

}

}

}

}

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航