当前位置： 首页 > news >正文

UDP和TCP协议发送接收数据

news 来源：原创 2024/4/27 18:22:21

目录

一.UDP协议发送接收数据(不需要建立连接,不可靠协议)

1.(客户端)发送数据步骤:

2.(服务端)接收数据步骤:

3.实现客户端键盘录入,服务端控制台输出(多线程)

4.实现双方互聊(多线程)

二.TCP协议发送接收数据(必须建立连接,可靠协议,效率稍低)

1.(客户端)发送数据步骤:

2.(服务端)接收数据步骤:

3.实现客户端键盘录入,服务端控制台输出

4.客户端键盘录入,服务端写到文本文件中

5. 客户端读取文档,服务端接收并存入文档且有反馈

一.UDP协议发送接收数据(不需要建立连接,不可靠协议)

1.(客户端)发送数据步骤:

  • 创建UDP通讯客户端对象(DatagramSocket)
  • 创建数据报包 public DatagramPacket(byte[] buf, int length, InetAddress address,int port)
  • 发送 数据
  • 释放资源
        //创建UDP Socket客户端
        DatagramSocket ds = new DatagramSocket();
        Scanner sc = new Scanner(System.in);
        while (true) {
            System.out.println("请输入你要发送的消息");
            String msg = sc.nextLine();
            byte[] bytes = msg.getBytes();
        //创建数据报包 ,下面数据中的"***.***.***.***"更换成接收消息的主机号,"9999"是由接收方设定好的端口号,
            DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress.getByName("***.***.***.***"), 9999);
        //发送数据
            ds.send(dp);
        }
        //释放资源
        ds.close();

2.(服务端)接收数据步骤:

  • 创建UDP通讯协议服务器端对象(DatagramSocket) 注意要用有参数构造 指定端口号
  • 创建数据报包,作用用来接收数据  // public DatagramPacket(byte[] buf, int length)
  • 接收数据  receive(dp) ;
  • 解析数据报包,拿出数据  dp.getData() ;  dp.getLength() ;
  • 释放资源
        //创建服务端对象的Socket并指定端口号,此处端口号可自己随意指定
        DatagramSocket ds = new DatagramSocket(9999);
        //创建数据报包,接收数据
            byte[] bytes = new byte[1024];
            DatagramPacket dp = new DatagramPacket(bytes, bytes.length);
            //接收数据
            ds.receive(dp);
            //解析数据报包,拿出数据 
            byte[] data = dp.getData();
            //获取数据的实际长度
            int length = dp.getLength();
            //获取发送方的ip和端口
            String ip = dp.getAddress().getHostAddress();

            String s = new String(data, 0, length);
            System.out.println("B-IP:为" + ip + "给你发来消息" + s);
        }
        //释放资源
        ds.close();

3.实现客户端键盘录入,服务端控制台输出(多线程)

        当同一个程序中用主线程接收数据,子线程发送数据,即可实现自己(客户端)发送,自己(服务端)接收消息.此时在知晓他人ip号的情况下也可实现给他人发消息(本机写(客户端)发送数据的代码,他人写(服务端)接收数据的代码).这个时候都属于单方面的发送消息,单方面的接收消息,即客户端键盘录入服务器控制台输出.如下为自己即作为客户端又作为服务端的代码实现:

