hello/hi的简单的网络聊天程序

Posted 2021-03-23 double-wjl

一、TCP/IP协议族

　　要想理解socket首先得熟悉一下TCP/IP协议族， TCP/IP（Transmission Control Protocol/Internet Protocol）即传输控制协议/网间协议，定义了主机如何连入因特网及数据如何在它们之间传输的标准，从字面意思来看TCP/IP是TCP和IP协议的合称，但实际上TCP/IP协议是指因特网整个TCP/IP协议族。不同于ISO模型的七个分层，TCP/IP协议参考模型把所有的TCP/IP系列协议归类到四个抽象层中。

　　　　　　　　　　Internet 的通信协议层次划分

　　在Internet层，解析IP地址，寻找通往目标IP的目的地的下一个路由地址。在网络接口层，则是寻找响应的硬件（MAC）地址。数据流以及网络拓扑结构如下图所示。

　　　数据流以及网络拓扑结构

　　我们知道两个进程如果需要进行通讯最基本的一个前提能够唯一的标示一个进程，在本地进程通讯中我们可以使用PID来唯一标示一个进程，但PID只在本地唯一，网络中的两个进程PID冲突几率很大，这时候我们需要另辟它径了，我们知道IP层的ip地址可以唯一标示主机，而TCP层协议和端口号可以唯一标示主机的一个进程，这样我们可以利用ip地址＋协议＋端口号唯一标示网络中的一个进程。 

二、socket通信

　　能够唯一标示网络中的进程后，它们就可以利用socket进行通信了，什么是socket呢？我们经常把socket翻译为套接字，socket是在应用层和传输层之间的一个抽象层，它把TCP/IP层复杂的操作抽象为几个简单的接口供应用层调用已实现进程在网络中通信。socket起源于UNIX，在Unix一切皆文件哲学的思想下，socket是一种"打开—读/写—关闭"模式的实现，服务器和客户端各自维护一个"文件"，在建立连接打开后，可以向自己文件写入内容供对方读取或者读取对方内容，通讯结束时关闭文件。

 　　　　Socket通信与网络协议之间的层次关系

　　socket是"打开—读/写—关闭"模式的实现，以使用TCP协议通讯的socket为例，其交互流程大概是这样子的

 　　　　　　socket 客户端和服务端建立连接过程

*服务器根据地址类型（ipv4,ipv6）、socket类型、协议创建socket
*服务器为socket绑定ip地址和端口号
*服务器socket监听端口号请求，随时准备接收客户端发来的连接，这时候服务器的socket并没有被打开
*客户端创建socket
*客户端打开socket，根据服务器ip地址和端口号试图连接服务器socket
*服务器socket接收到客户端socket请求，被动打开，开始接收客户端请求，直到客户端返回连接信息。这时候socket进入阻塞状态，所谓阻塞即accept()方法一直到客户端返回连接信息后才返回，开始接收下一个客户端谅解请求
*客户端连接成功，向服务器发送连接状态信息
*服务器accept方法返回，连接成功
*客户端向socket写入信息
*服务器读取信息
*客户端关闭
*服务器端关闭

三、Java Socket API的使用

  （1）建立一个服务器ServerSocket，并同时定义好ServerSocket的监听端口；
  （2）ServerSocket 调用accept()方法，使之处于阻塞。
  （3）创建一个客户机Socket,并设置好服务器的IP和端口。
  （4）客户机发出连接请求，建立连接。
  （5）分别取得服务器和客户端ServerSocket 和Socket的InputStream和OutputStream.
  （6) 利用Socket和ServerSocket进行数据通信。

四、基于java的socket编程代码

服务器端代码：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) throws IOException {
        ServerSocket server = new ServerSocket(1234);//服务器端口为1234

        System.out.println("服务器准备就绪～");

        // 等待客户端连接
        for (; ; ) {
            // 得到客户端
            Socket client = server.accept();
            // 客户端构建异步线程
            ClientHandler clientHandler = new ClientHandler(client);
            // 启动线程
            clientHandler.start();
        }
    }
    /**
     * 客户端消息处理
     */
    private static class ClientHandler extends Thread {
        private Socket socket;
        private boolean flag = true;

        ClientHandler(Socket socket) {
            this.socket = socket;
        }

        @Override
        public void run() {
            super.run();
            System.out.println("新客户端连接：" + socket.getInetAddress() +
                    " P:" + socket.getPort());
            try {
                // 得到打印流，用于数据输出；服务器回送数据使用
                PrintStream socketOutput = new PrintStream(socket.getOutputStream());
                // 得到输入流，用于接收数据
                BufferedReader socketInput = new BufferedReader(new InputStreamReader(
                        socket.getInputStream()));
                InputStream in = System.in;
                BufferedReader input = new BufferedReader(new InputStreamReader(in));


                do {
                    // 从客户端拿到一条数据
                    String str = socketInput.readLine();
                    if ("bye".equalsIgnoreCase(str)) {
                        flag = false;
                        // 回送
                        socketOutput.println("bye");
                    } else {
                        // 打印到屏幕。并回送数据长度
                        System.out.println("client:"+str);
                        String s = input.readLine();
                        socketOutput.println(s);
                    }
                } while (flag);

                socketInput.close();
                socketOutput.close();

            } catch (Exception e) {
                System.out.println("连接异常断开");
            } finally {
                // 连接关闭
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            System.out.println("客户端已退出：" + socket.getInetAddress() +
                    " P:" + socket.getPort());
        }
    }
}

