回显服务器(基于TCP)

服务器 0

目录

API学习

ServerSocket

Socket

服务端

思路分析

具体实现

客户端

思路分析

具体实现

运行测试

问题分析 

修改优化

完整代码


在学习了基于UDP实现的回显服务器后,我们学习基于TCP实现的回显服务器

API学习

ServerSocket

ServerSocket是创建TCP服务端Socket的API

构造方法:

方法说明
ServerSocket(int port)创建一个服务端流套接字Socket,并绑定到指定端口

常用方法:

方法说明
Socket accept()开始监听指定端口(创建时绑定的端口),有客户端连接后,返回一个服务端Socket对象,并基于该Socket建立与客户端的连接,否则阻塞等待
void close()关闭此套接字

Socket

Socket是客户端Socket或服务端中接收到客户端连接(accept方法)的请求后,返回的服务端Socket

无论是客户端还是服务端Socket,都是双方建立连接后,保存对端信息以及用来与对方收发数据的。

构造方法:

方法说明
Socket(String host, int port)创建一个客户端流套接字Socket,并与对应IP的主机的对应端口的进程建立连接

常用方法:

方法说明
InetAddress getInetAddress()返回套接字所连接的地址
InputStream getInputStream()返回此套接字的输入流
OutputStream getOutputStream()返回此套接字的输出流

服务端

思路分析

对于服务端,要实现的内容有:

1. 与客户端建立连接

2. 接收客户端发送的请求、读取解析请求

3. 根据请求计算数据响应

4. 将响应返回给客户端

由于服务器要等到客户端发送请求时才能进行接收、解析、计算响应等操作,而服务器不知道客户端什么时候发送请求,因此服务器需要一直“待命”,等待客户端发送请求 

具体实现

1.首先我们需要创建一个ServerSocket对象,并通过构造方法来指定服务器要绑定的端口号

import java.io.IOException;import java.net.ServerSocket;public class TcpEchoServer {    private ServerSocket socket = null;    public TcpEchoServer(int port) throws IOException {        socket = new ServerSocket(port);    }}

2.接下来,我们实现客户端与服务端连接的建立

TCP是有连接的,因此,在进行通信之前,客户端和服务器之间需要建立连接(就像打电话一样,需要一端拨号,另一端接听后,双方才能进行通话)

