package com.qq.MyClient; |
|
import java.io.IOException; |
import java.io.ObjectInputStream; |
import java.io.ObjectOutputStream; |
import java.net.Socket; |
import java.util.HashMap; |
import java.util.Map; |
import java.util.concurrent.ExecutorService; |
import java.util.concurrent.Executors; |
|
import com.qq.user.SendToMessage; |
import com.qq.user.user; |
public class MyClient { |
public Socket socket; |
public Socket getSocket() { |
return socket; |
} |
ExecutorService threadPool; |
public boolean fistLogin(user u){ |
boolean b= false ; |
try { |
socket= new Socket( "127.0.0.1" , 8000 ); |
threadPool=Executors.newCachedThreadPool(); |
ObjectOutputStream oos= new ObjectOutputStream(socket.getOutputStream()); |
oos.writeObject(u); |
|
ObjectInputStream ois= new ObjectInputStream(socket.getInputStream()); |
SendToMessage sm=(SendToMessage)ois.readObject(); |
if ( "1" .equals(sm.getMessType())){ |
b= true ; |
MyClientThread mct= new MyClientThread(socket); |
magaeMyClientThread.addMyClientThread(u.getUserId(), mct); |
threadPool.execute(mct); |
} |
} catch (Exception e) { |
e.printStackTrace(); |
} |
return b; |
} |
} |