备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

Java基础 | 网络编程

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

网络编程

（一）网络编程入门

1.网络编程概述

在这里插入图片描述

网络编程

  • 在网络通信协议下，实现网路互连的不同计算机上运行的程序间可以进行数据交换

2.网络编程三要素

在这里插入图片描述

3.IP地址

在这里插入图片描述

常用命令：

  • ipconfig：查看本机IP地址
  • ping IP地址：检查网路是否连通

特殊IP地址：

  • 127.0.0.1：是回送地址，可以代表本机地址，一般用来测试使用

4.InetAddress的使用

在这里插入图片描述

代码演示：

import java.net.InetAddress;
import java.net.UnknownHostException;

public class InetAddressDemo {
    public static void main(String[] args) throws UnknownHostException {
//        InetAddress address = InetAddress.getByName("PC-202111286656");
        InetAddress address = InetAddress.getByName("192.168.1.105");
        String name = address.getHostName();
        String ip = address.getHostAddress();

        System.out.println(name);//PC-202111286656
        System.out.println(ip);//192.168.1.105
    }
}

5.端口

在这里插入图片描述

6.协议

在这里插入图片描述

在这里插入图片描述

（二）UDP通信程序

1.UDP通信原理

UDP协议是一种不可靠的网路协议，它在通信的两端各建立一个Socket对象，但是这两个Socket只是发送，接收数据的对象 因此对于基于UDP协议的通信双方而言，没有所谓的客户端和服务器的概念

Java提供了DatagramSocket类作为UDP协议的Socket

2.UDP发送数据

在这里插入图片描述

代码演示：

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class UDPDemo {
    public static void main(String[] args) throws IOException {
        //DatagramSocket()  构建一个数据报套接字绑定到本地主机的任何可用的端口。
        DatagramSocket ds = new DatagramSocket();
        byte[] bys = "hello java".getBytes();
        DatagramPacket dp = new DatagramPacket(bys,bys.length, InetAddress.getByName("192.168.1.105"),10086);
        
        ds.send(dp);
        ds.close();
    }
}

3.UDP接收数据

在这里插入图片描述

代码演示：

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class ReceiveDemo {
    public static void main(String[] args) throws IOException {
        DatagramSocket ds = new DatagramSocket(10086);
        //创建数据包，用于接收数据
        byte[] bys = new byte[1024];
        DatagramPacket dp = new DatagramPacket(bys, bys.length);
        //接收数据
        ds.receive(dp);

        //解析数据
        byte[] datas = dp.getData();
        int len = dp.getLength();
        System.out.println("数据是：" + new String(datas, 0, len)); //数据是：hello java

        //注意接收数据，先运行接收端，再运行发送端
        
        //关闭接收端
        ds.close();
    }
}

4.案例（聊天室）

定义发送端：

import java.io.IOException;
import java.net.*;
import java.util.Scanner;

public class SendDemo {
    public static void main(String[] args) throws IOException {
        //创建发送端Socket对象
        DatagramSocket ds = new DatagramSocket();

        Scanner sc = new Scanner(System.in);
        System.out.println("请输入传输的数据：");
        String ss = "";
        while (!ss.equals("886")) {
            ss = sc.nextLine();
            //创建数据包
            byte[] bys = ss.getBytes();
            DatagramPacket dp = new DatagramPacket(bys, bys.length, InetAddress.getByName("192.168.1.105"), 10086);
            //发送数据
            ds.send(dp);
        }
        ds.close();
    }
}

定义接收端：

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class Receive {
    public static void main(String[] args) throws IOException {
        //创建接收端对象
        DatagramSocket ds = new DatagramSocket(10086);

        //创建数据包
        byte[] bys = new byte[1024];
        DatagramPacket dp = new DatagramPacket(bys,bys.length);

        while(true){
            //接收数据
            ds.receive(dp);
            //解析数据
            byte[] data = dp.getData();
            int length = dp.getLength();
            System.out.println("数据是："+new String(data,0,length));
        }
    }
}

