連接緩存?Connection Cache
引入maven依賴
<dependency>
? ? ? <groupId>org.apache.plc4x</groupId>
? ? ? <artifactId>plc4j-connection-cache</artifactId>
? ? ? <version>0.12.0</version>
? ? </dependency>
配置
PlcConnectionManager connectionManager = CachedPlcConnectionManager.getBuilder()
? ? ? ? ? ? .withMaxLeaseTime(Duration.ofSeconds(10))
? ? ? ? ? ? .withMaxWaitTime(Duration.ofMinutes(1))
? ? ? ? ? ? .build();
例子：
public static void main(String[] args) throws Exception {
? ? ? ? PlcConnectionManager connectionManager = CachedPlcConnectionManager.getBuilder().build();
? ? ? ? for (int i = 0; i < 10000; i++) {
? ? ? ? ? ? try(PlcConnection connection = connectionManager.getConnection("s7://192.168.1.192")) {
? ? ? ? ? ? ? ? if (connection.isConnected()){
? ? ? ? ? ? ? ? ? ? PlcReadRequest.Builder builder = connection.readRequestBuilder();
? ? ? ? ? ? ? ? ? ? builder.addTagAddress("PollingValue", "%DB1:4.0:BOOL");
? ? ? ? ? ? ? ? ? ? PlcReadRequest readRequest = builder.build();
? ? ? ? ? ? ? ? ? ? PlcReadResponse syncResponse = readRequest.execute().get(2000, TimeUnit.MILLISECONDS);
? ? ? ? ? ? ? ? ? ? printResponse(syncResponse);
? ? ? ? ? ? ? ? } else {
? ? ? ? ? ? ? ? ? ? logger.info("PLC is not connected, let's try again to connect");
? ? ? ? ? ? ? ? ? ? connection.connect();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? } catch (PlcConnectionException e){
? ? ? ? ? ? ? ? logger.error("Connection exception in trying to connect", e);
? ? ? ? ? ? } catch (CancellationException e){
? ? ? ? ? ? ? ? logger.error("Polling Thread canceled", e);
? ? ? ? ? ? } catch (IllegalStateException e){
? ? ? ? ? ? ? ? logger.error("Error in Netty state machine", e);
? ? ? ? ? ? } catch (ExecutionException e){
? ? ? ? ? ? ? ? logger.error("Interrupted Exception fired", e);
? ? ? ? ? ? } catch (TimeoutException e) {
? ? ? ? ? ? ? ? logger.error("Timeout exception fired", e);
? ? ? ? ? ? }
? ? ? ? ? ? TimeUnit.MILLISECONDS.sleep(100);
? ? ? ? }
? ? ? ? System.exit(0);
? ? }
