import java.io.bufferedreader;
import java.io.ioexception;
import java.io.printwriter;
import java.sql.sqlexception;

import util.*;
/*
 *
 * @author zhang
 * 完成客户端请求处理
 *
 */
public class serverthread extends thread{
 private final int  error=0; //查询出错
 private final int  n_valide=1;//不合法
 private final int  valide=2;//合法
 private angent angent; 
 private printwriter out;
 private string userid;
 private string password;
 private chatprotocol cp;
 
 public serverthread(angent aangent) {
  angent=aangent;
  userid=angent.getuserid();//得到用户的帐号密码
  password=angent.getpassword();
  cp=new chatprotocol(angent);//根据聊天内容建立一个protocol对象
 }

 public void run() {
  int i=isvalid();
  out.println(i);/*向客户端发送验证信息*/
  if(i<valide) this.stop(); //本线程中止
  //登陆成功,进行消息处理和转接
     cp.chat();//开始聊天
  
 }
 private int isvalid() {//验证用户的合法性
  string sql="select from user where userid=? and password=?";
  try {
   return sqlfactory.getpasssql().isvalidate(sql,userid,password)?valide:n_valide;
  } catch (sqlexception e) {
   system.out.println("用户验证查询时出错");
   e.printstacktrace();
   return error;
  }
 }
}