除了内核建立连接外,还需要服务端进行“接听”(accept操作),才能进行通信

    public void start() throws IOException {        System.out.println("启动服务器");        while (true){            //通过accept方法来“接听”            Socket clientSocket = socket.accept();        }    }

3. 然后通过实现processConnection方法来处理每一次连接建立后的通信(客户端与服务器之间的多次请求响应交互)

此时的实现过程与 基于UDP实现的回显服务器类似,循环读取请求、接收请求并解析、根据请求计算响应最后将响应返回给客户端

需要注意的是,TCP是面向字节流的,传输的基本单位是字节

    //处理连接建立后客户端与服务器之间的多次请求响应    private void processConnection(Socket clientSocket) throws IOException {        System.out.printf("[%s:%d] 客户端上线/n",clientSocket.getInetAddress(),clientSocket.getPort());        try (InputStream inputStream = clientSocket.getInputStream();             OutputStream outputStream = clientSocket.getOutputStream()){            //循环读取请求            while (true){                Scanner scanner = new Scanner(inputStream);                if(!scanner.hasNext()){//读取完毕,断开连接                    System.out.printf("[%s:%d] 客户端下线/n",clientSocket.getInetAddress(),clientSocket.getPort());                    break;                }                //读取请求并解析                String request = scanner.next();                //根据请求计算响应                String response = process(request);                //将响应返回给客户端                //由于直接通过outputStream进行写入不方便在响应末尾添加/n                //因此可以使用PrintWriter进行写入(使用其中的println方法)                PrintWriter printWriter = new PrintWriter(outputStream);                printWriter.println(response);                //不要忘记刷新操作                printWriter.flush();                //打印日志,观察程序执行效果                System.out.printf("[%s:%d] req: %s, resp: %s/n",clientSocket.getInetAddress(),clientSocket.getPort(),                        request, response);            }        }catch (IOException e){            throw new RuntimeException(e);        }finally {            clientSocket.close();        }    }        //根据请求计算响应    public String process(String request) {        return request;    }

客户端

思路分析

 对于客户端需要实现的内容有:

1. 从控制台读取用户输入的内容

2. 将内容构造成TCP请求,并发送给服务器

3. 等待服务器响应,当接收到服务器响应时,解析响应内容

4. 显示响应内容

具体实现

1.首先我们创建一个Socket对象,并在构造方法中传入服务器的ip和端口号

import java.io.IOException;import java.net.Socket;public class TcpEchoClient {    private Socket socket = null;    public TcpEchoClient(String serverIp, int serverPort) throws IOException {        socket = new Socket(serverIp, serverPort);    }}

2. 接下来我们实现客户端的启动(循环读取请求、发送请求、读取响应最后打印响应内容)

    public void start(){        System.out.println("启动客户端");        try (InputStream inputStream = socket.getInputStream();             OutputStream outputStream = socket.getOutputStream()){            Scanner scanner = new Scanner(System.in);//从控制台读取要发送的请求数据            Scanner scannerNetwork = new Scanner(inputStream);//从服务器读取响应            PrintWriter writer = new PrintWriter(outputStream);//通过PrintWriter进行写入操作            while (true){                //从控制台读取请求数据                System.out.print("请输入:");                if(!scanner.hasNext()){//读取完毕,退出循环                    break;                }                String request = scanner.next();//读取请求                //将请求发送给服务器                writer.println(request);//使用println方法来发送数据,使请求末尾带有/n                writer.flush();//刷新缓冲区,使数据及时发送出去                //从服务器读取响应                String response = scannerNetwork.next();                //显示响应内容                System.out.println(response);                                            }        }catch (IOException e){            throw new RuntimeException(e);        }    }

运行测试

在编写完代码后,我们同时运行服务器和客户端,并输入请求观察代码是否存在问题:

启动服务器:

    public static void main(String[] args) throws IOException {        TcpEchoServer server = new TcpEchoServer(9019);        server.start();    }

启动客户端:

    public static void main(String[] args) throws IOException {        TcpEchoClient client = new TcpEchoClient("127.0.0.1", 9019);        client.start();    }

运行测试结果:

服务器:

客户端:

 再运行一个客户端:

运行结果:

此时第二个客户端无响应,当关闭第一个客户端后,此时第二个客户端才能正常工作

问题分析 

为什么会出现这种情况呢?

通过观察服务器代码,我们可以发现:当第一个客户端与服务器建立连接后,服务器就进入processConnection,此时会在scanner.hasNext 阻塞,等待客户端的请求,接收请求后,解析计算响应并返回,然后再次等待请求....,直到该客户端退出后,才能结束processConnection方法,再次进行“接听”

因此,当有新的客户端与服务器建立连接时,虽然新的客户端与服务器在内核层面建立了TCP连接,但服务端未“接听”,因此连接未成功建立,也就无法进行交互。第二个客户端发送的请求存储在服务器的接收缓冲区中,当第一个客户端退出后,服务器就会立即处理第二个客户端之前发送的请求

那应该如何修改代码,使得服务器能够同时与多个客户端建立连接呢?

修改优化

此时使用单线程已经无法满足我们的需求,因此我们考虑使用多线程,主线程负责执行accecpt,每当有一个客户端进行连接,就分配一个新的线程,由这个新线程为客户端提供服务

    public void start() throws IOException {        System.out.println("启动服务器");        while (true){            //通过accept方法来“接听”            Socket clientSocket = socket.accept();            Thread woker = new Thread(()->{                try {                    processConnection(clientSocket);                } catch (IOException e) {                    throw new RuntimeException(e);                }            });            woker.start();        }    }

此时服务器就能够处理多个客户端的请求了

然而,当客户端比较多时,服务器就会频繁地创建和销毁线程,此时,我们可以考虑使用线程池

完整代码

服务端代码:

import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.io.PrintWriter;import java.net.InetAddress;import java.net.ServerSocket;import java.net.Socket;import java.util.Scanner;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class TcpEchoServer {    private ServerSocket socket = null;    public TcpEchoServer(int port) throws IOException {        socket = new ServerSocket(port);    }    public void start() throws IOException {        System.out.println("启动服务器");        ExecutorService pool = Executors.newCachedThreadPool();        while (true){            //通过accept方法来“接听”            Socket clientSocket = socket.accept();           /* Thread woker = new Thread(()->{                try {                    processConnection(clientSocket);                } catch (IOException e) {                    throw new RuntimeException(e);                }            });            woker.start();*/            pool.submit(new Runnable() {                @Override                public void run() {                    try {                        processConnection(clientSocket);                    } catch (IOException e) {                        throw new RuntimeException(e);                    }                }            });        }    }    //处理连接建立后客户端与服务器之间的多次请求响应    private void processConnection(Socket clientSocket) throws IOException {        System.out.printf("[%s:%d] 客户端上线/n",clientSocket.getInetAddress(),clientSocket.getPort());        try (InputStream inputStream = clientSocket.getInputStream();             OutputStream outputStream = clientSocket.getOutputStream()){            //循环读取请求            while (true){                Scanner scanner = new Scanner(inputStream);                if(!scanner.hasNext()){//读取完毕,断开连接                    System.out.printf("[%s:%d] 客户端下线/n",clientSocket.getInetAddress(),clientSocket.getPort());                    break;                }                //读取请求并解析                String request = scanner.next();                //根据请求计算响应                String response = process(request);                //将响应返回给客户端                //由于直接通过outputStream进行写入不方便在响应末尾添加/n                //因此可以使用PrintWriter进行写入(使用其中的println方法)                PrintWriter printWriter = new PrintWriter(outputStream);                printWriter.println(response);                //不要忘记刷新操作                printWriter.flush();                //打印日志,观察程序执行效果                System.out.printf("[%s:%d] req: %s, resp: %s/n",clientSocket.getInetAddress(),clientSocket.getPort(),                        request, response);            }        }catch (IOException e){            throw new RuntimeException(e);        }finally {            clientSocket.close();        }    }    //根据请求计算响应    public String process(String request) {        return request;    }    public static void main(String[] args) throws IOException {        TcpEchoServer server = new TcpEchoServer(9019);        server.start();    }}

客户端代码:

import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.io.PrintWriter;import java.net.Socket;import java.util.Scanner;public class TcpEchoClient {    private Socket socket = null;    public TcpEchoClient(String serverIp, int serverPort) throws IOException {        socket = new Socket(serverIp, serverPort);    }    public void start(){        System.out.println("启动客户端");        try (InputStream inputStream = socket.getInputStream();             OutputStream outputStream = socket.getOutputStream()){            Scanner scanner = new Scanner(System.in);//从控制台读取要发送的请求数据            Scanner scannerNetwork = new Scanner(inputStream);//从服务器读取响应            PrintWriter writer = new PrintWriter(outputStream);//通过PrintWriter进行写入操作            while (true){                //从控制台读取请求数据                System.out.print("请输入:");                if(!scanner.hasNext()){//读取完毕,退出循环                    break;                }                String request = scanner.next();//读取请求                //将请求发送给服务器                writer.println(request);//使用println方法来发送数据,使请求末尾带有/n                writer.flush();//刷新缓冲区,使数据及时发送出去                //从服务器读取响应                String response = scannerNetwork.next();                //显示响应内容                System.out.println(response);            }        }catch (IOException e){            throw new RuntimeException(e);        }    }    public static void main(String[] args) throws IOException {        TcpEchoClient client = new TcpEchoClient("127.0.0.1", 9019);        client.start();    }}

也许您对下面的内容还感兴趣: