JAVA学习笔记(六十)- 网络编程登录实例

客户端

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

/*
 * 客户端
 */
public class LoginClient {
    public static void main(String[] args) {
        try {
            //1.创建客户端Socket，指定服务器地址和端口号,同时建立连接
            Socket socket=new Socket("localhost", 8888);
            //2.获取输出流，向服务器发送信息
            OutputStream os=socket.getOutputStream();
            //PrintWriter pw=new PrintWriter(os);//封装为打印流
            ObjectOutputStream oos=new ObjectOutputStream(os);
            User user=new User("admin", "123");
            oos.writeObject(user);//序列化对象
            socket.shutdownOutput();//关闭当前输出流
            //3.获取输入流，并读取服务器端的响应信息
            InputStream is=socket.getInputStream();
            BufferedReader br=new BufferedReader(new InputStreamReader(is));
            String reply=br.readLine();
            while(reply!=null){
                System.out.println("我是客户端，服务器说："+reply);
                reply=br.readLine();
            }
            socket.shutdownInput();
            //4.关闭资源
            br.close();
            is.close();
            oos.close();
            os.close();
            socket.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

标题

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

/*
 * 服务器端
 */
public class LoginServer {
    public static void main(String[] args) {
        try {
            ServerSocket serverSocket=new ServerSocket(8888);
            System.out.println("******服务器即将启动，等待客户端的连接");
            int count=0;//统计客户端数量
            // 循环监听等待客户端的连接
            while(true){
                Socket socket=serverSocket.accept();
                //创建一个新的线程
                ServerThread thread=new ServerThread(socket);
                thread.start();//启动线程

                count++;
                System.out.println("客户端数量："+count);
                System.out.println("客户端IP："+socket.getInetAddress().getHostAddress());
            }
        } catch (IOException e) {
            e.printStackTrace();
        } 
    }
}

服务器端线程处理类

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

/*
 * 服务器端线程处理类
 */
public class ServerThread extends Thread {
    //与本线程相关的Socket
    Socket socket=null;

    public ServerThread(Socket socket){
        this.socket=socket;
    }

    //线程执行的操作
    @Override
    public void run() {
        InputStream is=null;
        ObjectInputStream ois=null;
        OutputStream os=null;
        PrintWriter pw=null;
        try {
            is=socket.getInputStream();//字节流
            ois=new ObjectInputStream(is);
            User user=(User) ois.readObject();
            System.out.println("用户名："+user.getUsername());
            System.out.println("密码："+user.getPassword());
            socket.shutdownInput();//关闭当前输入流
            os=socket.getOutputStream();
            pw=new PrintWriter(os);
            pw.println("欢迎您！");
            pw.flush();
            socket.shutdownOutput();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } finally{
            try {
                if(pw!=null)
                    pw.close();
                if(os!=null)
                    os.close();
                if(ois!=null)
                    ois.close();
                if(is!=null)
                    is.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

}

标题

import java.io.Serializable;

/*
 * 实体类User
 */
public class User implements Serializable {

    private static final long serialVersionUID = 6682618522883563864L;
    private int id;
    private String username;
    private String password;

    public User() {
        super();
    }

    public User(String username, String password) {
        super();
        this.username = username;
        this.password = password;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public static long getSerialversionuid() {
        return serialVersionUID;
    }
}