public class Test {
    public static void main(String[] args) throws IOException {
        //子线程接收消息
        new Thread() {
            @Override
            public void run() {
                try {
                    //创建服务端的Socket并暴露端口号
                    DatagramSocket ds = new DatagramSocket(9999);
                    System.out.println("A-服务器已经开启，等待接收收据....");
                    while (true) {
                        byte[] bytes = new byte[1024];
                        DatagramPacket dp = new DatagramPacket(bytes, bytes.length);
                        //阻塞式方法 此方法在接收到数据报前一直阻塞
                        ds.receive(dp);
                        //从数据报包中取出数据
                        byte[] data = dp.getData();
                        //获取数据的实际长度
                        int length = dp.getLength();
                        //获取发送方的ip和端口
                        String ip = dp.getAddress().getHostAddress();

                        String s = new String(data, 0, length);
                        System.out.println("本地IP:为" + ip + "给你发来消息" + s);
                        if ("886".equals(s)) {
                            break;
                        }

                    }
                    ds.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }.start();

        //主线程发消息
        sendMsg();
    }

    private static void sendMsg() throws IOException {
        //1.创建UDP Socket客户端
        DatagramSocket ds = new DatagramSocket();
        Scanner sc = new Scanner(System.in);
        while (true) {
            System.out.println("请输入你要发送的消息");
            String msg = sc.nextLine();
            byte[] bytes = msg.getBytes();
            //此处的***.***.***.***更改为自己的主机号
            DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress.getByName("***.***.***.***"), 9999);
            ds.send(dp);
            if ("886".equals(msg)) {
                break;
            }
        }
        ds.close();
    }
}

4.实现双方互聊(多线程)

如果要实现双方互聊的情况,那么双方都实现(客户端)发送数据和(服务端)接收数据的功能即可.A用户的功能实现如下:

public class A {
    public static void main(String[] args) throws IOException {
        //子线程接收消息
        new Thread() {
            @Override
            public void run() {
                try {
                    //创建服务端的Socket并暴露端口号
                    DatagramSocket ds = new DatagramSocket(8888);
                    System.out.println("A-服务器已经开启，等待接收收据....");
                    while (true) {
                        byte[] bytes = new byte[1024];
                        DatagramPacket dp = new DatagramPacket(bytes, bytes.length);
                        //阻塞式方法 此方法在接收到数据报前一直阻塞
                        ds.receive(dp);
                        //从数据报包中取出数据
                        byte[] data = dp.getData();
                        //获取数据的实际长度
                        int length = dp.getLength();
                        //获取发送方的ip和端口
                        String ip = dp.getAddress().getHostAddress();

                        String s = new String(data, 0, length);
                        System.out.println("B-IP:为" + ip + "给你发来消息" + s);
                        if ("886".equals(s)) {
                            break;
                        }

                    }
                    ds.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }.start();

        //主线程发消息
        sendMsg();
    }

    private static void sendMsg() throws IOException {
        //创建UDP Socket客户端
        DatagramSocket ds = new DatagramSocket();
        Scanner sc = new Scanner(System.in);
        while (true) {
            System.out.println("请输入你要发送的消息");
            String msg = sc.nextLine();
            byte[] bytes = msg.getBytes();
        //"***.***.***.***"更换成B用户的主机号
            DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress.getByName("***.***.***.***"), 8888);
            ds.send(dp);
            if ("886".equals(msg)) {
                break;
            }
        }
        ds.close();
    }
}

        B用户的功能实现代码也如上,注意的是发送消息时,主机号写成A用户的.并且A用户和B用户使用同一个端口号. 当然也可以自己和自己互聊,启动两个程序同时执行即可!需要注意的是两个程序代码的发送消息中的ip都写成自己的,并且两个程序的端口号不能设置一致,如果A设置的端口号为8888,B端口设置为9999,那么A程序中的发送数据的端口号需要写成9999,B中写成8888.如此便可以达成互聊的效果!

二.TCP协议发送接收数据(必须建立连接,可靠协议,效率稍低)

1.(客户端)发送数据步骤:

  • 创建TCP通讯协议客户端对象(Socket)   // public Socket(String host, int port)
  • 获取输出流对象
  • 写数据到连接通道中
  • 释放资源
        //创建TCP通讯协议客户端对象(Socket),其中***.***.***.***为接收方的主机号,7777为端口号,可自行定义     
        Socket sk = new Socket("***.***.***.***", 7777);
        //获取输出流对象
        OutputStream out = sk.getOutputStream();
        out.write("服务器你好！".getBytes());

        //读取服务端的反馈
        InputStream in = sk.getInputStream();
        byte[] bytes = new byte[1024];
        int len = in.read(bytes);
        String fk = new String(bytes, 0, len);
        System.out.println(fk);
        //释放资源
        sk.close();

2.(服务端)接收数据步骤:

