socket多線程方式案例

記下來,方便以后查看

 

User類

package com.xujingyang.ThreadSocket;

import java.io.Serializable;

public class User implements Serializable {
    private String name;
    private int age;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    public User(String name, int age) {
        super();
        this.name = name;
        this.age = age;
    }

    public User() {
    }

    @Override
    public int hashCode() {
        final int prime = 31;
        int result = 1;
        result = prime * result + age;
        result = prime * result + ((name == null) ? 0 : name.hashCode());
        return result;
    }

    @Override
    public boolean equals(Object obj) {
        if (this == obj)
            return true;
        if (obj == null)
            return false;
        if (getClass() != obj.getClass())
            return false;
        User other = (User) obj;
        if (age != other.age)
            return false;
        if (name == null) {
            if (other.name != null)
                return false;
        } else if (!name.equals(other.name))
            return false;
        return true;
    }

    @Override
    public String toString() {
        return "User [name=" + name + ", age=" + age + "]";
    }
}

 

客戶端類

package com.xujingyang.ThreadSocket;

import java.io.InputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;

public class Client {
    public static void main(String[] args) throws Exception {
        Socket socket=new Socket("localhost", 9999);//監聽端口
        
        ObjectOutputStream out=new ObjectOutputStream(socket.getOutputStream());//包裝對象流
        
        out.writeObject(new User("小明", 21));//寫入對象
        socket.shutdownOutput();//關閉流的占用
        
        //獲取服務器發過來的消息
        InputStream in = socket.getInputStream();
        byte[] b=new byte[1024];
        in.read(b);
        System.out.println(new String(b,0,b.length));
        
        //關閉流
        in.close();
        out.close();
        socket.close();
        
    }
}

服務器類

package com.xujingyang.ThreadSocket;

import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) throws Exception {
        ServerSocket socket=new ServerSocket(9999);//監聽端口
        
        //循環監聽接收各個客戶端連接
        while (true) {
            Socket client = socket.accept();
            
            //開啟多線程接受客戶端信息
            ThreadServer ts=new ThreadServer(client);
            new Thread(ts).start();
        }
        
    }
}

 

服務器多線程接收類

package com.xujingyang.ThreadSocket;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.OutputStream;
import java.net.Socket;

/**
 * 多線程接受用戶登陸,把客戶端連接對象傳入作為成員變量
 * @author 徐景洋
 */
public class ThreadServer implements Runnable {

    private Socket client;

    public ThreadServer(Socket client) {
        this.client=client;
    }

    @Override
    public void run() {
        try {
            //包裝對象接收流
            ObjectInputStream in=new ObjectInputStream(client.getInputStream());
            User user = (User) in.readObject();//讀取對象
            
            //比較是否符合標准.符合回答成功,否則失敗
            OutputStream out = client.getOutputStream();
            if((new User("小明",21)).equals(user)){
                out.write("登陸成功".getBytes());
                System.out.println(user);
            }else{
                out.write("登陸失敗".getBytes());
            }
            
            client.shutdownOutput();
            out.close();
            in.close();
            client.close();
            
        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
        }
        
        
    }
    
}