clinetthread.java

类似qq的以c/s结构和p2p结构结合的聊天软件。

package com.server;

import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.sql.ResultSet;

class ClientThread implements Runnable
{
	private static Socket clientSocket;
	private static ObjectOutputStream out;
	private static ObjectInputStream in;
	private static String acounts;
	private static String toClientessage;
	private static String sqlStr;
	private static ResultSet rs;
	private static String[] fromClientMessage;
	public ClientThread(Socket socket)
	{
		this.clientSocket=socket;
	}
	public void run()
	{
		 try
		 {
			 Dao dao=new Dao();
			 out=new ObjectOutputStream(clientSocket.getOutputStream());
			 in=new ObjectInputStream(clientSocket.getInputStream());
			 fromClientMessage=(String[])in.readObject();
			 acounts=fromClientMessage[1];
			 if(fromClientMessage[0].equals("withdraw"))
			 {
				 sqlStr="update usergrade set ip='unlogin' where acounts='"+acounts+"'";
				 dao.update(sqlStr);
			 }
			 if(fromClientMessage[0].equals("delete"))
			 {
				 sqlStr="select * from usergrade where acounts='"+acounts+"'";
				 rs=dao.query(sqlStr);
				 rs.next();
				 String newfriends=rs.getString("friends");
				 int index=newfriends.indexOf(fromClientMessage[2]);
				 System.out.println(index);
				 if(index==0)					 
				       
					 {
					       fromClientMessage[2]=fromClientMessage[2]+',';
					       newfriends=newfriends.replaceAll(fromClientMessage[2],"");
					 }
				 else
					  
					 {
					     newfriends=newfriends.replaceAll(','+fromClientMessage[2],"");
					 }
				 System.out.println(newfriends);
				 sqlStr="update usergrade set friends='"+newfriends+"' where acounts='"+acounts+"'";
				 dao.update(sqlStr);
			 }
			 
			 if(fromClientMessage[0].equals("addfriends"))
			 {
				 try
				 {
					 String clientName=fromClientMessage[2];
					 //System.out.println(fromClientMessage[1]+" "+fromClientMessage[2]);
					 sqlStr="update usergrade set friends=friends+','+'"+acounts+"' where acounts='"+clientName+"'";
					 dao.update(sqlStr);
					 toClientessage="success";
				 }catch(Exception ce){toClientessage="failed";}
				 out.writeObject(toClientessage);
			     out.flush();
			 }
			 
			 else
			 {
				 sqlStr="select * from usergrade where acounts='"+acounts+"'";
				 rs=dao.query(sqlStr);
				 if(rs.next())
			      {
					 toClientessage=rs.getString("ip");
			      } 
			     else
			     {
			    	 toClientessage="failed";
			     }
				    out.writeObject(toClientessage);
			        out.flush();
			 }
			 
		 }catch(Exception e){}	     
	}
}