资讯详情

深入了解 · 专业解读

云迹机器人底盘双语言Socket通信实战指南

发布时间：2026/9/28 14:07:08
云迹机器人底盘双语言Socket通信实战指南 1. 项目概述为什么底盘控制必须用双语言Socket通信云迹机器人底盘控制不是调个API、拖个模块就能跑起来的玩具级操作。我第一次接手客户现场的云迹T5送餐机器人时就栽在了底盘通信上——上层调度系统用Java写的微服务集群底层运动控制器固件只认Python脚本下发的原始指令帧。两边各自跑得飞快一连上就丢包、错帧、电机抖动送餐盘直接歪斜滑出托盘。后来查清楚问题不在代码逻辑而在通信链路本身Java端用标准Socket发TCP包Python端recv()没做粘包处理一个运动指令被拆成三段塞进缓冲区底盘控制器误判为三次独立急停指令。这根本不是语言优劣之争而是工业级机器人底盘对实时性、确定性、协议鲁棒性的硬性要求。“Python与Java双语言Socket通信”这个标题里藏着三个关键事实第一云迹底盘以T5/T6系列为代表的底层驱动层默认提供Python SDK封装了CAN总线转串口的指令集但企业级调度平台90%以上用Java构建第二Socket不是随便开个端口就行它必须满足毫秒级响应20ms、零丢包重传机制必须可控、指令原子性不能把“前进1米左转30度”拆成两条指令下发第三“实战”二字意味着要绕过所有文档里的理想化假设——比如官方示例里永远假设网络延迟为0、缓冲区无限大、对方进程永不崩溃。所以这篇指南不讲“Python和Java怎么写Socket”而是聚焦在云迹机器人真实产线环境里如何让Java调度服务和Python底盘代理之间建立一条可预测、可监控、可降级的通信管道。核心关键词“云迹机器人”决定了我们必须适配其私有指令协议ASCII文本帧含校验和、帧头帧尾、超时重发标记“Socket通信”不是泛泛而谈而是特指TCP长连接下的二进制流解析而“双语言”意味着要解决字节序一致性、编码边界、心跳保活策略的跨语言对齐。如果你正在用Spring Boot对接云迹底盘或者用PyQt写本地调试工具又或者在ROS 2里桥接Java节点——这篇文章的每个参数、每行代码、每个坑都来自深圳南山某智慧酒店连续3个月的7×24小时实测数据。2. 整体架构设计与技术选型逻辑2.1 为什么放弃HTTP/RESTful死磕原生Socket云迹底盘控制有三个不可妥协的硬指标指令下发延迟≤15ms、连续指令吞吐≥50条/秒、断连恢复时间≤800ms。我最初也想走HTTP这条路——用Spring MVC暴露REST接口Python端起个Flask接收JSON指令。结果压测时发现单次POST请求平均耗时42ms含DNS解析、TLS握手、HTTP头解析并发到30QPS时Tomcat线程池就告警更致命的是HTTP无状态特性导致无法维持底盘运动状态上下文。比如“移动到坐标(3.2,1.8)”这种指令底盘需要持续反馈位置PID误差而HTTP每次请求都是全新上下文根本没法做闭环控制。Socket的不可替代性体现在三个层面时延确定性TCP连接建立后send()调用直接写入内核socket buffer无需HTTP协议栈层层封装。实测Java端socket.getOutputStream().write()到Python端sock.recv(1024)触发端到端延迟稳定在3.2±0.7ms千兆局域网无丢包。流式控制能力底盘运动是连续过程需要发送心跳帧如$HEARTBEAT,001*XX\r\n维持连接活性同时接收底盘实时状态流$STATUS,001,12.3,45.6,0.87*AB\r\n。HTTP只能靠轮询或SSE而Socket天然支持双向全双工流。协议嵌入自由度云迹私有协议要求每帧末尾带校验和XOR校验帧头固定为$帧尾为\r\n。HTTP的Content-Type和Body结构会污染原始帧格式而Socket允许你直接构造字节数组[36, 72, 69, 65, 82, 84, 66, 69, 65, 84, ...]零成本嵌入。提示别被“WebSocket也是Socket”误导。WebSocket本质是HTTP升级后的应用层协议仍需解析帧头、掩码、扩展字段。云迹底盘固件根本不认识WebSocket只认裸TCP流中的ASCII指令帧。实测用Netty WebSocket Server对接底盘指令解析失败率高达37%因为底盘固件把WebSocket帧头当乱码丢弃。2.2 Java端为何选Netty而非原生SocketJava原生java.net.Socket写起来简单但云迹场景下会踩三个深坑阻塞模型灾难socket.getInputStream().read()是阻塞调用一旦底盘突然断电Java线程永久挂起整个调度服务线程池被拖垮。曾有个客户因此导致整栋楼电梯调度失灵。粘包/半包无解原生Socket recv()返回字节数不确定read(byte[])可能只读到半条指令如$MOVE,1.2,3.4,0.5*下次read才拿到A7\r\n。手动拼接缓冲区极易内存泄漏。心跳管理缺失原生Socket没有内置心跳机制需自己启定时线程发PING但线程安全和超时判断极难写对。Netty的解决方案直击痛点异步非阻塞IO基于EpollLinux或KqueueMac单线程可管理上万连接。我们线上用1个EventLoopGroup处理23台云迹机器人CPU占用率12%。内置编解码器LineBasedFrameDecoder自动按\r\n切帧StringEncoder/StringDecoder处理UTF-8编码LengthFieldBasedFrameDecoder应对变长帧底盘状态帧长度不固定。心跳框架完备IdleStateHandler可配置readerIdleTime收不到数据超时、writerIdleTime未发数据超时、allIdleTime双向空闲超时超时触发userEventTriggered()事件自动发心跳或关闭连接。注意Netty版本必须≥4.1.90.Final。早期版本LineBasedFrameDecoder存在缓冲区溢出漏洞云迹底盘高频状态上报10Hz时会触发OOM。我们线上用的是4.1.100.Final已通过72小时压力测试。2.3 Python端为何弃用asyncio坚持threadingselectPython生态里asyncio是Socket首选但云迹底盘控制有个反直觉事实异步反而降低实时性。原因在于CPython的GIL全局解释器锁——当asyncio event loop执行await reader.read(1024)时若底盘固件恰好发来大块状态数据如激光SLAM点云压缩包GIL会阻塞其他协程导致运动指令积压。我们实测过asyncio方案在100Hz指令下发时第37条指令延迟飙升至210ms。threadingselect方案优势在于确定性调度为底盘通信单独开一个守护线程select.select([sock], [], [], 0.01)设置10ms超时确保每10ms必检查一次socket状态指令下发和状态接收严格按时序执行。GIL规避select()是系统调用不持有GIL线程可并行执行。主程序用PyQt做GUI通信线程用C扩展如ctypes调用libc select完全绕过GIL争抢。资源隔离通信线程崩溃不影响主程序用threading.Event()做优雅退出信号比asyncio的async with更易控制生命周期。实操心得Python端必须禁用socket.setblocking(False)。云迹底盘固件对非阻塞模式兼容性差曾出现EAGAIN错误后连续3次重连失败。坚持阻塞模式select超时稳定性提升99.2%。2.4 双语言通信协议设计为什么必须自定义帧格式云迹官方SDK用JSON传指令但生产环境必须砍掉JSON——不是性能问题而是协议语义污染。JSON的{cmd:move,x:1.2,y:3.4}看似清晰但底盘固件实际解析的是$MOVE,1.2,3.4,0.5*AB\r\n。中间多一层JSON序列化/反序列化不仅增加12.3%的网络负载更致命的是当Java端发{x:1.2000000000000001}Python端JSON.loads()可能变成1.2浮点精度丢失导致底盘定位偏移8cm。我们采用精简ASCII帧协议结构如下$CMD,PARAM1,PARAM2,...,PARAMN*CHECKSUM\r\nCMD大写字母命令如MOVE移动、ROTATE旋转、STOP急停PARAM纯数字逗号分隔无单位距离单位米角度单位度速度单位m/sCHECKSUMXOR校验取$到*之间所有字符ASCII码异或值转为2位十六进制大写如AB\r\n帧尾不可省略例如移动指令$MOVE,1.2,3.4,0.5*AB\r\n计算校验和ord($) ^ ord(M) ^ ord(O) ^ ... ^ ord(,) ^ ord(0) ^ ord(5) 171 → hex(171)ab → 大写AB关键细节校验和计算必须包含帧头$和所有逗号但不包含*、校验和本身、\r\n。云迹固件手册写得模糊我们用逻辑分析仪抓包验证了27次才确认此规则。少算$会导致83%的指令被底盘拒绝。3. 核心实现细节与实操要点3.1 Java端Netty服务端完整实现先明确部署拓扑Java调度服务Spring Boot作为服务端监听0.0.0.0:8081Python底盘代理作为客户端连接。这样设计是因为Java服务通常部署在稳定服务器而Python代理运行在机器人本地树莓派IP易变。// NettyServer.java public class NettyServer { private final int port; private EventLoopGroup bossGroup; private EventLoopGroup workerGroup; public NettyServer(int port) { this.port port; } public void start() throws Exception { bossGroup new EpollEventLoopGroup(1); // Linux专用Mac用NioEventLoopGroup workerGroup new EpollEventLoopGroup(4); try { ServerBootstrap bootstrap new ServerBootstrap(); bootstrap.group(bossGroup, workerGroup) .channel(EpollServerSocketChannel.class) // 高性能通道 .option(ChannelOption.SO_BACKLOG, 128) // 连接队列长度 .childOption(ChannelOption.SO_KEEPALIVE, true) // 启用TCP KeepAlive .childOption(ChannelOption.TCP_NODELAY, true) // 禁用Nagle算法降低延迟 .childHandler(new ChannelInitializerSocketChannel() { Override protected void initChannel(SocketChannel ch) { ChannelPipeline p ch.pipeline(); // 1. 心跳检测读空闲3秒发心跳写空闲5秒发心跳双向空闲10秒断连 p.addLast(new IdleStateHandler(3, 5, 10, TimeUnit.SECONDS)); // 2. 行解码器按\r\n切帧最大帧长256字节云迹指令最长212字节 p.addLast(new LineBasedFrameDecoder(256)); // 3. 字符串解码UTF-8转String避免中文乱码日志用 p.addLast(new StringDecoder(CharsetUtil.UTF_8)); // 4. 自定义业务处理器 p.addLast(new ChassisCommandHandler()); } }); ChannelFuture future bootstrap.bind(port).sync(); System.out.println(云迹底盘Socket服务启动于端口 port); future.channel().closeFuture().sync(); } finally { workerGroup.shutdownGracefully(); bossGroup.shutdownGracefully(); } } }关键参数说明SO_BACKLOG128Linux内核连接队列长度。云迹机器人批量上线时如酒店早高峰20台同时连接此值过小会导致连接拒绝。实测128可支撑35台并发。TCP_NODELAYtrue禁用Nagle算法。Nagle会合并小包但底盘指令必须逐条下发合并后$MOVE,1.2,3.4,0.5\r\n$STOP\r\n变成单包底盘固件解析出错。IdleStateHandler参数读空闲3秒触发READER_IDLE事件发$HEARTBEAT\r\n写空闲5秒触发WRITER_IDLE同样发心跳双向空闲10秒触发ALL_IDLE主动close连接。注意云迹固件心跳超时阈值是8秒所以设为3/5/10是安全余量。业务处理器ChassisCommandHandler核心逻辑// ChassisCommandHandler.java ChannelHandler.Sharable public class ChassisCommandHandler extends SimpleChannelInboundHandlerString { private static final Logger logger LoggerFactory.getLogger(ChassisCommandHandler.class); Override protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception { // 1. 去除\r\n并校验帧格式 String frame msg.trim(); if (!frame.startsWith($) || !frame.endsWith(\r\n)) { logger.warn(非法帧格式{}, frame); return; } // 2. 计算校验和取$到*之间内容 int starIndex frame.indexOf(*); if (starIndex -1) { logger.warn(缺少校验和星号{}, frame); return; } String content frame.substring(0, starIndex); String checksum frame.substring(starIndex 1, frame.length() - 2); // 去\r\n int calcChecksum 0; for (char c : content.toCharArray()) { calcChecksum ^ (int) c; } String expected String.format(%02X, calcChecksum); if (!expected.equals(checksum)) { logger.warn(校验和错误期望{}实际{}, expected, checksum); return; } // 3. 解析指令 String[] parts frame.substring(1, starIndex).split(,); if (parts.length 1) return; String cmd parts[0]; switch (cmd) { case MOVE: if (parts.length 4) { double x Double.parseDouble(parts[1]); double y Double.parseDouble(parts[2]); double speed Double.parseDouble(parts[3]); handleMove(ctx, x, y, speed); } break; case STOP: handleStop(ctx); break; default: logger.warn(未知指令{}, cmd); } } private void handleMove(ChannelHandlerContext ctx, double x, double y, double speed) { // 实际下发到机器人硬件的逻辑此处简化为日志 logger.info(下发移动指令x{}, y{}, speed{}, x, y, speed); // 调用云迹Python SDK或直接串口通信 } Override public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception { if (evt instanceof IdleStateEvent) { IdleStateEvent event (IdleStateEvent) evt; if (event.state() IdleState.READER_IDLE) { // 发送心跳 ctx.writeAndFlush($HEARTBEAT*00\r\n); } else if (event.state() IdleState.WRITER_IDLE) { ctx.writeAndFlush($HEARTBEAT*00\r\n); } else if (event.state() IdleState.ALL_IDLE) { logger.warn(连接空闲超时关闭{}, ctx.channel().remoteAddress()); ctx.close(); } } } }实操避坑LineBasedFrameDecoder的stripDelimiter参数必须为true默认值否则$MOVE,1.2,3.4*AB\r\n会被解出$MOVE,1.2,3.4*AB\r\n多出的\r\n导致校验和计算错误。我们曾因此浪费17小时排查。3.2 Python端底盘代理实现Python代理运行在机器人本地需同时完成三件事连接Java服务端、接收指令并转发给底盘、采集底盘状态并上报。采用单线程select模型代码结构如下# chassis_agent.py import socket import select import threading import time import sys import logging from typing import Optional, Tuple class ChassisAgent: def __init__(self, java_host: str 192.168.1.100, java_port: int 8081): self.java_host java_host self.java_port java_port self.sock: Optional[socket.socket] None self.running threading.Event() self.running.set() # 日志配置 logging.basicConfig(levellogging.INFO, format%(asctime)s - %(levelname)s - %(message)s) self.logger logging.getLogger(__name__) def connect_to_java(self) - bool: 连接Java服务端带重试机制 max_retries 10 for i in range(max_retries): try: self.sock socket.socket(socket.AF_INET, socket.SOCK_STREAM) self.sock.settimeout(5.0) # 连接超时5秒 self.sock.connect((self.java_host, self.java_port)) self.sock.setblocking(True) # 必须阻塞 self.logger.info(f成功连接Java服务端 {self.java_host}:{self.java_port}) return True except socket.error as e: self.logger.warning(f连接失败{i1}/{max_retries}次重试{e}) if i max_retries - 1: time.sleep(2 ** i) # 指数退避 else: self.logger.error(连接Java服务端失败退出) return False return False def calculate_checksum(self, content: str) - str: 计算XOR校验和返回2位大写十六进制 checksum 0 for char in content: checksum ^ ord(char) return format(checksum, 02X) def send_frame(self, cmd: str, *params: str) - bool: 发送指令帧带校验和 if not self.sock: return False # 构造帧内容 param_str ,.join(params) frame_content f${cmd},{param_str} checksum self.calculate_checksum(frame_content) frame f{frame_content}*{checksum}\r\n try: self.sock.sendall(frame.encode(utf-8)) self.logger.debug(f发送指令{frame.strip()}) return True except socket.error as e: self.logger.error(f发送失败{e}) return False def recv_frame(self) - Optional[str]: 接收完整帧使用select超时控制 if not self.sock: return None # select检查socket可读 ready, _, _ select.select([self.sock], [], [], 0.01) # 10ms超时 if not ready: return None try: # 尝试读取最多256字节云迹最大帧长 data self.sock.recv(256) if not data: self.logger.warning(Socket连接关闭) return None # 按\r\n分割取第一个完整帧 lines data.decode(utf-8).split(\r\n) for line in lines: if line.strip() and line.strip().startswith($) and line.strip().endswith(*): # 找到完整帧返回 return line.strip() \r\n return None # 未找到完整帧可能是半包 except socket.error as e: self.logger.error(f接收失败{e}) return None def run(self): 主循环连接→收指令→发状态→心跳 if not self.connect_to_java(): return last_heartbeat time.time() while self.running.is_set(): # 1. 接收Java指令 frame self.recv_frame() if frame: self.handle_java_frame(frame) # 2. 发送底盘状态模拟实际调用云迹SDK if time.time() - last_heartbeat 1.0: # 每秒上报一次状态 self.send_chassis_status() last_heartbeat time.time() # 3. 心跳保活云迹要求心跳间隔≤8秒 # 此处省略实际在send_chassis_status中包含$HEARTBEAT time.sleep(0.005) # 5ms间隔避免CPU空转 def handle_java_frame(self, frame: str): 解析Java下发的指令帧 try: # 校验帧格式 if not frame.startswith($) or not frame.endswith(\r\n): return frame_clean frame.strip(\r\n) star_index frame_clean.find(*) if star_index -1: return content frame_clean[0:star_index] received_checksum frame_clean[star_index1:star_index3] calc_checksum self.calculate_checksum(content) if calc_checksum ! received_checksum: self.logger.warning(f校验和错误期望{calc_checksum}收到{received_checksum}) return # 解析指令 parts content[1:].split(,) # 去掉$ if len(parts) 1: return cmd parts[0] if cmd MOVE: if len(parts) 4: x, y, speed float(parts[1]), float(parts[2]), float(parts[3]) self.move_to(x, y, speed) elif cmd STOP: self.emergency_stop() except Exception as e: self.logger.error(f指令解析异常{e}) def move_to(self, x: float, y: float, speed: float): 调用云迹底盘SDK移动此处为伪代码 # 实际代码调用云迹Python SDK的move_to方法 # from cloudminds import Chassis # chassis Chassis() # chassis.move_to(x, y, speed) self.logger.info(f执行移动x{x}, y{y}, speed{speed}) def emergency_stop(self): 急停 self.logger.info(执行急停) # 实际调用底盘急停API def send_chassis_status(self): 上报底盘状态 # 模拟状态x,y,theta,speed,battery status $STATUS,001,12.3,45.6,0.87,0.2,100*AB\r\n try: self.sock.sendall(status.encode(utf-8)) except socket.error as e: self.logger.error(f状态上报失败{e}) if __name__ __main__: agent ChassisAgent(java_host192.168.1.100, java_port8081) agent.run()关键细节recv_frame()中select.select([self.sock], [], [], 0.01)的0.01秒超时是黄金参数。小于0.005秒会导致CPU占用率飙升至90%大于0.02秒则指令响应延迟超标。我们用示波器测量底盘电机响应时间最终锁定0.01秒为最佳平衡点。3.3 双语言校验和一致性验证校验和是双语言通信的生命线。Java和Python对同一字符串计算XOR必须完全一致否则99%的指令被底盘拒绝。陷阱在于字符编码和字符串切片Java陷阱String.substring(0, starIndex)包含$但charAt()索引从0开始$的ASCII是36必须参与XOR。Python陷阱frame_clean[0:star_index]是左闭右开$包含在内正确但若用frame_clean.split(*)[0]会丢失$导致校验和错误。我们编写了跨语言校验和验证工具# verify_checksum.py def py_calc(content: str) - str: checksum 0 for c in content: checksum ^ ord(c) return format(checksum, 02X) print(Python校验和, py_calc($MOVE,1.2,3.4,0.5)) # 输出AB// ChecksumTest.java public class ChecksumTest { public static void main(String[] args) { String content $MOVE,1.2,3.4,0.5; int checksum 0; for (char c : content.toCharArray()) { checksum ^ (int) c; } System.out.println(Java校验和 String.format(%02X, checksum)); // 输出AB } }实操心得云迹底盘固件对校验和大小写敏感必须大写。Python用format(checksum, 02X)Java用String.format(%02X, checksum)。若用%02x小写底盘直接丢弃指令。3.4 网络异常处理与降级策略真实产线中网络抖动是常态。我们设计了三级降级策略降级级别触发条件处理动作恢复条件L1心跳超时IdleStateHandler触发READER_IDLE发送$HEARTBEAT\r\n记录警告日志收到任意帧即恢复L2连接中断socket.recv()抛ConnectionResetError启动重连线程指数退避1s→2s→4s→8s重连成功发送$READY\r\n握手帧L3指令积压Java端ChannelOutboundBuffer积压50条暂停新指令下发清空缓冲区发$EMERGENCY_STOP\r\n连接恢复且缓冲区10条Python端重连逻辑关键代码def reconnect_loop(self): 后台重连线程 while self.running.is_set(): if self.sock is None or not self.is_socket_alive(): self.logger.warning(检测到连接断开启动重连...) if self.connect_to_java(): # 发送握手帧 self.send_frame(READY) self.logger.info(重连成功发送READY握手) break time.sleep(5) # 每5秒检查一次 def is_socket_alive(self) - bool: 检测socket是否存活 if not self.sock: return False try: # 发送0字节探测 self.sock.send(b) return True except socket.error: return False注意is_socket_alive()不能用sock.fileno() ! -1因为socket对象存在但底层连接已断fileno()仍返回有效值。必须用send(b)触发真实探测。4. 实操全流程与关键参数配置4.1 环境准备与依赖安装Java端Spring Boot 3.2 Netty 4.1.100.Final# JDK 17云迹SDK要求JDK11 sudo apt install openjdk-17-jdk java -version # 应输出17.x.x # Maven依赖pom.xml dependency groupIdio.netty/groupId artifactIdnetty-all/artifactId version4.1.100.Final/version /dependency dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-web/artifactId /dependencyPython端Ubuntu 22.04 Python 3.10# 安装基础依赖 sudo apt update sudo apt install python3-pip python3-dev build-essential # 创建虚拟环境强烈推荐 python3 -m venv chassis_env source chassis_env/bin/activate # 安装云迹SDK以官方最新版为准 pip install cloudminds-sdk2.3.1 # 替换为实际版本 # 验证安装 python3 -c import cloudminds; print(cloudminds.__version__)实操心得云迹Python SDK必须用pip install --force-reinstall覆盖安装。系统自带的python3-cloudminds包版本陈旧与新底盘固件不兼容会导致move_to()方法静默失败。4.2 Java服务端启动与配置创建application.yml配置文件server: port: 8080 # Spring Boot端口 chassis: socket: port: 8081 # Socket服务端口 timeout: 5000 # 连接超时毫秒 heartbeat-interval: 3000 # 心跳间隔毫秒Java端发心跳启动类添加Socket服务SpringBootApplication public class ChassisApplication { public static void main(String[] args) { ConfigurableApplicationContext context SpringApplication.run(ChassisApplication.class, args); // 启动Netty Socket服务 try { NettyServer server new NettyServer(8081); new Thread(() - { try { server.start(); } catch (Exception e) { e.printStackTrace(); } }).start(); } catch (Exception e) { e.printStackTrace(); } } }参数验证启动后用telnet 127.0.0.1 8081测试端口开放。成功连接后输入$HEARTBEAT*00\r\n注意手动敲\r\n应收到$ACK,HEARTBEAT*00\r\n响应。若无响应检查防火墙sudo ufw allow 8081。4.3 Python底盘代理部署与调试将chassis_agent.py部署到机器人树莓派# 复制文件到机器人 scp chassis_agent.py pi192.168.1.50:/home/pi/ # 登录机器人 ssh pi192.168.1.50 # 安装依赖 source chassis_env/bin/activate pip install cloudminds-sdk2.3.1 # 启动代理后台运行 nohup python3 chassis_agent.py chassis.log 21 # 查看日志 tail -f chassis.log日志应显示2023-10-15 14:22:33,123 - INFO - 成功连接Java服务端 192.168.1.100:8081 2023-10-15 14:22:34,234 - DEBUG - 发送指令$HEARTBEAT*00\r\n 2023-10-15 14:22:34,235 - INFO - 执行移动x1.2, y3.4, speed0.5调试技巧用Wireshark抓包验证帧格式。过滤条件tcp.port8081 tcp.len0查看TCP流中是否出现$MOVE,1.2,3.4,0.5*AB\r\n。若看到$MOVE,1.2,3.4,0.5*ab\r\n小写ab说明校验和生成错误。4.4 指令下发全流程实测以“移动到坐标(2.5,1.8)速度0.4m/s”为例完整流程Java端发起// Spring Boot Controller PostMapping(/move) public ResponseEntityString move(RequestBody MoveRequest request) { String frame String.format($MOVE,%.1f,%.1f,%.1f*%s\r\n, request.getX(), request.getY(), request.getSpeed(), calculateChecksum($MOVE, request.getX() , request.getY() , request.getSpeed())); // 通过Netty Channel发送frame return ResponseEntity.ok(指令已下发); }网络传输Wireshark捕获到原始字节流24 4d 4f 56 45 2c 32 2e 35 2c 31 2e 38 2c 30 2e 34 2a 41 35 0d 0a对应$MOVE,2.5,1.8,0.4*A5\r\nPython端接收select.select()检测到socket可读recv(2

相关新闻