（三）TCP通信程序

1.TCP通信原理

在这里插入图片描述

2.TCP发送数据

发送数据的步骤

1.创建客户端的Socket对象(Socket)

Socket(String host,int port)

2.获取输出流，写数据

OutputStream getOutputStream()

3.释放资源

void close()

代码演示：

import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;

public class TCP_sendDemo {
    public static void main(String[] args) throws IOException {
        //Socket(InetAddress address, int port)
//        Socket s = new Socket(InetAddress.getByName("192.168.1.105"),10000);
        //创建客户端对象 Socket(String host,int port)
        Socket s =new Socket("192.168.1.105",8888);

        //获取输出流写数据
        OutputStream os = s.getOutputStream();
        os.write("TCP我来了".getBytes());

        //释放资源
        s.close();
    }
}

3.TCP接收数据

接收数据的步骤

1.创建服务器端的Socket对象(ServerSocket)

ServerSocket(int port)

2.监听客户端连接，返回一个Socket对象

Socket accept()

3.获取输入流，读数据，并把数据显示在控制台

InputStream getInputStream()

4.释放资源

void close()

代码演示：

import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class TCP_acceptDemo {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);

        //监听客户端连接，返回Socket对象
        Socket s = ss.accept();

        //获取输入流，读数据，并把数据显示在控制台
        InputStream is = s.getInputStream();
        byte[] bys = new byte[1024];
        int len = is.read(bys);
        System.out.println("数据是：" + new String(bys, 0, len));

        //释放资源
        ss.close();
    }
}

（四）TCP通信练习

练习一：

  • 客户端：发送数据，接收服务器反馈
  • 服务器：接受数据，给出反馈

代码实现：

客户端：

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //创建客户端对象
        Socket s = new Socket(InetAddress.getByName("192.168.1.105"), 8888);

        //获取输出流，写数据
        OutputStream os = s.getOutputStream();
        os.write("服务端我来了".getBytes());

        //接收服务端反馈
        InputStream is = s.getInputStream();
        byte[] bys = new byte[1024];
        int len = is.read(bys);
        String data = new String(bys, 0, len);
        System.out.println("服务端:" + data);//服务端:数据收到了

        //释放资源
        s.close();

    }
}

服务器：

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);

        //监听客户端连接
        Socket s = ss.accept();

        //获取输入流对象，读数据
        InputStream is = s.getInputStream();
        byte[] bys = new byte[1024];
        int len = is.read(bys);
        String data = new String(bys, 0, len);
        System.out.println("数据是：" + data);//数据是：服务端我来了

        //给客户端反馈
        OutputStream os = s.getOutputStream();
        os.write("数据收到了".getBytes());

        //释放资源
        ss.close();

    }
}

练习二：

  • 客户端：数据来自键盘录入，直到输入的数据是886，发送数据结束
  • 服务器：接收到的数据在控制台输出

代码实现：

客户端：

import java.io.*;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Scanner;

public class ClientDemo2 {
    public static void main(String[] args) throws IOException {
        //创建客户端对象
        Socket s = new Socket(InetAddress.getByName("192.168.1.105"), 8888);
     
        //键盘录入
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        //封装字符输出流对象
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line = br.readLine()) != null) {

            bw.write(line);
            bw.newLine();
            bw.flush();
            //服务端反馈
            InputStream is = s.getInputStream();
            byte[] bys = new byte[1024];
            int len = is.read(bys);
            String ss = new String(bys, 0, len);
            System.out.println("服务端：" + ss);

            if (line.equals("886")) {
                break;
            }
        }
        //释放资源
        s.close();
    }
}

服务器：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo2 {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);

        //监听客户端连接
        Socket s = ss.accept();

        //封装字符输入流，读取数据
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String line;
        while ((line = br.readLine()) != null) {
            System.out.println("数据是：" + line);
            //给客户端反馈
            OutputStream os = s.getOutputStream();
            os.write("服务端收到了数据".getBytes());
        }
        
        //释放资源
        ss.close();
    }
}

