第一种方式(s7connector)

S7官网:S7Connector — Documentation，有简单的读写操作参考。

1.创建maven工程引入依赖

<dependency>
    <groupId>com.github.s7connector</groupId>
    <artifactId>s7connector</artifactId>
    <version>2.0</version>
</dependency>

2. 通过代码连接PLC

//PLC地址
String ipAddress = "192.168.101.90";
//默认端口
int port = 102;
S7Connector s7Connector = S7ConnectorFactory
                .buildTCPConnector()
                .withHost(ipAddress)
                .withPort(port)
                .withTimeout(10000) //连接超时时间
                .withRack(0)
                .withSlot(1)
                .build();

3.解析获取的数据

//第一个参数：DaveArea.DB 表示读取PLC的地址区域为DB
//第二个参数：DB地址，若plc中是DB1082，则填1082
//第三个参数：数据长度
//第四个参数：偏移量
byte[] barcodeByte = s7Connector.read(DaveArea.DB, 1082, 16, 82);
Integer extract = integerConverter.extract(Integer.class, barcodeByte, 0, 0);
System.out.println(extract);

测试结果

 解析使用的工具类可使用S7jar包中自带的方法(方法还是很全面的)

需注意的是PLC中数据类型的所占长度和java有所出入!!!

第二种方式(HslCommunication) 

参考C语言读PLC而来:C# 读写西门子PLC数据，包含S7协议和Fetch/Write协议，s7支持200smart，300PLC，1200PLC，1500PLC - dathlin - 博客园

1.创建maven工程引入依赖

<dependency>
   <groupId>com.github.dathlin</groupId>
   <artifactId>HslCommunication</artifactId>
   <version>3.1.1</version>
</dependency>

2. 通过代码连接PLC

SiemensS7Net siemensTcpNet = new SiemensS7Net(SiemensPLCS.S1200, "192.168.101.90");

3.解析获取的数据 

//105代表读取的长度
OperateResultExOne<byte[]> read = siemensTcpNet.Read("DB1082.80", (short) 105);
if (read.IsSuccess) {
    byte[] content = read.Content;
    //2是下标
    short no = siemensTcpNet.getByteTransform().TransInt16(content, 2);
    System.out.println(no);
}

测试结果

总结

• 两种方式皆可读取PLC中的数据,第一种方式只能单个读取,单个解析;第二种方式可读取整个DB块(字节数组)后解析其中数据(可根据实际情况去选择)
• 两种方式皆需注意PLC要与本身电脑处于同一网段(可修改电脑网段或利用西门子博途软件修改PLC中设置的网段)  

 最后大家要是觉得有用的话,给博主点个赞!!!

 PLC数据

Eclipse+Maven+JDK8

使用的轮子是 s7connector 官网有简单的案例 官网地址https://s7connector.github.io/s7connector/

1. 创建Maven工程，

2. 需要导入的Maven依赖

3. <dependencies>
   		<dependency>
   			<groupId>junit</groupId>
   			<artifactId>junit</artifactId>
   			<version>3.8.1</version>
   			<scope>test</scope>
   		</dependency>
   		<dependency>
   			<groupId>com.github.s7connector</groupId>
   			<artifactId>s7connector</artifactId>
   			<version>2.1</version>
   		</dependency>
   		<dependency>
   			<groupId>org.slf4j</groupId>
   			<artifactId>slf4j-api</artifactId>
   			<version>1.7.25</version>
   		</dependency>
   		<dependency>
   			<groupId>org.slf4j</groupId>
   			<artifactId>slf4j-log4j12</artifactId>
   			<version>1.7.25</version>
   		</dependency>
   	</dependencies>

 获取数据代码

import java.io.IOException;
import java.math.BigDecimal;

import com.github.s7connector.api.DaveArea;
import com.github.s7connector.api.S7Connector;
import com.github.s7connector.api.factory.S7ConnectorFactory;
import com.github.s7connector.impl.serializer.converter.BitConverter;
import com.github.s7connector.impl.serializer.converter.IntegerConverter;
import com.github.s7connector.impl.serializer.converter.RealConverter;
import com.github.s7connector.impl.serializer.converter.StringConverter;


/**
 * 测试PLC通信
 * 获得PLC的数据
 */
public class PlcTest1 {
	//Int类型的封装类 用来转义
	private static IntegerConverter intCon = new IntegerConverter();
	//String...
	private static StringConverter strCon = new StringConverter();
	//Boolean...
	private static BitConverter boolCon = new BitConverter();
	//real实数浮点...
	private static RealConverter realCon = new RealConverter();
	
	public static void main(String[] args) {
		long startTime = System.currentTimeMillis(); // 获取开始时间
		
		//创建与PLC的链接
		final S7Connector connector = S7ConnectorFactory.buildTCPConnector().withHost("192.168.0.21") //
				.withRack(0) // 架机号 可选
				.withSlot(1) // 插槽号 可选
				.build();
		
		byte[] PlcData = connector.read(DaveArea.DB, // 选择数据区块
				5, // 区块编号
				2, // 数据值长度 int长度2
				2); // 开始位置 偏移量
		System.out.println("转换int="+intCon.extract(new Integer(0).getClass(), PlcData, 0, 0));
		
        
		PlcData = connector.read(DaveArea.DB, // 选择数据区块
				5, // 区块编号
				16, // 数据值长度 String最小3 随值长度增加
				4); // 开始位置偏移量
        System.out.println("转换str="+strCon.extract(new String().getClass(), PlcData, 0, 0));
        
        
        PlcData = connector.read(DaveArea.DB, // 选择数据区块
				5, // 区块编号
				1, // 数据值长度 boolean长度1
				0); // 开始位置偏移量
        System.out.println("转换bool="+boolCon.extract(new Boolean(false).getClass(), PlcData, 0, 0));
        
        PlcData = connector.read(DaveArea.DB, // 选择数据区块
				5, // 区块编号
				4, // 数据值长度 double长度4
				516); //偏移量
        Double num1 = realCon.extract(new Double(0).getClass(), PlcData, 0, 0);
        BigDecimal bd1 = new BigDecimal(num1);
        System.out.println("转换real浮点="+bd1.setScale(2, BigDecimal.ROUND_HALF_UP).toPlainString());
        
        try {
			connector.close();//关闭链接
		} catch (IOException e) {
			e.printStackTrace();
		}
        
		long endTime = System.currentTimeMillis(); // 获取结束时间
		System.out.println("程序运行时间：" + (endTime - startTime) + "ms"); // 输出程序运行时间
	}
}

