Java学习路线-39:网络编程TCP、UDP数据传输

本文涉及的产品
数据传输服务 DTS,数据迁移 small 3个月
推荐场景:
MySQL数据库上云
数据传输服务 DTS,数据同步 1个月
简介: Java学习路线-39:网络编程TCP、UDP数据传输

第35 章 : 网络编程

152 网络编程简介

网络编程: 多台主机之间的数据通信

通信协议:IP、TCP(可靠数据连接)、UDP(不可靠数据连接)

网络程序模型:

C/S Client/Server 客户端/服务端 安全性高 开发成本高

B/S Browser/Server 浏览器/服务器 安全性较低 开发成本低


目前以B/S 结构为主


153 Echo程序模型

ServerSocket与Socket

ServerSocket 设置服务器监听端口

Socket 设置要连接服务器的ip和端口


实现一个客户端与服务器端通信 Echo服务

Server.java


import java.io.IOException;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class Server {
    public static void main(String[] args) throws IOException {
        // 设置服务器监听端口
        ServerSocket server = new ServerSocket(8080);
        System.out.println("服务启动。。。");
        // 接收客户端连接
        Socket client = server.accept();
        // 接收客户端消息
        Scanner scanner = new Scanner(client.getInputStream());
        scanner.useDelimiter("\n");
        // 发送给客户端数据
        PrintWriter out = new PrintWriter(client.getOutputStream());
        // 结束标志
        boolean flag = true;
        while (flag) {
            if (scanner.hasNext()) {
                // 读取客户端数据
                String message = scanner.next();
                System.out.println("收到: " + message);
                // 结束标志
                if ("bye".equalsIgnoreCase(message)) {
                    flag = false;
                }
                // 发送数据给客户端
                out.println("[echo] " + message);
                out.flush();
            }
        }
        // 关闭
        out.close();
        scanner.close();
        client.close();
        server.close();
    }
}

Client.java


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
public class Client {
    private final static BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
    public static void main(String[] args) throws IOException {
        // 连接服务器
        Socket client = new Socket("localhost", 8080);
        // 接收服务器信息
        Scanner scanner = new Scanner(client.getInputStream());
        scanner.useDelimiter("\n");
        // 向服务器发送信息
        PrintWriter out = new PrintWriter(client.getOutputStream());
        // 结束标志
        boolean flag = true;
        while (flag) {
            // 读取控制台输入,发送给服务器
            String message = getInput("请输入:");
            System.out.println("发送:" + message);
            out.println(message);
            out.flush();
            // 接收服务端返回的数据
            if (scanner.hasNext()) {
                System.out.println("返回:" + scanner.next());
            }
            // 结束标志
            if ("bye".equalsIgnoreCase(message)) {
                flag = false;
            }
        }
        // 关闭操作
        out.close();
        scanner.close();
        client.close();
    }
    // 接收控制台输入
    public static String getInput(String prompt) throws IOException {
        System.out.println(prompt);
        return reader.readLine();
    }
}

154 BIO处理模型

多线程接收多个客户端连接


只用修改服务端代码

Server.java


