CanadaMes.git - Gitblit

New file
			@@ -0,0 +1,81 @@
			package com.example.springboot.component;

			import cn.hutool.json.JSONArray;
			import cn.hutool.json.JSONObject;

			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 final MessageSender messageSender;
			//
			// public PlcParameter(MessageSender messageSender) {
			// this.messageSender = messageSender;
			// }

			@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();
			}


			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();
			}

			try {
			// 从队列接收并解析 JSON 消息为 JSONObject 对象
			JSONObject receivedJsonObject = RabbitMQUtils.receiveJsonMessage(JSONObject.class, "json_queue");
			System.out.println(receivedJsonObject.toString());
			} catch (Exception e) {
			e.printStackTrace();
			}
			}
			}


			}