客户端代码：

import java.io.*;
import java.net.Inet4Address;
import java.net.InetSocketAddress;
import java.net.Socket;

public class Client {
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket();
        // 连接本地，端口2500；
        socket.connect(new InetSocketAddress(Inet4Address.getLocalHost(), 2500));

        //打印客户端以及服务器相关信息
        System.out.println("已发起服务器连接，并进入后续流程～");
        System.out.println("客户端信息：" + socket.getLocalAddress() + " P:" + socket.getLocalPort());
        System.out.println("服务器信息：" + socket.getInetAddress() + " P:" + socket.getPort());

        try {
            // 发送接收数据
            send(socket);
        } catch (Exception e) {
            System.out.println("异常关闭");
        }

        // 释放资源
        socket.close();
        System.out.println("客户端已退出～");

    }

    private static void send(Socket client) throws IOException {
        // 构建键盘输入流
        InputStream in = System.in;
        BufferedReader input = new BufferedReader(new InputStreamReader(in));


        // 得到Socket输出流，并转换为打印流
        OutputStream outputStream = client.getOutputStream();
        PrintStream socketPrintStream = new PrintStream(outputStream);


        // 得到Socket输入流，并转换为BufferedReader
        InputStream inputStream = client.getInputStream();
        BufferedReader socketBufferedReader = new BufferedReader(new InputStreamReader(inputStream));

        boolean flag = true;
        do {
            // 键盘读取一行
            String str = input.readLine();
            socketPrintStream.println(str);
            // 从服务器读取响应信息，如果是bye，退出循环
            String echo = socketBufferedReader.readLine();
            if ("bye".equalsIgnoreCase(echo)) {
                flag = false;
            }else {
                System.out.println("server:"+echo);
            }
        }while (flag);

        // 资源释放
        socketPrintStream.close();
        socketBufferedReader.close();

    }
}

五、实验结果

    

六、Java Socket API和Linux Socket API关系探究

1、 java与linux api调用关系

我们知道java的socket实现是通过调用操作系统的socket api实现的,下面图表展示其调用关系

 

从java代码到linux内核是如何一步步调用的？

2、new ServerSocket(1234)
ServerSocket serverSocket = new ServerSocket(1234);
从java角度看，上一行代码就是创建一个端口号为:1234的ServerSocket.
但从底层实现来讲,它包含了如下三个重要操作

*socket创建
*socket绑定
*socket的侦听

 socket创建

　　若要执行网络I/O，进程首先就要调用一个socket函数，并会指定一个期望的协议类型和套接口类型，socket函数成功的时候会返回一个小的非负整数, 因在Linux中一切皆文件，所以这个整数表示一个文件描述符，此时会创建socket对应的结构，并将其和一个已经打开的文件对应。

socket绑定

　　对于TCP协议，bind函数可以和一个IP和一个端口绑定；此时该套接口处于TCP_CLOSE状态，如果不绑定端口号，则内核会为该套接口绑定一个临时的端口，如果不绑定IP地址，对于服务端而言，内核就会将客户端发送的SYN的目的IP地址作为服务器的源IP地址。

socket的侦听

　　由上面可以知道，listen会将主动转为被动连接，会将套接口由closed状态转换为linsten状态，并且维护了两个队列。

此时会和客户端进行三次握手来建立连接

 3、Socket socket = server.accept()

　　linux中由TCP服务器调用，从已完成的连接队列的队头返回下一个已完成连接；成功则会返回由内核创建的新的描述符；在并发服务器中，accept()返回后，服务器会调用fork函数，创建一个子进程，由该子进程来和客户端进行通讯，此时套接口对应文件描述符的引用计数会增加，同时父进程会关闭该已连接套接字，即会将引用计数减少。然后在原有的监听套接口上，继续监听有无其他连接，当由连接的时候，再次accept处理连接。

 

参考链接：https://blog.csdn.net/vipshop_fin_dev/article/details/102966081