server.java

彷qq聊天工具代码

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

class ServerThread extends Thread
{     //继承线程
      private Socket socket;//定义套接口 
      private BufferedReader in;//定义输入流
      private PrintWriter out;//定义输出流
      int no;//定义申请的jicq号码
      
      
      public ServerThread(Socket s) throws IOException 
	  {//线程构造函数
           socket=s;//取得传递参数
           in=new BufferedReader(new InputStreamReader(socket.getInputStream()));//创建输入流
           out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);//创建输出流
           start();//启动线程
      }

      public void run(){//线程监听函数
      try
	  { 
      	  while(true)
      	  {
               String str=in.readLine();//取得输入字符串
               
               if(str.equals("end"))
               	   break;//如果是结束就关闭连接
               else if(str.equals("login")) 
               {//如果是登录
                   try
				   { 
                   	  Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");//连接数据库
                      Connection c=DriverManager.getConnection("jdbc:odbc:javaicq","sa","sa");
                      String sql="select nickname,password from icq where icqno=?";                                                               
                      //准备从数据库选择呢称和密码                                                            
                      PreparedStatement prepare=c.prepareCall(sql);//设定数据库查寻条件
                      String icqno=in.readLine();
                      int g=Integer.parseInt(icqno);//取得输入的jicq号码
                      System.out.println(icqno);
                      String passwd=in.readLine().trim();//取得输入的密码
                      System.out.println(passwd);
                      prepare.clearParameters();
                      prepare.setInt(1,g);//设定参数
                      ResultSet r=prepare.executeQuery();//执行数据库查寻
                      if(r.next())
                      {//以下比较输入的号码于密码是否相同
                         String pass=r.getString("password").trim();
                         System.out.println(pass);
                         
                         if(passwd.regionMatches(0,pass,0,pass.length()))
                         { 
                         	out.println("ok");
                            //如果相同就告诉客户ok
                           //并且更新数据库用户为在线
                           //以及注册用户的ip 地址
                           //*************register ipaddress
                            String setip="update icq set ip=? where icqno=?";
                            PreparedStatement prest=c.prepareCall(setip);
                            prest.clearParameters();
                            prest.setString(1,socket.getInetAddress().getHostAddress());
                            prest.setInt(2,g);
                            int set=prest.executeUpdate();
                            System.out.println("ip="+socket.getInetAddress().getHostAddress()+"   "+set);
                            //*************ipaddress
                            //set status online
                            String status="update icq set status=1 where icqno=?";
                            PreparedStatement prest2=c.prepareCall(status);
                            prest2.clearParameters();
                            prest2.setInt(1,g);
                            int set2=prest2.executeUpdate();
                            System.out.println("status = 1  "+set2);
                            //set online
                          }
                         //否者告诉客户失败
                          else 
                          	out.println("false");
                         
                         r.close();
                         c.close();
                      }
                      else
                      { 
                      	 out.println("false");
                         System.out.println("false");
                         r.close();
                         c.close();
                       }
                    }
                    catch (Exception e)
					{    
                    	e.printStackTrace();
                    }
                    socket.close();
                }//end login
             //登录结束
               
                //以下为处理客户的新建请求    
               else if(str.equals("new"))
               {
                   try
				   {  Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");//连接数据库
                      Connection c2=DriverManager.getConnection("jdbc:odbc:javaicq","sa","sa");
                      String newsql="insert into icq(nickname,password,email,info,place,pic) values(?,?,?,?,?,?)";
                      //准备接受用户的呢称，密码，email，个人资料，籍贯，头像等信息
                      PreparedStatement prepare2=c2.prepareCall(newsql);
                      String nickname=in.readLine().trim();
                      String password=in.readLine().trim();
                      String email=in.readLine().trim();
                      String info=in.readLine().trim();
                      String place=in.readLine().trim();
                      int picindex=Integer.parseInt(in.readLine());
                      System.out.println("nickname:"+nickname);
                      System.out.println("password:"+password);
                      System.out.println("email:"+email);
                      System.out.println("info:"+info);
                      System.out.println("place:"+place);
                      System.out.println("picindex:"+picindex);
                      prepare2.clearParameters();
                      prepare2.setString(1,nickname);
                      prepare2.setString(2,password);
                      prepare2.setString(3,email);
                      prepare2.setString(4,info);
                      prepare2.setString(5,place);
                      prepare2.setInt(6,picindex);
                      int r3=prepare2.executeUpdate();//执行数据库添加
                      String sql2="select icqno from icq where nickname=?";
                      //以下告诉客户其注册的号码
                      PreparedStatement prepare3=c2.prepareCall(sql2);
                      prepare3.clearParameters();
                      prepare3.setString(1,nickname);
                      ResultSet r2=prepare3.executeQuery();
                      while(r2.next())
                      {
                         
                         no=r2.getInt(1);
                         System.out.println(no);
                      }
                      out.println(no);
                      out.println("ok");
                      c2.close();
                //完毕
                   }
                   catch (Exception e)
				   {
                   	  e.toString();
                   	  e.printStackTrace();
                   	  out.println("false");
                   }
                   socket.close();
                   
                }//end new
               //新建用户结束
               //以下处理用户查找好友
                else if(str.equals("find"))
                {
                   try
				   {
                   	  Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
                      Connection c3=DriverManager.getConnection("jdbc:odbc:javaicq","sa","sa");
                      //以下连接数据库，并且返回其他用户的呢称，性别，籍贯，个人资料等信息
                      String find="select nickname,sex,place,ip,email,info from icq";
                      Statement st=c3.createStatement();
                      ResultSet result=st.executeQuery(find);
                      while(result.next())
                      {
                         out.println(result.getString("nickname"));
                         out.println(result.getString("sex"));
                         out.println(result.getString("place"));
                         out.println(result.getString("ip"));
                         out.println(result.getString("email"));
                         out.println(result.getString("info"));
                      }//while end
                      out.println("over");
                      ////////GET ICQNO
                      int d,x;
                      boolean y;
                      //以下返回用户的jicq号码，头像号，及是否在线
                      ResultSet iset=st.executeQuery("select icqno,pic,status from icq");
                      while(iset.next())
                      {
                          d=iset.getInt("icqno");
                          out.println(d);
                          x=iset.getInt("pic");//pic info
                          out.println(x);
                          y=iset.getBoolean("status");
                          if (y)
                          {
                          	out.println("1");
                          }
                          else 
                          {
                          	 out.println("0");
                          }
      
                       }
                     // end send jicqno
                     iset.close();
                     /////////icqno end
                     c3.close();
                     result.close();
                   }
                   catch (Exception e)
				   {
                   	  e.printStackTrace();
                   	  System.out.println("false");
                   }
                   //socket.close();
                }//end find
                //查找好友结束
                //以下处理用户登录时读取其好友资料
               else if(str.equals("friend"))
               {
                  try
				  { 
                  	 Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
                     Connection c4=DriverManager.getConnection("jdbc:odbc:javaicq","sa","sa");
                     //以下连接好友表，返回用户的好友名单
                     String friend="select friend from friend where icqno=?";
                     PreparedStatement prepare4=c4.prepareCall(friend);
                     prepare4.clearParameters();
                     int icqno=Integer.parseInt(in.readLine());
                     System.out.println(icqno);
                     prepare4.setInt(1,icqno);
                     ResultSet r4=prepare4.executeQuery();
                     Vector friendno=new Vector();//该矢量保存好友号码
                     while(r4.next())
                     {
                        friendno.add(new Integer(r4.getInt(1)));
                     }
                     //read friend info
                    //以下告诉客户其好友的呢称，号码，ip地址，状态，头像，个人资料等信息
                     out.println(friendno.size());
                     for(int i=0;i<friendno.size();i++)
                     {
                        String friendinfo="select nickname,icqno,ip,status,pic,email,info from icq where icqno=?";
                        PreparedStatement prepare5=c4.prepareCall(friendinfo);
                        prepare5.clearParameters();
                        prepare5.setObject(1,friendno.get(i));
                        ResultSet r5=prepare5.executeQuery();
                        boolean status;
                        while(r5.next())
                        {
                           out.println(r5.getString("nickname"));
                           out.println(r5.getInt("icqno"));
                           out.println(r5.getString("ip"));
                           status=r5.getBoolean("status");
                           if (status)
                           	    out.println("1");
                           else 
                           {
                           	    out.println("0");
                           }
                           out.println(r5.getInt("pic"));
                           out.println(r5.getString("email"));
                           out.println(r5.getString("info"));
                        } //while
                        r5.close();
                     }//for
                     //发送完毕
                     out.println("over");
                     System.out.println("over");
                     c4.close();