  • 创建TCP通讯协议服务器端对象(ServerSocket)
  • 监听客户端
  • 获取输入流对象
  • 读取通道中的数据
  • 释放资源
        // 创建TCP通讯协议服务器端对象(ServerSocket),7777为客户端即发送端定义的.
        ServerSocket ss = new ServerSocket(7777);
        System.out.println("服务器以开启等待连接.....");
        //侦听客户端的连接
        Socket sk = ss.accept();
        //获取输入流对象
        InputStream in = sk.getInputStream();
        byte[] bytes = new byte[1024];
        int len = in.read(bytes);
        String s = new String(bytes, 0, len);
        System.out.println(s);
        //服务端给客户端一个反馈
        OutputStream out = sk.getOutputStream();
        out.write("客户端你好".getBytes());
        //释放资源
        ss.close();

3.实现客户端键盘录入,服务端控制台输出

此时客户端一直键盘录入消息,而客户端会一直接收消息!

//客户端的代码实现:
public class TCPClient {
    public static void main(String[] args) throws IOException {
        //其中***.***.***.***为接收方的主机号也可写自己的主机号,7777为端口号,可自行定义     
        Socket sk = new Socket("***.***.***.***", 7777); 
        OutputStream out = sk.getOutputStream();
        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
        BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(out));
        while (true) {
            System.out.println("请输入消息");
            String msg = reader.readLine();
            writer.write(msg);
            writer.newLine();
            writer.flush();
            if ("886".equals(msg)) {
                break;
            }
        }
        sk.close();
    }
}





//服务端的代码实现:
public class TCPServer {
    public static void main(String[] args) throws IOException {
        //7777为客户端即发送端定义的.
        ServerSocket ss = new ServerSocket(7777);
        System.out.println("服务器以开启等待连接.....");
        //侦听客户端的连接
        Socket sk = ss.accept();
        InputStream in = sk.getInputStream();
        //包装通道中字节流
        BufferedReader reader = new BufferedReader(new InputStreamReader(in));
        while (true) {
            String msg = reader.readLine();
            System.out.println(msg);
            if ("886".equals(msg)) {
                break;
            }
        }
        ss.close();
    }
}

       

4.客户端键盘录入,服务端写到文本文件中

//客户端的代码实现:
public class TCPClient {
    public static void main(String[] args) throws IOException {
//其中***.***.***.***为接收方的主机号也可写自己的主机号,7777为端口号,可自行定义
        Socket sk = new Socket("***.***.***.***", 7777);
        OutputStream out = sk.getOutputStream();
        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
        BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(out));
        while (true) {
            System.out.println("请输入消息");
            String msg = reader.readLine();
            writer.write(msg);
            writer.newLine();
            writer.flush();
            if ("886".equals(msg)) {
                break;
            }
        }
        sk.close();
    }
}




//服务端的代码实现
public class TCPServer {
    public static void main(String[] args) throws IOException {
        ServerSocket ss = new ServerSocket(7777);
        System.out.println("服务器以开启等待连接.....");
        //侦听客户端的连接
        Socket sk = ss.accept();
        InputStream in = sk.getInputStream();
        //包装通道中字节流
        BufferedReader reader = new BufferedReader(new InputStreamReader(in));
        //读取出来写入到msg.txt文件中
        BufferedWriter writer = new BufferedWriter(new FileWriter("msg.txt"));
        while (true) {
            String msg = reader.readLine();
            System.out.println(msg);
            writer.write(msg);
            writer.newLine();
            writer.flush();
            if ("886".equals(msg)) {
                break;
            }
        }
        ss.close();
    }
}

5. 客户端读取文档,服务端接收并存入文档且有反馈

这个过程实际上就是文件的上传,客户端读取文本文件发送数据到服务器端,服务器端读取数据存储到文本文件中.

//客户端的代码实现:
public class TCPClient {
    public static void main(String[] args) throws IOException {
//其中***.***.***.***为接收方的主机号也可写自己的主机号,7777为端口号,可自行定义
        Socket sk = new Socket("***.***.***.***", 7777);
        OutputStream out = sk.getOutputStream();
        //读出文件MyTest.java中的内容
        BufferedReader reader = new BufferedReader(new FileReader("MyTest.java"));
        //包装通道中的输入流
        BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(out));
        String line = null;
        while ((line = reader.readLine()) != null) {
            writer.write(line);
            writer.newLine();
            writer.flush();
        }

        System.out.println("下来了");

        //给服务端手写一个标记
        writer.write("over");
        writer.newLine();
        writer.flush();

        //读取服务端的反馈
        InputStream in = sk.getInputStream();
        byte[] bytes = new byte[1024];
        int len = in.read(bytes);
        String s = new String(bytes, 0, len);
        System.out.println(s);

        sk.close();
    }
}





//服务端的代码实现:
public class TCPServer {
    public static void main(String[] args) throws IOException {
        ServerSocket ss = new ServerSocket(7777);
        System.out.println("服务器以开启等待连接.....");
        //侦听客户端的连接
        Socket sk = ss.accept();
        InputStream in = sk.getInputStream();
        //包装通道中字节流
        BufferedReader reader = new BufferedReader(new InputStreamReader(in));
        //关联文件,写入到该文件中
        BufferedWriter writer = new BufferedWriter(new FileWriter("copy.java"));
        String line = null;
        while ((line = reader.readLine()) != null) {
            if ("over".equals(line)) {
                break;
            }
            //System.out.println(line);
            writer.write(line);
            writer.newLine();
            writer.flush();

        }
        System.out.println("服务端下来了");

        //给客户端一个反馈，告诉客户端文件上传成功
        OutputStream out = sk.getOutputStream();
        out.write("文件上传成功！".getBytes());

        ss.close();
    }
}

