Hi sir, thanks for reply Here we doing something Small Scale Industry Automation *Industry 4.0 *, I don't have PLC instead of PLC i am using *ESP32 *, through ESP32 I dumped the Ladder Logic code (Example: Simple Machine Control ON and OFF) using mqtt protocol and the code is went to mosquitto broker protocol and i am getting real time data in mosquito.Now i want to send that data from *Mosquito to plc4x *so here i am using Eclipse ide using *java*. So i wrote the code in java please verify my code. What I did is correct or not?
And also say how to see the data is received by Apache PLC4X once that Data Recive to plc4x then we try to send that data to Apache kafka. ALSO PLEASE SAY OUR FLOW OF WORK IS RIGHT OR ANYTHING WE MISSED!!!! OPENPLC we used to create Ladder logic to control machine *ESP32 Micro Controller link: **https://robu.in/product/esp32-38pin-development-board-wifibluetooth-ultra-low-power-consumption-dual-core/?gclid=CjwKCAjwl6OiBhA2EiwAuUwWZRoLZz42dfc99s8lv14KC7knmhQNMkHK5M0DVkIPU43c3lrNvYoJexoCjXcQAvD_BwE <https://robu.in/product/esp32-38pin-development-board-wifibluetooth-ultra-low-power-consumption-dual-core/?gclid=CjwKCAjwl6OiBhA2EiwAuUwWZRoLZz42dfc99s8lv14KC7knmhQNMkHK5M0DVkIPU43c3lrNvYoJexoCjXcQAvD_BwE>* package mqtt1; import java.util.function.Consumer; import java.util.function.Function; import org.apache.plc4x.java.mqtt.MqttPlcConnection; import org.apache.plc4x.java.mqtt.Connection; import org.apache.plc4x.java.api.PlcReader; import org.apache.plc4x.java.api.PlcConnection; import org.apache.plc4x.java.api.PlcDriverManager; import org.apache.plc4x.java.api.exceptions.PlcConnectionException; import org.apache.plc4x.java.api.exceptions.PlcRuntimeException; import org.apache.plc4x.java.api.types.PlcResponseCode; import org.apache.plc4x.java.api.values.PlcWriteRequest; import org.eclipse.paho.client.mqttv3.IMqttClient; import org.eclipse.paho.client.mqttv3.IMqttMessageListener; import org.eclipse.paho.client.mqttv3.MqttClient; import org.eclipse.paho.client.mqttv3.MqttConnectOptions; import org.eclipse.paho.client.mqttv3.MqttException; import org.eclipse.paho.client.mqttv3.MqttMessage; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class drill1 { private static final Logger LOGGER = LoggerFactory.getLogger(drill1 .class); public static void main(String[] args) throws MqttException { String brokerUrl = "tcp://192.168.0.199:1883"; String clientId = "abcdef"; String topic = "plc/testcode/"; String esp32IpAddress = "192.168.1.100"; // replace with actual IP address of your ESP32 // Create the MQTT client. IMqttClient mqttClient = new MqttClient(brokerUrl, clientId); // Configure the connection options. MqttConnectOptions connOpts = new MqttConnectOptions(); connOpts.setCleanSession(true); // Connect to the MQTT broker. mqttClient.connect(connOpts); // Create the PLC4X connection. try (PlcConnection plcConnection = new PlcDriverManager().getConnection("modbus:tcp://" + esp32IpAddress + ":502")) { // Subscribe to the MQTT topic. mqttClient.subscribe(topic, new IMqttMessageListener() { @Override public void messageArrived(String topic, MqttMessage message) throws Exception { LOGGER.info("Received message: {}", new String(message.getPayload())); // Convert the message to a PLC4X write request. PlcWriteRequest writeRequest = plcConnection.writeRequestBuilder() .addItem("my-item", "%DB1:DINT") .addValue("my-item", Integer.parseInt(new String(message.getPayload()))) .build(); // Write the value to the PLC. PlcResponseCode responseCode = writeRequest.execute().get(); if (responseCode != PlcResponseCode.OK) { LOGGER.warn("Failed to write value to PLC. Response code: {}", responseCode); } else { LOGGER.info("Wrote value to PLC."); } } }); } catch (PlcConnectionException e) { throw new PlcRuntimeException("Error connecting to ESP32 PLC", e); } } } <project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi=" http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation=" http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd";> <modelVersion>4.0.0</modelVersion> <groupId>com.calterio3</groupId> <artifactId>mqtt</artifactId> <version>0.0.1-SNAPSHOT</version> <dependencies> <dependency> <groupId>org.eclipse.paho</groupId> <artifactId>org.eclipse.paho.client.mqttv3</artifactId> <version>1.2.5</version> </dependency> <dependency> <groupId>org.apache.plc4x</groupId> <artifactId>plc4j-api</artifactId> <version>0.10.0</version> </dependency> </dependencies> <repositories> <repository> <id>apache.snapshots</id> <url>https://repository.apache.org/content/repositories/snapshots/ </url> </repository> </repositories> <build> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>3.8.1</version> <configuration> <source>11</source> <target>11</target> </configuration> </plugin> </plugins> </build> </project>
