java开发TCPIP协议：实现TCP单向裸数据发送

2023-12-20 22:20
文章标签 java 数据 实现 协议 开发 tcp 发送 单向 tcpip

本文主要是介绍java开发TCPIP协议：实现TCP单向裸数据发送，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

前面我们花费大量篇幅完成了TCP协议各种细节的讲解，从中我们能体会到该协议的复杂和烦琐。因此要想从零实现工业级鲁棒性的TCP数据传输协议几乎不可能，因此我们在实现过程中必须尽可能简化，就像老子说的天下难事必作于易，天下大事必作于细，因此我们在实现这么复杂的协议系统时必须从最简单的情况入手，然后一点点增加其骨架和血肉的丰富性。

本节我们先实现一次单向数据传输，我们将开放一个基于TCP协议的客户端，使用TCP协议向服务器发送裸数据，它的基本结构如下图：
tcp-server.png
该流程图是我们开发Client，让它与服务器进行三次握手连接后，Client向Server发送一个字符’t’，然后向服务器断开连接的过程。在完成这些代码的过程我体会到”知道那么多道理还是过不好这一生“这个大道理，虽然在前面章节我们言之凿凿的讲了很多TCP协议原理，到我真正实现起来时也得不断发蒙，调试了好久才能通过。

首先最容易发蒙的是seq和ack值的变化。通常情况下，当你发送的数据长度为len,如果发出去的数据包含有对应的seq值，如果对方收到数据后它返回的数据包对应ack就应该是发送方的seq+len，但有例外的情况，就像上图中握手和断开过程，如果对方发来的数据包中包含SYN,FIN等标志位，那么回复对方时ack的值必须是对方的seq加上对方数据长度，然后再加上1，这也就是为何在三次握手时，第一次我们给对方发送SYN包，seq设置为0，同时数据包没有任何数据，对方回复时却将ack设置为1的原因，然后对方发来的ACK+FIN时，它的seq为0，我们回复时必须将ack设置为1，这个现象在断开连接，也就是双方互发包含FIN的数据包时也是一样，这一点让我调试了好久才搞明白。

接下来我们进入实现阶段，首先我们需要在另一台设备上安装TCP服务器，只有服务器和客户端不在同一台设备上时我们才好使用wireshark抓包。通常情况下我们可以在手机上下载一个最简单的tcp服务器，我用的是iPhone，在AppStore里用tcp server为关键字就可以搜索到下面应用程序，设置好端口后就可以变成一个最简单的tcp服务器：

屏幕快照 2019-11-08 上午11.08.55.png
只要你能在另一台设备上运行可以接收TCP数据包的服务器程序都可以，我们的任务是在我们自己对TCP协议的实现基础上开发客户端，与它连接后，向它发送一个字符，然后端口连接，我们看看代码的实现。

在代码设计上我使用观察者模式，上层应用向TCP协议层调用相关接口后，TCP协议层以回调的方式通知上层应用，因此我们先添加接口定义：

package utils;public interface ITCPHandler {public  void  connect_notify(boolean connect_res);  //返回tcp连接结果public  void  send_notify(boolean send_res, int packet_handler); //通知数据包发送结果public  void  connect_close_notify(boolean close_res); //返回连接关闭通知
}

任何想要调用TCP协议层的应用都必须继承该接口，我们看看客户端的实现：

