完成客户端请求处理D---ServerThread

　　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;
　　  }
　　 }
　　}