From 09fe50d59e2f1e2261d376eb49ad6c40301f25b4 Mon Sep 17 00:00:00 2001 From: ZengTao <2773468879@qq.com> Date: 星期五, 10 五月 2024 16:08:59 +0800 Subject: [PATCH] 修改IP与数据库连接 --- springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java | 138 +++++++++++++++++++++------------------------- 1 files changed, 63 insertions(+), 75 deletions(-) diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java b/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java index dd51397..54f3223 100644 --- a/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java +++ b/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java @@ -1,93 +1,81 @@ package com.example.springboot.component; +import cn.hutool.json.JSONArray; import cn.hutool.json.JSONObject; -import org.apache.shiro.authz.annotation.RequiresPermissions; import java.util.ArrayList; import java.util.List; +import java.util.Arrays; +import java.io.BufferedReader; +import java.io.File; +import java.io.FileInputStream; +import java.io.FileNotFoundException; +import java.io.IOException; +import java.io.InputStreamReader; +import java.io.UnsupportedEncodingException; + +import org.apache.commons.io.FileUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.ApplicationContext; +import org.springframework.context.annotation.AnnotationConfigApplicationContext; +import org.springframework.stereotype.Component; + +@Component public class PlcParameter extends Thread { - private static final int SEND_INTERVAL = 1000; - private static final int WRITE_INTERVAL = 100; - private short[] params = new short[]{1111, 121, 3232, 0, 1, 0, 1, 0, 1, 0, 1, 0}; - List<Short> paramList = S7control.getinstance().ReadWord("DB100.DBW", 12); +// private final MessageSender messageSender; +// +// public PlcParameter(MessageSender messageSender) { +// this.messageSender = messageSender; +// } -// 灏嗗垪琛ㄤ腑鐨勫�煎鍒跺埌 params 鏁扮粍涓� + @Override + public void run() { + while (this != null) { + try { +// try { +// RabbitMQUtils.sendMessage("Hello, world!", "module_queue"); +// } catch (Exception e) { +// e.printStackTrace(); +// } +// try { +// RabbitMQUtils.receiveMessage("module_queue"); +// } catch (Exception e) { +// e.printStackTrace(); +// } +// String message = "Hello, RabbitMQ!"; +// messageSender.sendMessage(message); + Thread.sleep(500); + + } catch (InterruptedException e) { + e.printStackTrace(); + } - @Override - public void run() { - try { - // 鍙戦�佷竴娆℃秷鎭� -// sendMessages(); + JSONObject jsonObject = new JSONObject(); + jsonObject.put("key1", "value1"); + jsonObject.put("key2", 123); + JSONArray jsonArray = new JSONArray(); + jsonArray.add("item1"); + jsonArray.add("item2"); + jsonObject.put("key3", jsonArray); - // 寤惰繜涓�娈垫椂闂� + try { + // 灏� JSON 瀵硅薄杞崲涓哄瓧绗︿覆骞跺彂閫佸埌闃熷垪//RabbitMQUtils.sendJsonMessage(jsonObject, "json_queue"); + } catch (Exception e) { + e.printStackTrace(); + } - - while (true) { - // 鍐欏叆PLC - writeToPlc(); - Thread.sleep(WRITE_INTERVAL); - - // 鍙戦�佹秷鎭� - sendMessages(); - Thread.sleep(SEND_INTERVAL); - } - - } catch (InterruptedException e) { - e.printStackTrace(); - } + try { + // 浠庨槦鍒楁帴鏀跺苟瑙f瀽 JSON 娑堟伅涓� JSONObject 瀵硅薄 + JSONObject receivedJsonObject = RabbitMQUtils.receiveJsonMessage(JSONObject.class, "json_queue"); + System.out.println(receivedJsonObject.toString()); + } catch (Exception e) { + e.printStackTrace(); + } } + } - private void sendMessages() { - WebSocketServer sendwServer = WebSocketServer.sessionMap.get("Parameter"); - if (sendwServer != null) { - JSONObject jsonObject = new JSONObject(); - jsonObject.append("params", params); - sendwServer.sendMessage(jsonObject.toString()); - } - } - private void writeToPlc() { - WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("Parameter"); - if (webSocketServer != null) { - List<String> messages = webSocketServer.getMessages(); - - String addressList = "DB100.DBW0"; - - if (!messages.isEmpty()) { - // 灏嗘渶鍚庝竴涓秷鎭浆鎹负 short 绫诲瀷鐨勫垪琛� - String lastMessage = messages.get(messages.size() - 1); - System.out.println("messages锛�" + messages); - String[] parts = lastMessage.split(","); - List<Short> messageValues = new ArrayList<>(); - for (String part : parts) { - try { - // 浣跨敤姝e垯琛ㄨ揪寮忔竻闄ら潪鏁板瓧瀛楃 - String cleanedPart = part.replaceAll("[^0-9-]", ""); - short value = Short.parseShort(cleanedPart.trim()); - messageValues.add(value); - } catch (NumberFormatException e) { - // 濡傛灉鏃犳硶瑙f瀽涓� short 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒� - e.printStackTrace(); - } - } - - // 鏇挎崲鍒濆鍙橀噺鐨勫�� - for (int i = 0; i < messageValues.size(); i++) { - if (i < params.length) { - params[i] = messageValues.get(i); - } - } - - // 灏嗘秷鎭�煎啓鍏� PLC - S7control.getinstance().WriteWord(addressList, messageValues); - System.out.println("messageValues锛�" + messageValues); - System.out.println("addressList锛�" + addressList); - // 娓呯┖娑堟伅鍒楄〃 - webSocketServer.clearMessages(); - } - } - } } -- Gitblit v1.8.0