一、Netty入门到精通(RPC实现)——传统的socket分析

╰半橙微兮° 2023-08-17 16:48 107阅读 0赞

参考bilibili：[ https://www.bilibili.com/video/av44457831?from=search&seid=8212310434369019426][https_www.bilibili.com_video_av44457831_from_search_seid_8212310434369019426]

使用Java进行TCP/UDP协议的网络通信一般使用Java的Net包下的Socket服务进行编写，有Server服务端和Client客户端

服务端用于监听客户端的连接和接收客户端发来的信息，

客户端可以接收服务端发送的信息，形成多个客户端与一个服务端连接，各个客户端可以相互通信的机制

## 1、服务端代码 ##

package traditional_socket;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    /**
     * \* Created with IntelliJ IDEA.
     * \* User: sunxianpeng
     * \* Date: 2019/9/29
     * \* Time: 15:35
     * \* To change this template use File | Settings | File Templates.
     * \* Description:
     * \传统 Socket 编程
     */
    public class OioServer {
        public static void main(String[] args) throws IOException {
            ServerSocket serverSocket = new ServerSocket(10101);
            System.out.println("server start !!");
            while (true){
                final Socket socket = serverSocket.accept();
                System.out.println("accept new client ");
                handler(socket);
            }
    
        }
    
        public static void handler(Socket socket){
            try {
                byte[] bytes = new byte[1024];
                InputStream inputStream = socket.getInputStream();
                while (true){
                    int read = inputStream.read(bytes);
                    if(read != -1){
                        System.out.println(new String(bytes, 0,read));
                    }else {
                        break;
                    }
                }
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                try {
                    System.out.println("close socket ");
                    socket.close();
                }catch (IOException e){
                    e.printStackTrace();
                }
            }
        }
    }

## 2、简单实用 ##

*  启动服务端后，服务端会在server.accept();的位置阻塞等待。
 *  使用Windows的 CMD 控制台的telnet进行客户端连接

telnet 127.0.0.1 10101

程序向下运行，程序走到read = input.read(bytes);发生了阻塞等待，等待客户端传输信息，

阻塞过程中，意味着这条线程是被这个***Socket一直占用着的***，其它的Socket不能进来。(再次打开一个CMD控制台使用telnet，可以发现进不来)

CMD中输入信息 send helloworld (**Ctrl+\]** 进入客户端，send发信息)，可以看到服务端收到了信息 ： helloworld

想要服务端处理多个客户端的信息，就需要为每一个客户端分配一个线程。

## 3、多客户端连接 ##

package traditional_socket;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.util.concurrent.Executor;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    /**
     * \* Created with IntelliJ IDEA.
     * \* User: sunxianpeng
     * \* Date: 2019/9/29
     * \* Time: 15:35
     * \* To change this template use File | Settings | File Templates.
     * \* Description:
     * \传统 Socket 编程
     */
    public class OioServer {
        public static void main(String[] args) throws IOException {
            //创建一个缓存线程池
            ExecutorService executorService = Executors.newCachedThreadPool();
            ServerSocket serverSocket = new ServerSocket(10101);
            System.out.println("server start !!");
            while (true){
                //获取一个套接字(阻塞)
                final Socket socket = serverSocket.accept();
                System.out.println("accept new client ");
                //在线程池为新客户端开一个线程
                executorService.execute(new Runnable() {
                    public void run() {
                        //业务处理
                        handler(socket);
                    }
                });
    
            }
    
        }
    
        public static void handler(Socket socket){
            try {
                byte[] bytes = new byte[1024];
                InputStream inputStream = socket.getInputStream();
                while (true){
                    int read = inputStream.read(bytes);
                    if(read != -1){
                        System.out.println(new String(bytes, 0,read));
                    }else {
                        break;
                    }
                }
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                try {
                    System.out.println("close socket ");
                    socket.close();
                }catch (IOException e){
                    e.printStackTrace();
                }
            }
        }
    }

*  创建一个缓存线程池，当服务端新连接了一个客户端的时候，就创建一个新的线程为客户端进行服务。
 *  现在在windows CMD上实用telnet 连接两个客户端连接，可以就看到两个客户端的信息都可以接收到
 *  使用这种结构实现一个长连接服务器有一个很大的弊端，因为目前我们**每个客户端都为其分配了一个线程去运行**，如果有一万个客户端进来，我们就要分配一万个线程给客户端使用，这样的资源消耗是十分巨大的。就好像一个饭店每进来一个客人，就为其分配一个服务员给他服务一样，对于饭店来说服务员的开销也是巨大的。
 *  基于以上几点，传统的Socket服务**实现长连接服务是不合适的，但是可以实现短连接的服务器**，如老版本的tomcat。

4、总结

传统IO传输的特点：

*  至少**两处阻塞点**(等待客户端连接，等待客户端发送信息)
 *  **单线程**下只能有**一个客户端连接**
 *  使用**线程池**可以连接多个客户端，但是十分**消耗性能**。

[https_www.bilibili.com_video_av44457831_from_search_seid_8212310434369019426]: https://www.bilibili.com/video/av44457831?from=search&seid=8212310434369019426