补充:如果想实现双方或多方聊天功能,那么双方都实现客户端和服务端的代码,便可以实现互相聊天的操作!

  • UDP协议: 发短信 ​ 将数据源和目的地封装成数据包，不需要建立连接； ​ 每个数据报包的大小在限制在64k； ​ 因无连接，是不可靠协议； ​ 不需要建立连接，速度快，效率高 ​ ​
  • TCP协议: 打电话 视频 ​ 建立连接，形成传输数据的通道； ​ 在连接中进行大数据量传输； ​ 需要连接所以是可靠协议； ​ 必须建立连接，效率会稍低

(小编也在努力学习更多哟!以后再慢慢分享的啦!)

希望对友友们有所帮助!!!!

相关文章：

  • Apache Doris 快速学习大纲
  • FastFlow（5）---软件加速器 software accelerator
  • 华为OD:0019-0020:-最小步骤数—删除字符串中出现次数最少的字符
  • Python学生成绩管信息理系统（面向对象）（学生信息篇）
  • 国稻种芯百团计划行动 丰收节贸促会·袁隆平：水稻国际竞争
  • 面试精选：3、史上最详细的Linux精选面试题（二）
  • 2.21 haas506 2.0开发教程 - TTS - Text To Speech (320开发板)
  • Promethues-如何监控容器
  • 测试人生 | 从小团队的业务到独角兽的测开，涨薪超过60%，90后小哥哥凤凰涅槃了
  • 技术门槛高？来看 Intel 机密计算技术在龙蜥社区的实践
  • 532. 数组中的 k-diff 数对
  • 通过mybatis自定义参数类型转换器，进行数据库字段加密脱敏
  • Win10修复IPv6优先访问
  • 盘点市面上七款好用的代码加密混淆工具，你都用过哪款？
  • STC15单片机-按键检测单击或长按(外部中断)
  • [译]前端离线指南（上）
  • “大数据应用场景”之隔壁老王（连载四）
  • 2017前端实习生面试总结
  • conda常用的命令
  • java架构面试锦集：开源框架+并发+数据结构+大企必备面试题
  • mysql innodb 索引使用指南
  • RxJS 实现摩斯密码(Morse) 【内附脑图】
  • ⭐ Unity 开发bug —— 打包后shader失效或者bug (我这里用Shader做两张图片的合并发现了问题)
  • 基于OpenResty的Lua Web框架lor0.0.2预览版发布
  • 简单实现一个textarea自适应高度
  • 快速体验 Sentinel 集群限流功能，只需简单几步
  • 猫头鹰的深夜翻译：Java 2D Graphics, 简单的仿射变换
  • 数据科学 第 3 章 11 字符串处理
  • Play Store发现SimBad恶意软件，1.5亿Android用户成受害者 ...
  • 京东物流联手山西图灵打造智能供应链，让阅读更有趣 ...
  • ​HTTP与HTTPS：网络通信的安全卫士
  • ​Spring Boot 分片上传文件
  • # 学号 2017-2018-20172309 《程序设计与数据结构》实验三报告
  • $redis-setphp_redis Set命令，php操作Redis Set函数介绍
  • （10）STL算法之搜索（二） 二分查找
  • (C++17) std算法之执行策略 execution
  • (poj1.2.1)1970(筛选法模拟)
  • （WSI分类）WSI分类文献小综述 2024
  • （附源码）springboot高校宿舍交电费系统 毕业设计031552
  • （转）利用PHP的debug_backtrace函数，实现PHP文件权限管理、动态加载 【反射】...
  • （轉）JSON.stringify 语法实例讲解
  • .“空心村”成因分析及解决对策122344
  • .gitignore文件设置了忽略但不生效
  • .NET CORE 3.1 集成JWT鉴权和授权2
  • .NET Core WebAPI中封装Swagger配置
  • .NET Core 控制台程序读 appsettings.json 、注依赖、配日志、设 IOptions
  • .Net8 Blazor 尝鲜
  • .NET设计模式（2）：单件模式（Singleton Pattern）
  • .net下的富文本编辑器FCKeditor的配置方法
  • /etc/skel 目录作用
  • @Validated和@Valid校验参数区别
  • []error LNK2001: unresolved external symbol _m
  • []FET-430SIM508 研究日志 11.3.31
  • [1127]图形打印 sdutOJ
  • [2021]Zookeeper getAcl命令未授权访问漏洞概述与解决