import java.io.IOException;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class Server {
    public static class ClientThread implements Runnable {
        private Socket client = null;
        private Scanner scanner = null;
        private PrintWriter out = null;
        private boolean flag = true; // 结束标志
        ClientThread(Socket client) throws IOException {
            this.client = client;
            // 接收客户端消息
            this.scanner = new Scanner(client.getInputStream());
            this.scanner.useDelimiter("\n");
            // 发送给客户端数据
            this.out = new PrintWriter(client.getOutputStream());
        }
        @Override
        public void run() {
            while (this.flag) {
                if (this.scanner.hasNext()) {
                    // 读取客户端数据
                    String message = this.scanner.next();
                    System.out.println("收到: " + Thread.currentThread() + message);
                    // 结束标志
                    if ("bye".equalsIgnoreCase(message)) {
                        this.flag = false;
                    }
                    // 发送数据给客户端
                    this.out.println("[echo] " + message);
                    this.out.flush();
                }
            }
            this.out.close();
            this.scanner.close();
            try {
                this.client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    public static void main(String[] args) throws IOException {
        // 设置服务器监听端口
        ServerSocket server = new ServerSocket(8080);
        System.out.println("服务启动。。。");
        while (true) {
            // 接收客户端连接
            Socket client = server.accept();
            new Thread(new ClientThread(client)).start();
        }
        // 关闭
        // server.close();
    }
}

155 UDP程序

UDP 基于数据报实现

TCP要保证可靠连接,需要的服务器资源就多


不管客户端是否接收到


Receiver.java

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class Receiver {
    public static void main(String[] args) throws IOException {
        DatagramSocket receiver = new DatagramSocket(9000);
        byte[] data = new byte[2014];
        DatagramPacket packet = new DatagramPacket(data, data.length);
        // 等待接收数据
        receiver.receive(packet);
        System.out.println(new String(data, 0, packet.getLength()));
        // 关闭
        receiver.close();
    }
}

Sender.java


import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class Sender {
    public static void main(String[] args) throws Exception {
        DatagramSocket sender = new DatagramSocket(9001);
        // 发送数据
        String message = "Hello world";
        DatagramPacket packet = new DatagramPacket(message.getBytes(), 0, message.length(), InetAddress.getByName("localhost"), 9000);
        sender.send(packet);
        // 关闭
        sender.close();
    }
}

相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
Sqoop 企业级大数据迁移方案实战
Sqoop是一个用于在Hadoop和关系数据库服务器之间传输数据的工具。它用于从关系数据库(如MySQL,Oracle)导入数据到Hadoop HDFS,并从Hadoop文件系统导出到关系数据库。 本课程主要讲解了Sqoop的设计思想及原理、部署安装及配置、详细具体的使用方法技巧与实操案例、企业级任务管理等。结合日常工作实践,培养解决实际问题的能力。本课程由黑马程序员提供。
相关文章
|
4天前
|
消息中间件 Java Linux
2024年最全BATJ真题突击:Java基础+JVM+分布式高并发+网络编程+Linux(1),2024年最新意外的惊喜
2024年最全BATJ真题突击:Java基础+JVM+分布式高并发+网络编程+Linux(1),2024年最新意外的惊喜
|
2天前
|
存储 网络协议 Linux
【Linux 网络】网络基础(一)(局域网、广域网、网络协议、TCP/IP结构模型、网络传输、封装和分用)-- 详解(下)
【Linux 网络】网络基础(一)(局域网、广域网、网络协议、TCP/IP结构模型、网络传输、封装和分用)-- 详解(下)
|
2天前
|
存储 网络协议 安全
【Linux 网络】网络基础(一)(局域网、广域网、网络协议、TCP/IP结构模型、网络传输、封装和分用)-- 详解(上)
【Linux 网络】网络基础(一)(局域网、广域网、网络协议、TCP/IP结构模型、网络传输、封装和分用)-- 详解(上)
|
3天前
|
网络协议 Python
在python中利用TCP协议编写简单网络通信程序,要求服务器端和客户端进行信息互传。 - 蓝易云
在这个示例中,服务器端创建一个socket并监听本地的12345端口。当客户端连接后,服务器发送一条欢迎消息,然后关闭连接。客户端创建一个socket,连接到服务器,接收消息,然后关闭连接。
56 0
|
8天前
|
网络协议 网络性能优化
UDP与TCP:了解这两种网络协议的不同之处
UDP与TCP:了解这两种网络协议的不同之处
|
8天前
|
网络协议
TCP三次握手:实现网络通信的神秘仪式
TCP三次握手:实现网络通信的神秘仪式
|
9天前
|
网络协议 算法 网络性能优化
Qt TCP网络上位机的设计(通过网络编程与下位机结合)
Qt TCP网络上位机的设计(通过网络编程与下位机结合)
Qt TCP网络上位机的设计(通过网络编程与下位机结合)
|
9天前
|
网络协议 Unix 网络性能优化
网络编程 —— TCP 和 UDP 编程详解
网络编程 —— TCP 和 UDP 编程详解
网络编程 —— TCP 和 UDP 编程详解
|
9天前
|
网络协议 网络性能优化 网络架构
|
9天前
|
Java 开发者 Spring
Java一分钟之-Java网络编程基础:Socket通信
【5月更文挑战第13天】本文介绍了Java Socket编程基础知识,包括使用`ServerSocket`和`Socket`类建立连接,通过`OutputStream`和`InputStream`进行数据传输。常见问题涉及忘记关闭Socket导致的资源泄漏、网络异常处理及并发同步。理解Socket通信原理并掌握异常处理、资源管理和并发控制,能帮助开发者构建更稳定的网络应用。
34 1

热门文章

最新文章