客户端的监听

[java]代码库

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