运行结果

写入数据代码

package wlf.learn;

import java.math.BigDecimal;
import java.nio.ByteBuffer;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;

import com.github.s7connector.api.DaveArea;
import com.github.s7connector.api.S7Connector;
import com.github.s7connector.api.factory.S7ConnectorFactory;
import com.github.s7connector.impl.serializer.converter.BitConverter;
import com.github.s7connector.impl.serializer.converter.IntegerConverter;
import com.github.s7connector.impl.serializer.converter.RealConverter;
import com.github.s7connector.impl.serializer.converter.StringConverter;


/**
 * 测试PLC通信 获得PLC的数据
 * 多线程
 */
public class PlcTest2 {

	public static void main(String[] args) {
		long startTime = System.currentTimeMillis(); // 计算开始时间
		S7Connector connector = S7ConnectorFactory.buildTCPConnector().withHost("192.168.0.21") //
				.withRack(0) // 架机号 可选
				.withSlot(1) // 插槽号 可选
				.build();
		// 线程池
		ExecutorService pool = Executors.newFixedThreadPool(10);

		ThreadPoolExecutor executor = (ThreadPoolExecutor) pool;
		executor.setCorePoolSize(2);
		executor.setMaximumPoolSize(3);
		
		//Real读写
		executor.execute(new WriteReal(connector,(float)202109.06));
		executor.execute(new GetReal(connector));
		
		//String读写
		executor.execute(new WriteString(connector,"SShelloword"));//'SS'占位符 从第3个字符开始为写入内容
		executor.execute(new GetString(connector));
		
		
		//关闭线程池
		pool.shutdown();
		
		long endTime = System.currentTimeMillis(); // 计算结束时间
		System.out.println("程序整体运行时间:" + (endTime - startTime) + "ms"); // 输出程序运行时间

	}
}


class GetString implements Runnable {
	S7Connector connector = null;

	GetString(S7Connector connector) {
		this.connector = connector;
	}

	public void run() {
		long startTime = System.currentTimeMillis(); // 计算开始时间
		// String...
		StringConverter strCon = new StringConverter();
		byte[] PlcData = connector.read(DaveArea.DB, // 选择数据区块
				5, // 区块编号
				128, //byte数据值长度 String最小3 最大96 随值长度增加
				4); // 开始位置偏移量
		System.out.print("str=" + strCon.extract(new String().getClass(), PlcData, 0, 0).trim());
		long endTime = System.currentTimeMillis(); // 计算结束时间
		System.out.println("\t时间：" + (endTime - startTime) + "ms"); // 输出程序运行时间
	}
}

class GetReal implements Runnable {
	S7Connector connector = null;

	GetReal(S7Connector connector) {
		this.connector = connector;
	}

	public void run() {
		long startTime = System.currentTimeMillis(); // 计算开始时间
		RealConverter realCon = new RealConverter();
		byte[] PlcData = connector.read(DaveArea.DB, // 选择数据区块
				5, // 区块编号
				4, //byte数据值长度 double长度4
				260); // 偏移量
		Double num1 = realCon.extract(new Double(0).getClass(), PlcData, 0, 0);
		BigDecimal bd1 = new BigDecimal(num1);
		System.out.print("real浮点=" + bd1.setScale(2, BigDecimal.ROUND_HALF_UP).toPlainString());
		long endTime = System.currentTimeMillis(); // 计算结束时间
		System.out.println("\t时间：" + (endTime - startTime) + "ms"); // 输出程序运行时间
	}
}


/**
 * 写入Real到PLC
 * @author 1
 *
 */
class WriteReal implements Runnable {
	S7Connector connector = null;
	Float data = null;
	WriteReal(S7Connector connector,Float data) {
		this.connector = connector;
		this.data = data;
	}

	public void run() {
		long startTime = System.currentTimeMillis(); // 计算开始时间
		
		System.out.println(); // 输出程序运行时间
		byte[] bytes = ByteBuffer.allocate(4).putFloat(data).array();
		connector.write(DaveArea.DB,5,260,bytes);
		
		long endTime = System.currentTimeMillis(); // 计算结束时间
		System.out.println("写入Real成功："+data+"\t时间：" + (endTime - startTime) + "ms");
	}
}

/**
 * 写入String到PLC
 * @author 1
 *
 */
class WriteString implements Runnable {
	S7Connector connector = null;
	String data = null;
	WriteString(S7Connector connector,String data) {
		this.connector = connector;
		this.data = data;
	}

	public void run() {
		long startTime = System.currentTimeMillis(); // 计算开始时间
		
		byte[] bytes = data.getBytes();
		connector.write(DaveArea.DB,5,4,bytes);
		
		long endTime = System.currentTimeMillis(); // 计算结束时间
		System.out.println("写入Str成功："+data+"\t时间：" + (endTime - startTime) + "ms");
	}
}