cusloginthread.java

基于JSP的网络聊天室系统,功能明了易懂

package chat;

import chat.*;
import java.util.*;
import java.sql.*;
import java.net.*;
import java.io.*;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2002</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

public class CusLoginThread extends Thread {
   DatagramPacket sendpacket,receivepacket;//声明发送和接收数据包
   DatagramSocket sendsocket;//声明接收DatagramSocket
   UserTempInfo usertemp=new UserTempInfo();

  public CusLoginThread()
  {

  }

  public CusLoginThread(DatagramPacket packet)
  {
     receivepacket=packet;
  }

  public boolean getuserInfo()
  {
    String name=new String();
    String pwd=new String();
  try
  {
    //byte data[] = receivepacket.getData();
    String received = new String(receivepacket.getData());
    char mark = '@';
    int Index = received.indexOf(mark);
    received = received.substring(Index + 1);
    Index = received.indexOf(mark);
    name = received.substring(0, Index); //name
    received = received.substring(Index + 1);
    Index = received.indexOf(mark);
    pwd = received.substring(0, Index); //pwd

    usertemp.name = name;
    usertemp.pwd = pwd;
    usertemp.IP=receivepacket.getAddress();
    usertemp.port=receivepacket.getPort();

  }catch(Exception e)
  {
    return false;
  }
  return true;
  }
  public void sendloginUdp()
  {
    try
    {
      getuserInfo();
    String pac="21@";
    String name=new String();
    String pwd=new String();
    name=usertemp.name;
    pwd=usertemp.pwd;
    usertemp.map=usertemp.getmapbyName(name);
    if(checkLogin(name,pwd))
    {
      if(WholeChatRoomInfo.findName(name)==false)
      {
        WholeChatRoomInfo.wander.addElement(usertemp);//);  //已经是闲逛人员
        pac += "1";
      }
      else
      {
        pac+="2";
      }
    }
    else
      pac+="0";

      //发送
    byte senddata[]=new byte[10];
    senddata=pac.getBytes();
    sendsocket=new DatagramSocket();//初始化

    sendpacket=new DatagramPacket(senddata,pac.length() ,//InetAddress.getByName("127.0.0.1"),3550);
                                  usertemp.IP,usertemp.port);
                                  //receivepacket.getAddress(),receivepacket.getPort());
    sendsocket.send(sendpacket);

    }
    catch(Exception e)
    {

    }
  }
  public void run()
    {
       sendloginUdp();
    }
    public boolean checkLogin(String name,String pwd)
    {
      DataBean db=new DataBean();
      db.connect();
      String sql="select * from user_info where user_name='"
          +name+"' and user_pwd='"+pwd+"'";
      try{
        ResultSet rs=db.openRs(sql);
        if(rs.next())
        {
          return true;
        }
        else
          return false;
        }
        catch(Exception e)
        {
          return false;
        }
    }
}