Socket编程

一、前提

多台客户端 / 服务器 之间传递实体类的序列化对象

需要实现四个类，即服务器类，线程类，客户端类及实体类

注：实体类需实现接口：implements Serializable

二、服务器类

服务器类，需要实现两个类：ServerSocket 和 Socket 。且 ServerSocket 初始化需要给个参数（端口号）

.accept() 方法是阻塞当前 socket 对象（socket 在最后是需要关闭的）。处于等待状态，直到客户端发过来信息唤醒它

public class Servlet {

    public static void main(String[] args) {
        // 服务器
        try {
            
            ServerSocket serverSocket = new ServerSocket(5000);
            Socket socket = new Socket();

            // 无限循环，服务器保持开启状态
            while(true){
                socket = serverSocket.accept();    
                ScoktThread st = new ScoktThread(socket);
                st.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

三、线程类

在有参构造方法中初始化 Socket 对象。此线程类根据启动该线程对象来对该对象进行一系列操作。

public class ScoktThread extends Thread{

    private Socket socket;
    
    public ScoktThread(Socket socket) {
        super();
        this.socket = socket;
    }

    @Override
    public void run() {
        // TODO Auto-generated method stub
        super.run();
        InputStream is = null;
        ObjectInputStream ois =null;
        OutputStream os =null;
        
        try {
            // 获取客户端发来的信息
            is = socket.getInputStream();
            ois = new ObjectInputStream(is);
            User user = (User) ois.readObject();
            System.out.println("成功接收到客户端信息："+user.getUserName()+"-"+user.getPwd());
            
            // 获取客户端信息
            InetAddress id = socket.getInetAddress();
            String ip = id.getHostAddress();
            System.out.println("客户 ip 地址:"+ip);
            
            // 反馈信息
            String restr = "我是服务器，欢迎你加入";
            os = socket.getOutputStream();
            os.write(restr.getBytes());
            
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } finally {
            try {
                ois.close();
                is.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

四、客户端类

客户端类，需要实现 Socket 类。初始化时需要两个参数：要连接服务器的 ip 地址（localhost，即127.0.0.1 是本地地址）+对应的端口号

    public static void main(String[] args) {
        // 客户端
        Socket socket;
        try {
            socket = new Socket("localhost",5000);
    
            OutputStream os = socket.getOutputStream();
            ObjectOutputStream oos = new ObjectOutputStream(os);
            User user = new User("小居","居先生");
            oos.writeObject(user);
            
            // 成功发送后需要暂时关闭输出流
            socket.shutdownOutput();
            
            InputStream in = socket.getInputStream();
            BufferedReader br = new BufferedReader(new InputStreamReader(in));
            String str = null;
            while((str = br.readLine())!=null){
                System.out.println(str);
            }
            
            br.close();
            in.close();
            oos.close();
            os.close();
            socket.close();
            
        
        } catch (UnknownHostException e1) {
            e1.printStackTrace();
        } catch (IOException e1) {
            e1.printStackTrace();
        }
    }

五、实体类（不重要）

实体类仅需注意，要实现 Serializable 接口。

/**
 * 用户类
 * @author ice_debj
 *
 */
public class User implements Serializable{

    /**
     * 
     */
    private static final long serialVersionUID = 3144628657162072787L;
    private String userName;
    private String pwd;
    
    public User() {
        super();
    }
    public User(String userName, String pwd) {
        super();
        this.userName = userName;
        this.pwd = pwd;
    }
    
    public String getUserName() {
        return userName;
    }
    public void setUserName(String userName) {
        this.userName = userName;
    }
    public String getPwd() {
        return pwd;
    }
    public void setPwd(String pwd) {
        this.pwd = pwd;
    }    
}

六、总结