练习三：

  • 客户端：数据来自键盘录入，直到输入的数据是886，结束数据发送
  • 服务器：接收到的数据写入文本文件

客户端：

import java.io.*;
import java.net.Socket;

public class ClientDemo3 {
    public static void main(String[] args) throws IOException {
        //创建客户端对象
        Socket s = new Socket("192.168.1.105", 8888);
        //封装字符输入流对象，键盘录入数据
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        //获取输出流
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line = br.readLine()) != null) {
            if (line.equals("886")) {
                break;
            }
            bw.write(line);
            bw.newLine();
            bw.flush();

            //服务端给出反馈
            InputStream is = s.getInputStream();
            byte[] bys = new byte[1024];
            int len = is.read(bys);
            String ss = new String(bys, 0, len);
            System.out.println("服务端：" + ss);
        }
        //释放资源
        s.close();
    }
}

服务器：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo3 {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);

        //监听客户端连接
        Socket s = ss.accept();
        //封装字符输入流对象，读取数据
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //创建把数据写入文本
        BufferedWriter bw = new BufferedWriter(new FileWriter("src\\TEMP\\TEMP29\\sd3.txt"));

        String line;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();

            //给客户端反馈
            OutputStream os = s.getOutputStream();
            os.write("数据已写入文本中".getBytes());
        }
        //释放资源
        bw.close();//此处BufferedWriter指向的是文本而不是Socket所以需要进行单独释放
        ss.close();
    }
}

练习四：

客户端：数据来自文本文件

服务器：接收到的数据写入文本文件

客户端：

import java.io.*;
import java.net.Socket;

public class ClientDemo4 {
    public static void main(String[] args) throws IOException {
        //创建客户端对象
        Socket s = new Socket("192.168.1.105", 8888);
        //封装文本文件的数据
        BufferedReader br = new BufferedReader(new FileReader("src\\TEMP\\TEMP29\\sd3.txt"));
        //封装输出流写数据
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();

            //服务端反馈
            InputStream is = s.getInputStream();
            byte[] bys = new byte[1024];
            int len = is.read(bys);
            String data = new String(bys, 0, len);
            System.out.println("服务端：" + data);
        }

        //释放资源
        br.close();
        s.close();
    }
}

服务器：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo4 {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);
        //监听客户端连接
        Socket s = ss.accept();
        //封装字符输入流，读取数据
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //把数据写入文本
        BufferedWriter bw = new BufferedWriter(new FileWriter("src\\TEMP\\TEMP29\\sd4.txt"));

        String line;
        while((line = br.readLine())!=null){
            bw.write(line);
            bw.newLine();
            bw.flush();

            //给客户端反馈
            OutputStream os = s.getOutputStream();
            os.write("数据已读取并写入目标文本中".getBytes());
        }


        //释放资源
        bw.close();
        ss.close();
    }
}

练习五：

  • 客户端：数据来自文本文件，接收服务器反馈
  • 服务器：接收的数据写入文本文件，给出反馈
  • 出现问题：程序一直等待
  • 原因：读数据的方法是阻塞式的
  • 解决办法：自定义结束标语；使用shutdownOutput()方法 (推荐)

客户端：

import java.io.*;
import java.net.Socket;

public class ClientDemo4 {
    public static void main(String[] args) throws IOException {
        //创建客户端对象
        Socket s = new Socket("192.168.1.105", 8888);
        //封装文本文件的数据
        BufferedReader br = new BufferedReader(new FileReader("src\\TEMP\\TEMP29\\sd3.txt"));
        //封装输出流写数据
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }

        //结束标语
        s.shutdownOutput();

        //接收服务端反馈
        InputStream is = s.getInputStream();
        byte[] bys = new byte[1024];
        int len = is.read(bys);
        String data = new String(bys, 0, len);
        System.out.println("服务端：" + data);

        //释放资源
        br.close();
        s.close();
    }
}

服务器：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo4 {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);
        //监听客户端连接
        Socket s = ss.accept();
        //封装字符输入流，读取数据
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //把数据写入文本
        BufferedWriter bw = new BufferedWriter(new FileWriter("src\\TEMP\\TEMP29\\sd4.txt"));

        String line;
        while((line = br.readLine())!=null){
            bw.write(line);
            bw.newLine();
            bw.flush();
        }

        //给客户端反馈
        OutputStream os = s.getOutputStream();
        os.write("数据已读取并写入目标文本中".getBytes());

        //释放资源
        bw.close();
        ss.close();
    }
}

练习六：

  • 客户端：数据来自文本文件，接收服务器反馈
  • 服务器：接收到的数据写入文本文件，给出反馈，代码用线程进行封装，为每一个客户端开启一个线程

服务器线程类：

import java.io.*;
import java.net.Socket;

public class ServerThread implements Runnable {
    private Socket s;

    public ServerThread(Socket s) {
        this.s = s;
    }

    @Override
    public void run() {
        try {
            //接受数据写到文本文件
            BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
//            BufferedWriter bw = new BufferedWriter(new FileWriter("src\\TEMP\\TEMP29\\copyFile.txt"));
            //解决名称冲突问题
            int count = 0;
            File file = new File("src\\TEMP\\TEMP29\\copyFile[" + count + "].txt");
            while(file.exists()){
                count++;
                file =new File("src\\TEMP\\TEMP29\\copyFile[" + count + "].txt");
            }
            BufferedWriter bw = new BufferedWriter(new FileWriter(file));
            //写数据
            String line;
            while ((line = br.readLine()) != null) {
                bw.write(line);
                bw.newLine();
                bw.flush();
            }
            //给出反馈
            BufferedWriter bwServer = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
            bwServer.write("数据已读取并写入目标文本中");
            bwServer.newLine();
            bwServer.flush();
            //释放资源
            s.close();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

服务器：

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo5 {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);
        while(true) {
            //监听客户端连接
            Socket s = ss.accept();
            //为每个客户端开启一个线程
            new Thread(new ServerThread(s)).start();
        }

//        ss.close();
    }
}
文章标签：
Java
网络协议
关键词：
Java网络
Java网络编程
网络编程java
java基础网络
Java基础
BoBooY
目录
相关文章
༺ཌༀൢ学海无涯ൢༀད༻
|
29天前
|
网络协议 算法 Java
Java的集合、线程、网络编程、反射
Java的集合、线程、网络编程、反射
༺ཌༀൢ学海无涯ൢༀད༻
14 0
Java的集合、线程、网络编程、反射
小蜗牛耶
|
1天前
|
JavaScript Java 测试技术
基于Java的网络游戏交易系统的设计与实现(源码+lw+部署文档+讲解等)
基于Java的网络游戏交易系统的设计与实现(源码+lw+部署文档+讲解等)
小蜗牛耶
6 0
桃李春风一杯酒
|
1天前
|
SQL 安全 Java
Java安全编程：防范网络攻击与漏洞
【4月更文挑战第15天】本文强调了Java安全编程的重要性，包括提高系统安全性、降低维护成本和提升用户体验。针对网络攻击和漏洞，提出了防范措施：使用PreparedStatement防SQL注入，过滤和转义用户输入抵御XSS攻击，添加令牌对抗CSRF，限制文件上传类型和大小以防止恶意文件，避免原生序列化并确保数据完整性。及时更新和修复漏洞是关键。程序员应遵循安全编程规范，保障系统安全。
桃李春风一杯酒
13 2
小蜗牛耶
|
6天前
|
JavaScript Java 测试技术
基于Java的网络类课程思政学习系统的设计与实现(源码+lw+部署文档+讲解等)
基于Java的网络类课程思政学习系统的设计与实现(源码+lw+部署文档+讲解等)
小蜗牛耶
25 0
基于Java的网络类课程思政学习系统的设计与实现(源码+lw+部署文档+讲解等)
是阿超
|
14天前
|
搜索推荐 Java
Java基础(快速排序算法)
Java基础(快速排序算法)
是阿超
21 4
我开始找你了
|
26天前
|
网络协议 安全 Java
Java网络编程
Java网络编程
我开始找你了
15 1
C4.
|
1月前
|
Java
Java网络编程
Java网络编程
C4.
15 0
不爱讲大道理
|
1月前
|
存储 网络协议 安全
JAVA网络编程
JAVA网络编程
不爱讲大道理
20 1
₍ᐢ..ᐢ₎王
|
1月前
|
网络协议 Java
Java基于TCP的网络编程
Java基于TCP的网络编程
₍ᐢ..ᐢ₎王
12 0
小白学大数据
|
1月前
|
数据采集 前端开发 JavaScript
Java网络爬虫实践：解析微信公众号页面的技巧
Java网络爬虫实践：解析微信公众号页面的技巧
小白学大数据
24 0

热门文章

最新文章

  • 1
    网络技术基础（14）——ACL访问控制列表
  • 2
    网络技术基础（15）——DHCP简介与配置
  • 3
    网络技术基础（16）——DHCP中继
  • 4
    P2P网络下分布式文件共享场景的测试
  • 5
    【spring（六）】WebSocket网络传输协议
  • 6
    C/C++网络编程基础知识超详细讲解第一部分（系统性学习day11）
  • 7
    C/C++网络编程基础知识超详细讲解第三部分（系统性学习day13）
  • 8
    C/C++网络编程基础知识超详细讲解第二部分（系统性学习day12）
  • 9
    Java中的集合框架：深入理解与应用
  • 10
    通义千问API：找出两篇文章的不同
  • 1
    Java中的集合框架：深入理解与应用
    19
  • 2
    Java并发编程：理解并使用Future和Callable接口
    17
  • 3
    性能工具之 Java 调试工具 JDB
    32
  • 4
    JAVA云HIS系统医院信息管理源码
    28
  • 5
    Java基于物联网技术的智慧工地云管理平台源码 依托丰富的设备接口标准库，快速接入工地现场各类型设备
    146
  • 6
    [Java基础]——JVM内存模型
    33
  • 7
    [Java基础]——类的生命周期
    12
  • 8
    [java进阶]——泛型类、泛型方法、泛型接口、泛型的通配符
    21
  • 9
    【java进阶】Java中线程的实现方式
    13
  • 10
    【java进阶】集合的三种遍历(迭代器、增强for、Lambda)
    16

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 阿里云平台上进行Java程序的编译与运行
  • 使用Java面向对象编写网络通信程序应用
  • Elasticsearch Java API Client 开发
  • 手动部署Java Web环境（Alibaba Cloud Linux 2）
  • 容器的网络入门
  • 容器的自定义网络
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）
    为什么选择阿里云什么是云计算全球基础设施技术领先稳定可靠安全合规分析师报告
    产品和定价全部产品免费试用产品动态产品定价价格计算器云上成本管理
    解决方案技术解决方案
    文档与社区文档开发者社区天池大赛培训与认证
    权益中心免费试用高校计划企业扶持计划推荐返现计划
    支持与服务基础服务企业增值服务迁云服务官网公告健康看板信任中心
    关注阿里云
    关注阿里云公众号或下载阿里云APP，关注云资讯，随时随地运维管控云服务
    阿里云APP阿里云微信
    联系我们：4008013260
    法律声明Cookies政策廉正举报安全举报联系我们加入我们
    阿里巴巴集团淘宝网天猫全球速卖通阿里巴巴国际交易市场1688阿里妈妈飞猪阿里云计算AliOS万网高德UC友盟优酷钉钉支付宝达摩院淘宝海外阿里云盘饿了么
    © 2009-2024 Aliyun.com 版权所有 增值电信业务经营许可证： 浙B2-20080101 域名注册服务机构许可： 浙D3-20210002 京D3-20220015
    浙公网安备 33010602009975号浙B2-20080101-4