【Java 网络编程】TCP 服务器端 客户端 简单示例(二)

简介: 【Java 网络编程】TCP 服务器端 客户端 简单示例(二)

IX ServerSocket 服务器端同时与多个客户端交互方案


将与单个客户端交互的操作封装到线程中 , 每当与一个新的客户端建立连接 , 就开启一个异步线程处理与该客户端之间的交互 ;


客户端处理线程 :


 

/**
     * 异步线程 , 处理单个客户端连接
     * 如果多个客户端连接 , 就需要创建多个该类, 同时处理多个客户端连接
     */
    public static class ClientHandler extends Thread{
        //1. 客户端 Socket 连接
        private Socket clientSocket;
        public ClientHandler(Socket clientSocket) {
            this.clientSocket = clientSocket;
        }
    }


无限循环等待客户端连接 , 一旦连接成功 , 就开启一个异步线程 ;


         

//II. 等待客户端连接, 注意此处是无限循环连接
            while(true){
                //1. 收到一个客户端连接请求 , 获取 客户端 Socket 连接
                Socket clientSocket = serverSocket.accept();
                //2. 将 Socket 连接传入 ClientHandler 线程 , 异步处理与客户端交互操作
                ClientHandler clientHandler = new ClientHandler(clientSocket);
                //3. 启动 与客户端 Socket 交互处理 异步线程
                clientHandler.start();
            }




X Socket 客户端代码示例


import java.io.*;
import java.net.*;
/**
 * 客户端
 */
