备案控制台
开发者社区 开发与运维 文章 正文

黑马全套Java教程（九）：网络编程（四）

2024-07-02 9
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 黑马全套Java教程（九）：网络编程

黑马全套Java教程（九）：网络编程（三）+https://developer.aliyun.com/article/1556507

37.4 线程池优化

ServerDemo2.java

package d8_socket4;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.*;
//目标：实现服务端可以同时处理多个客户端的消息
public class ServerDemo2 {
    //使用静态变量记住一个线程池对象
    private static ExecutorService pool = new ThreadPoolExecutor(3,5,6,
            TimeUnit.SECONDS, new ArrayBlockingQueue<>(2), Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());
    public static void main(String[] args) {
        try {
            System.out.println("=====服务端启动成功=====");
            //1. 注册端口
            ServerSocket serverSocket = new ServerSocket(6666);
            //定义一个死循环由主线程负责不断的接收客户端的Socket管道连接
            while (true) {
                //2. 每接收到一个客户端的Socket管道，交给一个独立的子线程负责读取消息
                Socket socket = serverSocket.accept();
                System.out.println(socket.getRemoteSocketAddress() + "：它来了，上线了！");
                //任务对象负责读取消息
                Runnable target = new ServerReaderRunnable(socket);
                pool.execute(target);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

ClientDemo1.java

package d8_socket4;
import java.io.IOException;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;
//目标：使用线程池优化，实现通信
public class ClientDemo1 {
    public static void main(String[] args) {
        try {
            System.out.println("=====客户端启动成功=====");
            //1. 创建Socket通信管道请求有服务端的连接
            //public Socket(String host, int port)
            //参数一：服务器的IP
            //参数二：服务端的端口
            Socket socket = new Socket("127.0.0.1",6666);
            //2. 从socket通信管道中得到一个字节输出流，负责发送数据
            OutputStream os = socket.getOutputStream();
            //3. 把低级的字节流包装成打印流
            PrintStream ps = new PrintStream(os);
            Scanner sc = new Scanner(System.in);
            while (true) {
                //4. 发送消息
                System.out.println("请说：");
                String msg = sc.nextLine();
                ps.println(msg);
                ps.flush();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

ServerReaderRunnable.java

package d8_socket4;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.Socket;
public class ServerReaderRunnable implements Runnable{
    private Socket socket;
    public ServerReaderRunnable(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run(){
        try {
            //3. 从socket通信管道中得到一个字节输入流
            InputStream is = socket.getInputStream();
            //4. 把字节输入流包装成缓冲字符输入流进行消息的接收
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            //5. 按照行读取消息
            String msg;
            while((msg = br.readLine()) != null){
                System.out.println(socket.getRemoteSocketAddress() + "说了：" + msg);
            }
        } catch (IOException e) {
            System.out.println(socket.getRemoteSocketAddress() + "：下线了！");
        }
    }
}


案例：即时通信

即时通信的含义，要怎么设计：

  • 即时通信，是指一个客户端的消息发出去，其他客户端可以接收到
  • 即时通信需要进行端口转发的设计思想
  • 服务端需要把在线的Socket管道存储起来
  • 一旦收到一个消息要推送给其他管道

ServerReaderThread.java

package d9_tcp_sms;
import d8_socket4.ServerReaderRunnable;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
//目标：实现服务端可以同时处理多个客户端的消息
public class ServerDemo2 {
    //定义一个静态的List集合存储当前全部在线的socket管道
    public static List<Socket> allOnlineSockets = new ArrayList<>();
    public static void main(String[] args) throws Exception{
        System.out.println("=====服务端启动成功=====");
        //1. 注册端口
        ServerSocket serverSocket = new ServerSocket(6666);
        //定义一个死循环由主线程负责不断的接收客户端的Socket管道连接
        while (true) {
            //2. 每接收到一个客户端的Socket管道，交给一个独立的子线程负责读取消息
            Socket socket = serverSocket.accept();
            System.out.println(socket.getRemoteSocketAddress() + "：上线了！");
            //任务对象负责读取消息
            Runnable target = new ServerReaderRunnable(socket);
            allOnlineSockets.add(socket);   //上线完成
            //3. 创建一个独立的线程来单独处理这个socket管道
            new ServerReaderThread(socket).start();
        }
    }
}
class ServerReaderThread extends Thread {
    private Socket socket;
    public ServerReaderThread(Socket socket) {
        this.socket = socket;
    }
    @Override
    public void run() {
        try {
            //3. 从socket通信管道中得到一个字节输入流
            InputStream is = socket.getInputStream();
            //4. 把字节输入流包装成缓冲字符输入流进行消息的接收
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            //5. 按照行读取消息
            String msg;
            while ((msg = br.readLine()) != null) {
                System.out.println(socket.getRemoteSocketAddress() + "发来了：" + msg);
                //把这个消息进行端口转发给全部客户端socket管道
                sendMsgToAll(msg);
            }
        } catch (Exception e) {
            System.out.println(socket.getRemoteSocketAddress() + "：下线了！");
            ServerDemo2.allOnlineSockets.remove(socket);
        }
    }
    private void sendMsgToAll(String msg) throws Exception{
        for(Socket socket : ServerDemo2.allOnlineSockets){
            PrintStream ps = new PrintStream(socket.getOutputStream());
            ps.println(msg);
            ps.flush();
        }
    }
}

ClientDemo1.java

package d9_tcp_sms;
import java.io.*;
import java.net.Socket;
import java.util.Scanner;
public class ClientDemo1 {
    public static void main(String[] args) throws Exception {
        System.out.println("=====客户端启动成功=====");
        //1. 创建Socket通信管道请求有服务端的连接
        Socket socket = new Socket("127.0.0.1", 6666);
        //创建一个独立的线程专门负责这个客户端的读消息（服务端随时可能转发消息过来）
        new ClientReaderThread(socket).start();
        //2. 从socket通信管道中得到一个字节输出流，负责发送数据
        OutputStream os = socket.getOutputStream();
        //3. 把低级的字节流包装成打印流
        PrintStream ps = new PrintStream(os);
        //4. 发送消息
        Scanner sc = new Scanner(System.in);
        while (true) {
            System.out.println("请说：");
            String msg = sc.nextLine();
            ps.println(msg);
            ps.flush();
        }
    }
}
class ClientReaderThread extends Thread {
    private Socket socket;
    public ClientReaderThread(Socket socket) {
        this.socket = socket;
    }
    @Override
    public void run() {
        try {
            //3. 从socket通信管道中得到一个字节输入流
            InputStream is = socket.getInputStream();
            //4. 把字节输入流包装成缓冲字符输入流进行消息的接收
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            //5. 按照行读取消息
            String msg;
            while ((msg = br.readLine()) != null) {
                System.out.println("收到消息：" + msg);
            }
        } catch (Exception e) {
            System.out.println(socket.getRemoteSocketAddress() + "：服务端把你踢出去了！");
        }
    }
}


案例：模拟BS系统

package d10_bs;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.*;
//目标：实现服务端可以同时处理多个客户端的消息
public class BSserverDemo {
    public static void main(String[] args) throws Exception{
        //1. 注册端口
        ServerSocket serverSocket = new ServerSocket(8080);
        //2. 创建一个循环接收多个客户端的请求
        while (true) {
            Socket socket = serverSocket.accept();
            //3. 创建一个独立的线程来单独处理这个socket管道
            new ServerReaderThread(socket).start();
        }
    }
}
class ServerReaderThread extends Thread {
    private Socket socket;
    public ServerReaderThread(Socket socket) {
        this.socket = socket;
    }
    @Override
    public void run() {
        try {
            //浏览器  已经与本线程建立了Socket管道
            //响应消息给浏览器显示
            PrintStream ps = new PrintStream(socket.getOutputStream());
            //必须响应HTTP协议格式数据，否则浏览器不认识消息
            ps.println("HTTP/1.1 200 OK");  //协议类型和版本  响应成功的消息！
            ps.println("Content-Type:text/html;charset=UTF-8");  //响应的数据类型：文本/网页
            ps.println();  //必须发送一个空行
            //才可以响应数据回去给浏览器
            ps.println("<span style='color:red;font-size:90px'>《Java大法好》 </span>");
            ps.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

例2：利用线程池优化

package d10_bs;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.*;
//目标：实现服务端可以同时处理多个客户端的消息
public class BSserverDemo {
    //使用静态变量记住一个线程池对象
    private static ExecutorService pool = new ThreadPoolExecutor(3,5,6,
            TimeUnit.SECONDS, new ArrayBlockingQueue<>(2),
            Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());
    public static void main(String[] args) throws Exception{
        //1. 注册端口
        ServerSocket serverSocket = new ServerSocket(8080);
        //2. 创建一个循环接收多个客户端的请求
        while (true) {
            Socket socket = serverSocket.accept();
            //3. 创建一个独立的线程来单独处理这个socket管道
            pool.execute(new ServerReaderThread(socket));
        }
    }
}
class ServerReaderThread extends Thread {
    private Socket socket;
    public ServerReaderThread(Socket socket) {
        this.socket = socket;
    }
    @Override
    public void run() {
        try {
            //浏览器  已经与本线程建立了Socket管道
            //响应消息给浏览器显示
            PrintStream ps = new PrintStream(socket.getOutputStream());
            //必须响应HTTP协议格式数据，否则浏览器不认识消息
            ps.println("HTTP/1.1 200 OK");  //协议类型和版本  响应成功的消息！
            ps.println("Content-Type:text/html;charset=UTF-8");  //响应的数据类型：文本/网页
            ps.println();  //必须发送一个空行
            //才可以响应数据回去给浏览器
            ps.println("<span style='color:red;font-size:90px'>《Java大法好》 </span>");
            ps.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
文章标签：
Java
存储
关键词：
网络编程java
Java网络编程
Java教程
Java网络
Java教程网络编程
zdb呀
目录
相关文章
北京-宏哥
|
1天前
|
XML 测试技术 数据格式
《手把手教你》系列基础篇（八十五）-java+ selenium自动化测试-框架设计基础-TestNG自定义日志-下篇（详解教程）
【7月更文挑战第3天】TestNG教程展示了如何自定义日志记录。首先创建一个名为`TestLog`的测试类，包含3个测试方法，其中一个故意失败以展示日志。使用`Assert.assertTrue`和`Reporter.log`来记录信息。接着创建`CustomReporter`类，继承`TestListenerAdapter`，覆盖`onTestFailure`, `onTestSkipped`, 和 `onTestSuccess`，在这些方法中自定义日志输出。
北京-宏哥
17 6
北京-宏哥
|
17小时前
|
Java 测试技术 Apache
《手把手教你》系列基础篇（八十六）-java+ selenium自动化测试-框架设计基础-Log4j实现日志输出（详解教程）
【7月更文挑战第4天】Apache Log4j 是一个广泛使用的 Java 日志框架，它允许开发者控制日志信息的输出目的地、格式和级别。Log4j 包含三个主要组件：Loggers（记录器）负责生成日志信息，Appenders（输出源）确定日志输出的位置（如控制台、文件、数据库等），而 Layouts（布局）则控制日志信息的格式。通过配置 Log4j，可以灵活地定制日志记录行为。
北京-宏哥
13 4
省赚客_123456
|
1天前
|
网络协议 安全 Java
Java中的网络编程：Socket编程详解
Java中的网络编程：Socket编程详解
省赚客_123456
6 1
泥腿子架构师
|
1天前
|
安全 网络协议 Java
Java中的网络通信：HTTP详解
Java中的网络通信：HTTP详解
泥腿子架构师
6 1
泥腿子架构师
|
1天前
|
网络协议 Java 网络安全
Java中的网络编程：TCP详解
Java中的网络编程：TCP详解
泥腿子架构师
6 1
weixin_836869520
|
17小时前
|
网络协议 安全 Java
深入了解Java中的网络编程与Socket通信
深入了解Java中的网络编程与Socket通信
weixin_836869520
7 0
爱你三千遍斯塔克
|
1天前
|
Linux 网络安全 数据安全/隐私保护
网络安全教程-------渗透工具Kali，官网链接,ARM的介绍，Mobil，华为小米,oppe手机，是无法刷入第三方的操作系统的，E+手机，谷歌的picksoul，或者三星手机，系统盘是WSL的
网络安全教程-------渗透工具Kali，官网链接,ARM的介绍，Mobil，华为小米,oppe手机，是无法刷入第三方的操作系统的，E+手机，谷歌的picksoul，或者三星手机，系统盘是WSL的
爱你三千遍斯塔克
5 0
北京-宏哥
|
2天前
|
Java 测试技术 Android开发
《手把手教你》系列基础篇（八十四）-java+ selenium自动化测试-框架设计基础-TestNG日志-上篇（详解教程
【7月更文挑战第2天】TestNG是一个用于自动化测试的Java框架，提供日志记录功能。日志有两种模式：底层级详细记录每个步骤，高层级仅记录关键事件。示例代码展示了如何在测试方法中使用`Reporter.log()`记录信息，这些信息会显示在TestNG HTML报告中。文章还提及了日志显示时可能出现的编码问题及解决办法。
北京-宏哥
8 0
省赚客_123456
|
2天前
|
网络协议 Java
Java网络编程基础与Socket实现技术
Java网络编程基础与Socket实现技术
省赚客_123456
4 0
蒋固金
|
Java 数据库 容器
JAVA基础教程汇总
蒋固金
12134 3

热门文章

最新文章

  • 1
    【网络连接】ping不通的常见原因+解决方案，如何在只能访问网关时诊断，并修复IP不通的问题
  • 2
    云计算与网络安全：保障信息安全的新挑战与应对策略
  • 3
    深入理解Docker自定义网络：构建高效的容器网络环境
  • 4
    SPSS大学生网络购物行为研究：因子分析、主成分、聚类、交叉表和卡方检验
  • 5
    R语言软件对房屋价格预测：回归、LASSO、决策树、随机森林、GBM、神经网络和SVM可视化|数据分享
  • 6
    使用Python实现卷积神经网络（CNN）
  • 7
    2023年河南省中等职业教育技能大赛网络建设与运维项目比赛试题（一）
  • 8
    某高校园区网络的规划与建设
  • 9
    2023 金砖国家职业技能大赛网络安全省赛理论题样题（金砖国家未来技能挑战赛）
  • 10
    SSH：加密安全访问网络的革命性协议
  • 1
    【Java网络编程】网络编程概述、UDP通信（DatagramPacket 与 DatagramSocket）
    38
  • 2
    【网络编程】理解客户端和服务器并使用Java提供的api实现回显服务器
    20
  • 3
    【探索Linux】P.29（网络编程套接字 —— 简单的TCP网络程序模拟实现）
    26
  • 4
    【探索Linux】P.28（网络编程套接字 —— 简单的UDP网络程序模拟实现）
    24
  • 5
    【探索Linux】P.27（网络编程套接字 —— UDP协议介绍 | TCP协议介绍 | UDP 和 TCP 的异同）
    36
  • 6
    【探索Linux】P.26（网络编程套接字基本概念—— socket编程接口 | socket编程接口相关函数详细介绍 ）
    32
  • 7
    【探索Linux】P.25（网络编程套接字基本概念 —— 预备知识）
    13
  • 8
    [计算机网络]---网络编程套接字
    26
  • 9
    【Swift 开发专栏】Swift 中的网络编程：URLSession 与 Alamofire
    48
  • 10
    Python网络编程之udp编程、黏包以及解决方案、tcpserver
    26

    • 相关课程

    更多
  • 5天玩转Java面向对象编程
  • Java开发工具
  • Java 虚拟机原理
  • Java Web项目实战 - 图书商城
  • Java面试疑难点解析 - Java Web开发

    • 相关电子书

    更多
  • 可编程网络视角的网络创新研究
  • 可编程网络和SDN3.0
  • 开放促进创新：构建开放网络生态
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）