package Application;import java.net.InetAddress;import utils.ITCPHandler;public class TCPRawDataSender implements ITCPHandler{private  TCPThreeHandShakes  tcp_socket = null;  @Overridepublic void connect_notify(boolean connect_res) {if (connect_res) {System.out.println("connection established!");try {tcp_socket.tcp_send("t".getBytes());} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}else {System.out.println("connection fail!");}}@Overridepublic void send_notify(boolean send_res, int packet_handler) {if (send_res == true) {System.out.println("send data ok!");}try {tcp_socket.tcp_close();} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}@Overridepublic void connect_close_notify(boolean close_res) {if (close_res == true) {System.out.println("connection close complete!");} else {System.out.println("connection close fail!");}}public void run() {try {InetAddress ip = InetAddress.getByName("192.168.2.127"); //220.181.43.8short port = 1234;tcp_socket = new TCPThreeHandShakes(ip.getAddress(), port, this);tcp_socket.tcp_connect();System.out.println("finish handshake!");} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}}

它的逻辑很简单，首先调用tcp_connect与给定服务器进行三次握手的连接。连接成功后，它的connect_notify接口会被调用，然后他使用tcp_send来向服务器发送一个字节，该调用会返回一个整数当做当前数据发送的句柄，当发送完成后它的send_notify接口会被调用，然后将发送结果与数据对应句柄关联起来告知相应数据发送是否成功。该接口被调用时客户端使用tcp_close来断开连接，如果断开成功，那么它的connect_close_notify会被调用。

同时前面实现的TCPThreeHandShakes将作为使用TCP协议的中间层，由它负责调用TCP协议封包层来发送和接收数据，为此我对其做了一些修改：

public class TCPThreeHandShakes extends Application{private byte[] dest_ip;private byte [] send_data = null;private short dest_port;private int ack_num = 0;private int seq_num = 0;ITCPHandler tcp_handler = null;//增加协议状态标量private static int CONNECTION_IDLE = 0;private static int CONNECTION_CONNECTING = 1;private static int CONNECTION_CONNECTED = 2;private static int CONNECTION_CLOSING = 3;private static int CONNECTION_SEND = 4;private int  tcp_state = CONNECTION_IDLE;public TCPThreeHandShakes(byte[] server_ip, short server_port, ITCPHandler tcp_handler) {this.dest_ip = server_ip;this.dest_port = server_port;//指定一个固定端口，以便抓包调试	Random rand = new Random();this.port = (short)rand.nextInt();this.tcp_handler = tcp_handler;}public boolean tcp_connect() throws Exception {if (tcp_state != CONNECTION_IDLE) {  //只有在空闲状态才能发起新连接return  false; }tcp_state = CONNECTION_CONNECTING;beginThreeHandShakes();return true;}public boolean tcp_close() throws Exception {if (this.tcp_state != CONNECTION_CONNECTED) {return false;}tcp_state = CONNECTION_CLOSING;//启动关闭流程beginClose();return true;}public boolean tcp_send(byte[] data) throws Exception {if (this.tcp_state != CONNECTION_CONNECTED) {return false;}tcp_state = CONNECTION_SEND;send_data = data;createAndSendPacket(data, "ACK");return true;}
.....
@Overridepublic void handleData(HashMap<String, Object> headerInfo) {。。。。if (ack) {int seq_num = (int)headerInfo.get("seq_num");int ack_num = (int)headerInfo.get("ack_num");byte[] data = (byte[])headerInfo.get("data");int data_length = 0;if (data != null) {  //如果收到对方数据，那么将对方seq加上数据长度最为ack回应data_length += data.length;}try {if (this.tcp_state == CONNECTION_CONNECTING && syn) {this.tcp_state = CONNECTION_CONNECTED;System.out.println("tcp handshake from othersize with seq_num" + seq_num + " and ack_num: " + ack_num);this.seq_num = ack_num;this.ack_num = seq_num + 1;createAndSendPacket(null, "ACK");this.tcp_handler.connect_notify(true); //通知上面连接成功}if (tcp_state == CONNECTION_SEND && ack_num == this.seq_num + send_data.length) {tcp_state = CONNECTION_CONNECTED;this.seq_num = ack_num;send_data = null;this.ack_num = seq_num + data_length;tcp_handler.send_notify(true, 0);}if (tcp_state == CONNECTION_CLOSING) {  //向对方发送ack+fin然后收到ack进入到此tcp_state = CONNECTION_IDLE;this.seq_num = 0;this.ack_num = 0;}if (fin) {  //收到fin包时，ack 要在对方seq上加1this.seq_num = ack_num;this.ack_num = seq_num + data_length + 1;createAndSendPacket(null, "ACK");if (tcp_state != CONNECTION_IDLE && tcp_state != CONNECTION_CLOSING) { //这里意味对方主动发起断开,因此回复ack后再次向对方发送ack+fincreateAndSendPacket(null, "FIN,ACK");}}} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}//收到服务器发回的fin+ack包，正式关闭连接if (ack && fin) {  System.out.println("receive fin packet and close connection");if (this.tcp_state == CONNECTION_CLOSING) {this.tcp_state = CONNECTION_IDLE;this.tcp_handler.connect_close_notify(true); //通知上面连接关闭try { int seq_num = (int)headerInfo.get("seq_num");int ack_num = (int)headerInfo.get("ack_num");System.out.println("tcp handshake closing from othersize with seq_num" + seq_num + " and ack_num: " + ack_num);this.seq_num += 1;this.ack_num = seq_num + 1;createAndSendPacket(null, "ACK");} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}}}
}

我对这个类代码上做了较大改动，具体的修改设计过程请观看视频的详细讲解，在上面代码完成后运行时，效果如下，首先是服务器端成功接收到了代码向他发送的字符’t’:

屏幕快照 2019-11-08 上午11.30.49.png

同时wireshark抓包情况如下：
屏幕快照 2019-11-08 上午11.32.18.png

下一节我们将在此基础上实现更复杂的双向数据发送。
更详细的讲解和代码调试演示过程，请点击链接
更多技术信息，包括操作系统，编译器，面试算法，机器学习，人工智能，请关照我的公众号：
这里写图片描述

这篇关于java开发TCPIP协议：实现TCP单向裸数据发送的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/517717。

相关文章

JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
Spring Security--Architecture Overview

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类，它们之间的依赖，构建起了整个框架。想要理解整个架构，最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文（security context）的信息。当前操作的用户是谁，该用户是否已经被认证，他拥有哪些角色权限…这些都被保
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
Spring Security 从入门到进阶系列教程

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门（一）：登录与退出》 《Spring-Security-入门（二）：基于数据库验证》 《Spring-Security-入门（三）：密码加密》 《Spring-Security-入门（四）：自定义-Filter》 《Spring-Security-入门（五）：在 Sprin
阅读更多...
Java架构师知识体认识

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物
阅读更多...
大模型研发全揭秘：客服工单数据标注的完整攻略

大模型研发全揭秘：客服工单数据标注的完整攻略

在人工智能（AI）领域，数据标注是模型训练过程中至关重要的一步。无论你是新手还是有经验的从业者，掌握数据标注的技术细节和常见问题的解决方案都能为你的AI项目增添不少价值。在电信运营商的客服系统中，工单数据是客户问题和解决方案的重要记录。通过对这些工单数据进行有效标注，不仅能够帮助提升客服自动化系统的智能化水平，还能优化客户服务流程，提高客户满意度。本文将详细介绍如何在电信运营商客服工单的背景下进行
阅读更多...
基于MySQL Binlog的Elasticsearch数据同步实践

基于MySQL Binlog的Elasticsearch数据同步实践

一、为什么要做 随着马蜂窝的逐渐发展，我们的业务数据越来越多，单纯使用 MySQL 已经不能满足我们的数据查询需求，例如对于商品、订单等数据的多维度检索。 使用 Elasticsearch 存储业务数据可以很好的解决我们业务中的搜索需求。而数据进行异构存储后，随之而来的就是数据同步的问题。 二、现有方法及问题 对于数据同步，我们目前的解决方案是建立数据中间表。把需要检索的业务数据，统一放到一张M
阅读更多...
这15个Vue指令，让你的项目开发爽到爆

这15个Vue指令，让你的项目开发爽到爆

1. V-Hotkey 仓库地址: github.com/Dafrok/v-ho… Demo: 戳这里 https://dafrok.github.io/v-hotkey 安装: npm install --save v-hotkey 这个指令可以给组件绑定一个或多个快捷键。你想要通过按下 Escape 键后隐藏某个组件，按住 Control 和回车键再显示它吗？小菜一碟： <template
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2