简介本资源是一个面向Java开发者与工业自动化工程师的西门子S7系列PLC通信入门实践项目聚焦于使用S7connector库实现上位机与PLC的稳定连接、数据读写及基础控制逻辑交互适用于智能制造、产线监控系统开发等场景。压缩包为ZIP格式共72个文件含62个Java源码集中于src/main/java下的连接管理、数据解析与协议封装模块、2个XML配置文件pom.xml定义Maven依赖与构建流程、2个Markdown文档README.md与CONTRIBUTING.md提供项目说明与贡献指南、以及Makefile、.gitignore、LICENSE等工程支撑文件整体体积仅527KB轻量易导入。已有1561人学习下载项目结构完整具备典型Maven Java工程特征包含测试目录、许可证声明与CI配置.travis.yml可直接编译运行并快速复现S7通信全流程是掌握工业协议Java集成的高实用性参考范例。1. 为什么用 Java 连西门子 PLC这个 s7connector-master 示例项目不是“玩具”而是工业现场可落地的通信起点很多刚接触工控自动化的人会下意识认为PLC 通信必须用博图、Step 7 或 C# Siemens S7.NET——Java太重、太慢、不靠谱。但现实是越来越多的 MES、SCADA 中间件、边缘计算网关和数字孪生平台正用 Java 构建跨厂商、跨协议的数据接入层。s7connector-master 就是这样一个被真实产线验证过的轻量级实现它不依赖 Siemens 官方 SDK无授权限制纯 Java 实现 S7Comm 协议栈支持 ISO on TCP即 S7 的标准以太网通信模式能直接对接 S7-1200/1500需开启 PUT/GET 功能、S7-300/400需 CP343-1 或集成以太网口。项目里src/main/java/com/s7connector/下的S7Connector类封装了连接池、读写超时、DB 块/MB/IB/QB 地址解析等关键逻辑而test/目录中S7ConnectorTest用真实 PLC IP 和 Rack/Slot 参数跑通了读 DB100.DBD0、写 M100.0 等典型操作。它适合两类人一是 Java 后端工程师要快速接入产线设备数据二是自动化工程师想绕过博图二次开发门槛用熟悉语法控制逻辑。注意它不处理 OPC UA也不兼容 TIA Portal V18 的新安全握手机制这是它的边界也是你选型前必须看清的起点。2. 拆解 s7connector-master 的核心通信链路从 Maven 依赖到 S7Comm 协议帧构造2.1 项目结构与构建方式Maven 是唯一入口pom.xml 决定协议兼容性打开压缩包中的pom.xml第一眼就能确认这是标准 Maven 项目。关键依赖只有两项netty-all用于异步 TCP 通信和junit测试驱动。没有siemens-s7-sdk或opcua-stack这类重量级闭源库说明作者刻意规避了授权风险。build段落里plugins配置了maven-compiler-plugin目标 JDK 8这解释了为何项目能在老旧工控机上运行——很多现场服务器仍停留在 Java 8 环境。src/main/resources/下虽无配置文件但src/main/java/com/s7connector/impl/S7ConnectorImpl.java中硬编码了默认超时参数READ_TIMEOUT_MS 5000、WRITE_TIMEOUT_MS 3000。这些值在实际产线中往往需要调大因为 PLC 响应受扫描周期、网络抖动影响极大。Makefile存在但仅提供make clean和make test的快捷命令本质是 Maven 的 wrapper真正构建必须执行mvn clean compile而非make build。提示不要直接运行mvn exec:java启动主类——项目未定义mainClass。正确做法是先mvn compile编译再手动执行java -cp target/classes:lib/* com.s7connector.example.S7Example需提前将lib/下的 netty jar 复制到 target 目录。2.2 S7Comm 协议握手流程三次 TCP 连接 两次 ISO on TCP 报文交换s7connector 的核心不在“连上”而在“连稳”。它复现了西门子 S7 协议的完整握手链路TCP 连接向 PLC 的 102 端口发起三次握手非 80 或 443这是 S7 专用端口ISO on TCP 连接请求发送 COTP 连接请求报文0x11 0x03 0x00 0x00 0x01 0x00 0x01其中0x01表示 TSAPTransport Service Access Point的本地/远程地址对应 PLC 的 Rack/Slot 设置S7Comm Job 请求建立 ISO 连接后发送 S7Comm 协议的Job类型报文0x01 0x00 0x00 0x00 0x00 0x01 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x00触发 PLC 返回Ack_Data响应。这段逻辑藏在S7ConnectorImpl.connect()方法中。关键参数rack和slot不是随意填写的S7-1200 默认 rack0, slot1S7-1500 默认 rack0, slot2若使用 CP 卡如 CP343-1则 slot2。错误设置会导致Connection refused或No response from PLC异常。项目README.md中的示例代码new S7Connector(192.168.0.1, 0, 1)就是针对 S7-1200 的典型配置。2.2.1 报文解析实战用 Wireshark 抓包验证 S7Comm 帧结构为确认通信真实性建议在 PLC 侧开启“允许来自远程伙伴的 PUT/GET 访问”TIA Portal → 设备配置 → CPU 属性 → 保护 → 连接机制然后在 PC 上运行S7Example并用 Wireshark 过滤tcp.port 102。你会看到三组关键报文报文序号方向协议层关键字段含义1PC→PLCTCPSYN建立 TCP 连接2PC→PLCCOTPCR (Connection Request)发送 TSAP 地址Rack/Slot3PC→PLCS7CommJob (Function Code 0x01)请求建立 S7 连接抓包时注意若第 2 步 COTP 报文未收到 ACK说明 PLC 网络配置错误IP 冲突或防火墙拦截若第 3 步无响应大概率是 PUT/GET 未启用或 Rack/Slot 错误。项目test/目录下的S7ConnectorTest类中Test public void testReadDB()方法正是通过断点调试S7ConnectorImpl.readDB()的byte[] response this.sendAndReceive(request);行配合 Wireshark 定位协议层问题。2.3 数据读写实现DB 块地址解析与字节序转换的硬编码陷阱读写操作的核心是S7Connector.readDB(int dbNumber, int startByte, int length)和writeDB(int dbNumber, int startByte, byte[] data)。这里藏着两个易踩坑点第一DB 地址计算S7 的 DB 块地址不是简单偏移。例如读取DB100.DBX0.0布尔量实际请求的是DB100的第 0 字节第 0 位而DB100.DBD4双字4 字节对应起始地址startByte4长度length4。项目com.s7connector.types.DataType枚举类定义了BOOL,BYTE,WORD,DWORD,INT,DINT等类型但未自动计算字节偏移——开发者必须手动换算。比如DB100.DBD10要传startByte10而非10*4。第二字节序Endianness西门子 PLC 使用大端序Big-Endian而 x86 PC 默认小端。项目S7ConnectorImpl.convertBytesToInteger(byte[] bytes)方法中对WORD2 字节和DWORD4 字节做了显式反转// 读取 DWORD 时将网络字节序大端转为 Java int public static int bytesToInt(byte[] bytes) { return ((bytes[0] 0xFF) 24) | ((bytes[1] 0xFF) 16) | ((bytes[2] 0xFF) 8) | (bytes[3] 0xFF); }这段代码的关键在于 0xFF防止 Java 的byte有符号扩展-1 变成 0xFFFFFFFF。若漏掉此操作读取DB100.DBD0的值0x00000001会变成-1。test/目录中S7ConnectorTest.testReadDBDWord()用Assert.assertEquals(1, result)验证了该转换的正确性。3. 在真实 PLC 上跑通示例从 TIA Portal 配置到 Java 代码调试的全链路实操3.1 PLC 侧配置TIA Portal V15/V16 中启用 PUT/GET 的三步法s7connector 依赖 PUT/GET 功能而该功能在 TIA Portal 中默认关闭。必须按顺序操作硬件组态中启用通信在“设备配置” → “CPU” → “属性” → “常规” → “保护” → “连接机制”勾选“允许来自远程伙伴的 PUT/GET 访问”下载硬件配置点击“下载到设备”此时 PLC 会重启并应用新设置检查防火墙状态在“在线与诊断” → “网络安全” → “防火墙”确认“允许所有连接”或至少放行“S7comm”服务端口 102。注意若 PLC 已启用“安全访问”Secure AccessPUT/GET 会被强制禁用此时必须关闭安全访问或改用 S7-1500 的 S7-Communication需额外授权。s7connector-master 不支持 S7-Communication 协议这是它的明确限制。3.2 Java 侧连接调试用 S7Example 类验证通信连通性项目src/main/java/com/s7connector/example/S7Example.java是唯一可直接运行的入口。其 main 方法包含完整流程public static void main(String[] args) { // 1. 创建连接器实例PLC IP、Rack、Slot S7Connector connector new S7Connector(192.168.0.1, 0, 1); try { // 2. 建立连接 connector.connect(); System.out.println(Connected to PLC); // 3. 读取 DB100 的前 4 字节DBD0 byte[] data connector.readDB(100, 0, 4); System.out.println(DB100.DBD0 Arrays.toString(data)); // 4. 写入 DB100 的第 4 字节DBB4 connector.writeDB(100, 4, new byte[]{0x01, 0x02}); } catch (Exception e) { e.printStackTrace(); } finally { connector.disconnect(); } }执行前需确保PLC 与 PC 在同一网段如 PLC IP192.168.0.1PC IP192.168.0.100pom.xml中netty-all版本为4.1.42.Final项目锁定版本避免与高版本 Netty 的EventLoopGroup兼容问题若报错java.net.ConnectException: Connection refused先ping 192.168.0.1确认物理连通再telnet 192.168.0.1 102测试端口开放。3.2.1 常见异常与定位方法日志输出与断点调试结合当connector.connect()抛出IOException时不要只看堆栈。打开S7ConnectorImpl.java在connect()方法末尾添加日志// 在 sendAndReceive() 调用后插入 if (response null || response.length 0) { throw new IOException(PLC returned empty response - check PUT/GET enable and Rack/Slot); }同时在sendAndReceive()中打印原始字节数组System.out.println(Send: Arrays.toString(request)); System.out.println(Recv: Arrays.toString(response));这样能快速区分是网络层失败无 recv 输出还是协议层失败recv 有数据但格式错误。例如若 recv 到0x00 0x00 0x00 0x00 0x00 0x01 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x00全零说明 PLC 未响应问题在 PLC 配置若 recv 到0x00 0x00 0x00 0x00 0x00 0x01 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x01末字节为 0x01则是 S7Comm 错误码需查西门子文档0x01表示“无效的作业类型”。3.3 数据类型映射表Java 与 S7 数据类型的精确对应关系s7connector 对 S7 数据类型的处理是硬编码的必须严格匹配。下表列出DataType枚举与 PLC 实际变量的对应规则S7 数据类型Java 类型字节长度地址偏移规则示例 PLC 变量s7connector 调用方式BOOLboolean1 bit按位计算startBit (byteOffset * 8) bitOffsetDB100.DBX0.0readDB(100, 0, 1) 解析 bit 0BYTEbyte1 bytestartByte直接对应 DB 字节地址DB100.DBB10readDB(100, 10, 1)WORDshort2 bytesstartByte为偶数否则读取错位DB100.DBW12readDB(100, 12, 2)DWORDint4 bytesstartByte必须是 4 的倍数DB100.DBD16readDB(100, 16, 4)INTshort2 bytes同WORD但值域为 -32768~32767DB100.DBW20readDB(100, 20, 2)DINTint4 bytes同DWORDDB100.DBD24readDB(100, 24, 4)关键约束startByte必须对齐数据类型长度。例如读DINT时传startByte25会导致 PLC 返回0x0000错误响应因为 S7 要求 DINT 地址必须是 4 字节对齐0,4,8,12...。项目未做自动校验开发者需自行保证。4. 连接池与生产环境优化如何让 s7connector-master 支撑 50 PLC 并发连接4.1 原生连接管理缺陷单连接阻塞与无重连机制s7connector-master 的S7Connector类是无状态的每次connect()都新建 TCP 连接disconnect()后立即释放。这在测试场景可行但在生产环境会引发两大问题连接风暴每秒 10 次读操作 × 50 台 PLC 500 次 TCP 握手耗尽 PC 端口资源单点故障网络抖动导致IOException后调用方需自行重试而原生代码无指数退避逻辑。解决方案是封装连接池。项目src/main/java/com/s7connector/pool/目录为空说明作者未提供但可基于Apache Commons Pool2快速实现!-- pom.xml 新增依赖 -- dependency groupIdorg.apache.commons/groupId artifactIdcommons-pool2/artifactId version2.11.1/version /dependency4.1.1 自定义连接池工厂S7ConnectorFactory 的核心实现创建S7ConnectorFactory类继承BasePooledObjectFactoryS7Connectorpublic class S7ConnectorFactory extends BasePooledObjectFactoryS7Connector { private final String plcIp; private final int rack; private final int slot; public S7ConnectorFactory(String plcIp, int rack, int slot) { this.plcIp plcIp; this.rack rack; this.slot slot; } Override public S7Connector create() throws Exception { S7Connector connector new S7Connector(plcIp, rack, slot); connector.connect(); // 连接池预热时建立连接 return connector; } Override public PooledObjectS7Connector wrap(S7Connector connector) { return new DefaultPooledObject(connector); } Override public void destroyObject(PooledObjectS7Connector pooledObject) throws Exception { pooledObject.getObject().disconnect(); // 归还时断开 } Override public boolean validateObject(PooledObjectS7Connector pooledObject) { // 简单心跳读取一个固定地址如 DB1.DBX0.0 try { pooledObject.getObject().readDB(1, 0, 1); return true; } catch (Exception e) { return false; } } }此工厂确保每次borrowObject()返回的都是已连接且可用的S7Connector实例避免重复握手开销。4.2 生产级参数调优Netty EventLoop 与超时阈值的黄金组合Netty 的EventLoopGroup配置直接影响并发性能。默认NioEventLoopGroup()使用Runtime.getRuntime().availableProcessors() * 2个线程但工控场景下更推荐固定值// 在 S7ConnectorImpl 构造函数中修改 this.eventLoopGroup new NioEventLoopGroup(4); // 固定 4 个线程避免 CPU 核心数波动影响同时调整超时参数以适应产线网络参数原值推荐值依据READ_TIMEOUT_MS500010000PLC 扫描周期可能达 200ms多次读取需预留缓冲WRITE_TIMEOUT_MS30005000写操作涉及 PLC 逻辑执行响应延迟更高CONNECTION_TIMEOUT_MS30008000工厂内网可能存在 ARP 延迟这些值需写入S7ConnectorImpl的静态 final 字段并在pom.xml中添加 profile 支持多环境profiles profile idprod/id properties s7.timeout.read10000/s7.timeout.read s7.timeout.write5000/s7.timeout.write /properties /profile /profiles5. birthday14r 版本的特殊能力支持 S7-1200 的 DB 块动态读取与位操作增强5.1 birthday14r 的代码差异从 commit log 看新增特性项目标题中的birthday14r并非随机字符串而是 Git 分支名或发布标签。对比s7connector-master主干与birthday14r分支的 diff发现三个实质性更新DB 块大小自动探测新增S7Connector.getDBSize(int dbNumber)方法通过发送0x01 0x00 0x00 0x00 0x00 0x01 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x02Function Code 0x02查询 DB 块长度避免硬编码length参数位操作工具类com.s7connector.util.BitUtils提供getBit(byte[] data, int byteIndex, int bitIndex)和setBit(byte[] data, int byteIndex, int bitIndex, boolean value)直接支持DB100.DBX0.3这类位地址读写异常分类细化将IOException细分为PlcConnectionException网络层、PlcProtocolException协议层、PlcDataException数据层便于上层做差异化重试。这些改动使birthday14r版本更适合 S7-1200 应用——因为 S7-1200 的 DB 块常动态创建且位操作需求高频如启停信号、报警标志。5.1.1 动态 DB 大小探测的实战调用在S7Example.java中加入try { int dbSize connector.getDBSize(100); // 返回 DB100 的总字节数 System.out.println(DB100 size dbSize bytes); // 安全读取整个 DB 块 if (dbSize 0 dbSize 65535) { // S7 限制最大 64KB byte[] fullDb connector.readDB(100, 0, dbSize); System.out.println(Full DB100 loaded); } } catch (PlcProtocolException e) { // DB100 不存在或未激活 System.err.println(DB100 not found: e.getMessage()); }该方法底层发送 S7Comm 的Get DB Size请求PLC 返回0x00 0x00 0x00 0x00 0x00 0x01 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x00 0x02后的响应体中第 12-13 字节为高位字节第 14-15 字节为低位字节组合成 16 位整数即 DB 长度。5.2 位操作增强用 BitUtils 精确控制单个布尔量S7-1200 的 I/O 点常以位形式存在传统readDB(100, 0, 1)返回整个字节再用 0x01提取 bit0效率低且易错。birthday14r的BitUtils提供原子操作// 读取 DB100.DBX0.3第 0 字节第 3 位 byte[] dbData connector.readDB(100, 0, 1); boolean bit3 BitUtils.getBit(dbData, 0, 3); // true/false // 写入 DB100.DBX0.5 为 true byte[] writeData connector.readDB(100, 0, 1); BitUtils.setBit(writeData, 0, 5, true); connector.writeDB(100, 0, writeData);BitUtils.setBit()内部执行data[byteIndex] | (1 bitIndex)确保只修改目标位不影响同字节其他信号。这比手动位运算更安全尤其在多线程环境下。注意birthday14r版本未更新pom.xml的version需手动修改为1.4.0-r并mvn install到本地仓库否则mvn dependency:tree无法识别该版本。本文还有配套的精品资源点击获取