public class Client {
    /**
     * 客户端入口函数
     * @param args
     */
    public static void main(String[] args){
        try {
            //I. 连接
            //1. 创建 Socket 对象
            Socket socket = new Socket();
            //2. 设置 Socket 的超时时间
            socket.setSoTimeout(5000);
            //3. 创建连接的端点 , 该端点包括 IP 地址和端口号
            InetSocketAddress inetSocketAddress =
                    new InetSocketAddress(
                            Inet4Address.getLocalHost(),   //本机IP地址
                            8000                      //端口号
                    );
            //4.. 连接服务器端点 , 并设置超时时间
            socket.connect(inetSocketAddress, 5000);
            //5. 如果连接成功会继续执行下面的操作, 如果失败会根据失败情况抛出异常
            //II. 获取 Socket 连接两个端点的属性, IP 地址和端口号
            //1. 获取服务器 IP 地址
            InetAddress serverAddress = socket.getInetAddress();
            //2. 获取服务器端口号
            int serverPort = socket.getPort();
            //3. 获取客户端 IP 地址
            InetAddress clientAddress = socket.getLocalAddress();
            //4. 获取客户端端口号
            int clientPort = socket.getLocalPort();
            System.out.println("服务器连接成功\n服务器地址 : " + serverAddress +
                    " , 服务器端口号 : " + serverAddress +
                    "\n客户端地址 : " + clientAddress + " , 客户端端口号 : " + clientPort);
            //向服务器端发送数据
            sendToServer(socket);
            //III. 关闭 Socket 连接
            socket.close();
            System.out.println("客户端 Socket 连接关闭");
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            //客户端可能挂了 , 需要重启
        }
    }
    public static void sendToServer(Socket socket){
        try {
            //I. 获取用户控制台输入信息
            //1. 获取控制台输入流
            InputStream is = System.in;
            //2. 该输入流会阻塞 , 等待用户控制台输入
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            //II. 将用户输入信息上传到服务器
            //4. 获取客户端的输出流 , 用于向服务器端写出数据
            OutputStream os = socket.getOutputStream();
            //5. 创建打印流 , 用于向服务器端写出字符
            PrintStream ps = new PrintStream(os);
            //III. 从服务器获取信息 , 这里循环读取数据, 接收到 服务器端的 quit 字符串才退出
            //1. 获取服务器端输入流
            InputStream isFromServer = socket.getInputStream();
            //2. 将输入流转为 BufferedReader
            BufferedReader brFromServer = new BufferedReader(new InputStreamReader(isFromServer));
            //3. 循环控制变量 , 退出时设置为 false
            boolean isReadFromServer = true;
            while (isReadFromServer){
                //4. 阻塞命令行 , 等待用户输入一行数据, 并存入 string 对象中
                String string = br.readLine();
                //5. 通过打印流 , 将该字符串传输给服务器端
                ps.println(string);
                //6. 阻塞控制台 , 从服务器读取一行数据
                String stringFromServer = brFromServer.readLine();
                //7. 根据服务器返回的数据进行不同操作
                if("quit".equals(stringFromServer)){
                    //停止循环
                    isReadFromServer = false;
                }else{
                    System.out.println(stringFromServer);
                }
            }
            //IV. 释放资源
            br.close();
            ps.close();
            brFromServer.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}





XI Socket 服务器端代码示例


import java.io.*;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
/**
 * 服务器端
 */
public class Server {
    /**
     * 服务器端入口函数
     * @param args
     */
    public static void main(String[] args){
        try {
            //I. 创建服务器套接字, 并监听端口
            //1. 创建服务器套接字 , 只需要指定端口即可 , 不需要指定 IP 地址
            //      其 IP 地址就是本机的 IP 地址 , 如果机器有多个 IP 地址
            //      如果没有指定 IP 地址 , 那么会监听所有的 IP 地址的指定端口号
            ServerSocket serverSocket = new ServerSocket(8000);
            //2. 获取服务器端 IP 地址
            InetAddress inetAddress = serverSocket.getInetAddress();
            //3. 获取服务器端口号
            int localPort = serverSocket.getLocalPort();
            System.out.println("服务器开启\nIP 地址 : " + inetAddress + " , 端口号 : " + localPort);
            //II. 等待客户端连接, 注意此处是无限循环连接
            while(true){
                //1. 收到一个客户端连接请求 , 获取 客户端 Socket 连接
                Socket clientSocket = serverSocket.accept();
                //2. 将 Socket 连接传入 ClientHandler 线程 , 异步处理与客户端交互操作
                ClientHandler clientHandler = new ClientHandler(clientSocket);
                //3. 启动 与客户端 Socket 交互处理 异步线程
                clientHandler.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    /**
     * 异步线程 , 处理单个客户端连接
     * 如果多个客户端连接 , 就需要创建多个该类, 同时处理多个客户端连接
     */
    public static class ClientHandler extends Thread{
        //1. 客户端 Socket 连接
        private Socket clientSocket;
        //2. 循环控制变量
        private boolean loopFlag = true;
        public ClientHandler(Socket clientSocket) {
            this.clientSocket = clientSocket;
        }
        @Override
        public void run() {
            super.run();
            //I. 获取客户端相关信息
            //1. 获取客户端的 IP 地址
            InetAddress inetAddress = clientSocket.getInetAddress();
            //2. 获取客户端的端口号
            int port = clientSocket.getPort();
            //3. 打印客户端的信息
            System.out.println("客户端信息 : \nIP 地址 : " + inetAddress + " , 端口号 : " + port);
            try {
                //II. 创建与客户端交互的输入输出流
                //1. 获取客户端 Socket 输出流 , 用于向客户端发送数据
                OutputStream os = clientSocket.getOutputStream();
                //2. 创建打印流 , 用于向客户端输出数据
                PrintStream ps = new PrintStream(os);
                //3. 获取客户端 Socket 输入流 , 用于接收客户端数据
                InputStream is = clientSocket.getInputStream();
                //4. 获取客户端的字符输入流 , 该输入流可以阻塞等待客户端输入
                BufferedReader br = new BufferedReader(new InputStreamReader(is));
                //III. 循环处理与客户端交互的信息
                while (loopFlag){
                    //1. 等待客户端输入
                    String string = br.readLine();
                    //2. 处理客户端输入
                    if("quit".equals(string)){
                        //如果客户端发送退出, 那么停止循环, 将该信息在送回客户端
                        loopFlag = false;
                        //将信息发送到客户端
                        ps.println("quit");
                    }else{
                        //将信息打印到控制台
                        System.out.println(string);
                        //将发送成功信息返回给客户端
                        ps.println("发送成功 , 大小 " + string.length() + " 字节");
                    }
                }
                //IV. 关闭相关资源
                ps.close();
                br.close();
            } catch (IOException e) {
                e.printStackTrace();
            }finally {
                try {
                    //如果出现异常 , 将该 Socket 关闭
                    clientSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            System.out.println("客户端退出 : \nIP 地址 : " + inetAddress + " , 端口号 : " + port);
        }
    }
}





XII 运行客户端与服务器端代码


1. 编译两个 Java 代码 : 选择菜单栏 -> Build -> Rebuild Project 选项 , 获取到 Client.class 和 Server.class 文件 ;




2. 字节码文件地址 : 编译后的 class 字节码文件在工程目录的 out\production\classes 目录下 ;




打开两个命令行界面 , 首先进入该目录 , 先运行服务器端 , 在命令行中输入 java Server , 即开启了服务器端 ; 再打开客户端 , 在另一个命令行中运行 java Client , 即开启了客户端 ;




客户端输入文字 , 与服务器端交互 :


image.png

目录
相关文章
|
1月前
|
Java
在 Java 中捕获和处理自定义异常的代码示例
本文提供了一个 Java 代码示例,展示了如何捕获和处理自定义异常。通过创建自定义异常类并使用 try-catch 语句,可以更灵活地处理程序中的错误情况。
59 1
|
2月前
|
存储 Java
Java中的HashMap和TreeMap,通过具体示例展示了它们在处理复杂数据结构问题时的应用。
【10月更文挑战第19天】本文详细介绍了Java中的HashMap和TreeMap,通过具体示例展示了它们在处理复杂数据结构问题时的应用。HashMap以其高效的插入、查找和删除操作著称,而TreeMap则擅长于保持元素的自然排序或自定义排序,两者各具优势,适用于不同的开发场景。
50 1
|
2天前
|
负载均衡 网络协议 算法
不为人知的网络编程(十九):能Ping通,TCP就一定能连接和通信吗?
这网络层就像搭积木一样,上层协议都是基于下层协议搭出来的。不管是ping(用了ICMP协议)还是tcp本质上都是基于网络层IP协议的数据包,而到了物理层,都是二进制01串,都走网卡发出去了。 如果网络环境没发生变化,目的地又一样,那按道理说他们走的网络路径应该是一样的,什么情况下会不同呢? 我们就从路由这个话题聊起吧。
17 4
不为人知的网络编程(十九):能Ping通,TCP就一定能连接和通信吗?
|
21天前
|
网络安全 Python
Python网络编程小示例:生成CIDR表示的IP地址范围
本文介绍了如何使用Python生成CIDR表示的IP地址范围,通过解析CIDR字符串,将其转换为二进制形式,应用子网掩码,最终生成该CIDR块内所有可用的IP地址列表。示例代码利用了Python的`ipaddress`模块,展示了从指定CIDR表达式中提取所有IP地址的过程。
35 6
|
23天前
|
监控 网络协议 网络性能优化
网络通信的核心选择:TCP与UDP协议深度解析
在网络通信领域,TCP(传输控制协议)和UDP(用户数据报协议)是两种基础且截然不同的传输层协议。它们各自的特点和适用场景对于网络工程师和开发者来说至关重要。本文将深入探讨TCP和UDP的核心区别,并分析它们在实际应用中的选择依据。
51 3
|
27天前
|
Java
在Java中实现接口的具体代码示例
可以根据具体的需求,创建更多的类来实现这个接口,以满足不同形状的计算需求。希望这个示例对你理解在 Java 中如何实现接口有所帮助。
42 1
|
2月前
|
Web App开发 缓存 网络协议
不为人知的网络编程(十八):UDP比TCP高效?还真不一定!
熟悉网络编程的(尤其搞实时音视频聊天技术的)同学们都有个约定俗成的主观论调,一提起UDP和TCP,马上想到的是UDP没有TCP可靠,但UDP肯定比TCP高效。说到UDP比TCP高效,理由是什么呢?事实真是这样吗?跟着本文咱们一探究竟!
68 10
|
1月前
|
网络协议 算法 网络性能优化
计算机网络常见面试题(一):TCP/IP五层模型、TCP三次握手、四次挥手,TCP传输可靠性保障、ARQ协议
计算机网络常见面试题(一):TCP/IP五层模型、应用层常见的协议、TCP与UDP的区别,TCP三次握手、四次挥手,TCP传输可靠性保障、ARQ协议、ARP协议
|
1月前
|
存储 Java API
Java实现导出多个excel表打包到zip文件中,供客户端另存为窗口下载
Java实现导出多个excel表打包到zip文件中,供客户端另存为窗口下载
47 4
|
6天前
|
安全 Java API
java如何请求接口然后终止某个线程
通过本文的介绍,您应该能够理解如何在Java中请求接口并根据返回结果终止某个线程。合理使用标志位或 `interrupt`方法可以确保线程的安全终止,而处理好网络请求中的各种异常情况,可以提高程序的稳定性和可靠性。
37 6
下一篇
DataWorks