通过Socket实现TCP编程（十二）

原文链接：https://www.cnblogs.com/hysum/p/7531529.html

Socket通信：

TCP协议是面向对象连接、可靠的、有序的，以字节流的方式发送数据。
基于TCP协议实现网络通信的类：
- 客户端----Socket类
- 服务器端----ServerSocket类

一、Socket通信模型

(1) 在服务端建立一个ServerSocket,绑定相应的端口，并且在指定的端口进行侦听，等待客户端的连接。

(2) 当客户端创建连接Socket并且向服务端发送请求。

(3) 服务器收到请求，并且接受客户端的请求信息。一旦接收到客户端的连接请求后，会创建一个链接socket，用来与客户端的socket进行通信。通过相应的输入/输出流进行数据的交换，数据的发送接收以及数据的响应等等。

(4) 当客户端和服务端通信完毕后，需要分别关闭socket，结束通信。

Socket通信实现步骤：

(1) 创建ServerSocket和Socket

(2) 打开链接到Socket的输入/输出流

(3) 按照协议对Socket进行读/写操作

(4) 关闭输入输出流、关闭Socket

二、Socket和ServerSocket常用方法

ServerSocket常用方法：

ServerSocket(int port)——创建并绑定到特定端口的服务器套接字
accept()——侦听并接受到此套接字的连接
close()——关闭此套接字 getInetAddress()——得到ServerSocket对象绑定的IP地址。如果ServerSocket对象未绑定IP地址，返回0.0.0.0。
getLocalPort()——返回此套接字在其上侦听的端口

Socket常用方法：

Socket(InetAddress address, int port)——创建一个套接字并将其连接到指定ip地址的指定端口号
Socket(String host, int port)——创建一个套接字并将其连接到指定主机上的指定端口号
close()——关闭此套接字
getInetAddress()——返回套接字连接的地址
getInputStream()——返回此套接字的输入流
getOutputStream——返回此套接字的输出流

三、编程实现基于TCP/IP的用户登录小程序

1. 服务端

创建ServerSocket对象，绑定监听端口
通过accept()方法监听客户端请求
连接建立后，通过输入流读取客户端发送的请求信息
通过输出流向客户端发送响应信息
关闭相关资源

public class TcpServer {

    public static void main(String[] args) throws IOException{
        // 1.创建一个服务器端的Socket,即ServerSocket，指定绑定的端口
        ServerSocket ss = new ServerSocket(8888);
        // 2.调用accept方法开始监听，等待客户端的连接
        System.out.println("服务器即将启动，等待客户端的连接...");
        Socket so = ss.accept();// accept方法返回Socket实例
        // 3.获取一个输入流，并读取客户端信息
        InputStream is = so.getInputStream();// 字节输入流
        InputStreamReader isr = new InputStreamReader(is);// 将字节输入流包装成字符输入流
        BufferedReader br = new BufferedReader(isr);// 加上缓冲流，提高效率
        String info = null;
        while ((info = br.readLine()) != null) {// 循环读取客户端信息
            System.out.println("我是服务器，客户端说：" + info);

        }
        so.shutdownInput();// 关闭输入流
        // 4.获取一个输出流，向客户端输出信息,响应客户端的请求
        OutputStream os = so.getOutputStream();// 字节输出流
        PrintWriter pw = new PrintWriter(os);// 字符输出流
        BufferedWriter bw = new BufferedWriter(pw);// 缓冲输出流
        bw.write("欢迎您！");
        bw.newLine();
        bw.flush();

        // 5.关闭资源
        os.close();
        pw.close();
        bw.close();
        br.close();
        isr.close();
        is.close();
        so.close();
        ss.close();
    }
}

View Code

2. 客户端

创建Socket对象，指明需要连接的服务器的地址和端口号
连接建立后，通过输出流向服务器端发送请求信息
通过输入流获取服务器相应的信息
关闭相关资源。

public class TcpClient {

    public static void main(String[] args) throws IOException{
        // 1.创建客户端Socket，指定服务器地址和端口
        Socket so = new Socket("localhost", 8888);// 端口号要和服务器端相同
        // 2.获取输出流，向服务器端发送登录的信息
        OutputStream os = so.getOutputStream();// 字节输出流
        PrintWriter pw = new PrintWriter(os);// 字符输出流
        BufferedWriter bw = new BufferedWriter(pw);// 加上缓冲流
        bw.write("用户名：admin;密码：123");
        bw.flush();
        so.shutdownOutput();// 关闭输出流
        // 3.获取输入流，得到服务端的响应信息
        InputStream is = so.getInputStream();
        InputStreamReader isr = new InputStreamReader(is);
        BufferedReader br = new BufferedReader(isr);
        String info = null;
        while ((info = br.readLine()) != null) {
            System.out.println("我是客户端，服务器说:" + info);
        }

        // 4.关闭资源
        bw.close();
        pw.close();
        os.close();
        so.close();
    }
}

View Code

四、使用多线程实现多客户端的通信

多线程步骤：

服务器端创建ServerSocket，循环调用accept()等待客户端连接。
客户端创建一个socket并请求和服务器端连接。
服务器端接收客户端请求，创建socket与该客户建立专线连接。
建立连接的两个socket在一个单独的线程上对话。
服务器端继续等待新的连接。

新建一个服务器线程处理类ServerThread，该类继承Thread类：

public class TcpThreadServer {

    public static void main(String[] args) {
        try {
            // 1.创建一个服务器端的Socket,即ServerSocket，指定绑定的端口
            ServerSocket ss = new ServerSocket(8888);

            System.out.println("服务器即将启动，等待客户端的连接...");
            Socket so = null;
            // 记录客户端的数量
            int count = 0;
            // 循环侦听等待客户端的连接
            while (true) {
                // 2.调用accept方法开始监听，等待客户端的连接
                so = ss.accept();// accept方法返回Socket实例
                // 创建一个新的线程
                ServerThread st = new ServerThread(so);
                // 启动线程，执行与客户端的交互
                st.start();// 注意是start不是run
                count++;
                System.out.println("此时客户端数量为：" + count);
                InetAddress add = so.getInetAddress();
                System.out.println("当前客户端的ip地址为" + add.getHostAddress());
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

View Code

服务端

public class TcpThreadServer {

    public static void main(String[] args) {
        try {
            // 1.创建一个服务器端的Socket,即ServerSocket，指定绑定的端口
            ServerSocket ss = new ServerSocket(8888);

            System.out.println("服务器即将启动，等待客户端的连接...");
            Socket so = null;
            // 记录客户端的数量
            int count = 0;
            // 循环侦听等待客户端的连接
            while (true) {
                // 2.调用accept方法开始监听，等待客户端的连接
                so = ss.accept();// accept方法返回Socket实例
                // 创建一个新的线程
                ServerThread st = new ServerThread(so);
                // 启动线程，执行与客户端的交互
                st.start();// 注意是start不是run
                count++;
                System.out.println("此时客户端数量为：" + count);
                InetAddress add = so.getInetAddress();
                System.out.println("当前客户端的ip地址为" + add.getHostAddress());
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

View Code