后端修改

src/main/java/com/example/backend/dds/TestPublisher.java

@@ -14,7 +14,7 @@ import org.springframework.stereotype.Component;
 import javax.annotation.PreDestroy;
 import java.util.concurrent.*;
 
-@Component
+
 public class TestPublisher {
 
     private static final int N_MSGS = 20;
@@ -52,7 +52,7 @@ public class TestPublisher {
         s[2] = "-DCPSDefaultDiscovery";  // 指定发现机制为InfoRepo
         s[3] = "DEFAULT_REPO";           // 使用集中式InfoRepo
         s[4] = "-DCPSInfoRepo";          // InfoRepo的corbaloc地址
-        s[5] = "corbaloc:iiop:10.195.84.22:12345/DCPSInfoRepo"; // 替换为实际IP和端口
+        s[5] = "corbaloc:iiop:192.168.43.155:12345/DCPSInfoRepo"; // 替换为实际IP和端口
         executor.submit(() -> initialize(s)); // 初始化放在后台线程
     }
     public static boolean checkReliable(String[] args) {

src/main/java/com/example/backend/dds/TestSubscriber.java

@@ -16,7 +16,7 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.atomic.AtomicReference;
 
-@Component
+
 public class TestSubscriber {
     private DomainParticipantFactory dpf;
     private DomainParticipant dp;
@@ -55,7 +55,7 @@ public class TestSubscriber {
         s[2] = "-DCPSDefaultDiscovery";  // 指定发现机制为InfoRepo
         s[3] = "DEFAULT_REPO";           // 使用集中式InfoRepo
         s[4] = "-DCPSInfoRepo";          // InfoRepo的corbaloc地址
-        s[5] = "corbaloc:iiop:10.195.84.22:12345/DCPSInfoRepo"; // 替换为实际IP和端口
+        s[5] = "corbaloc:iiop:192.168.43.155:12345/DCPSInfoRepo"; // 替换为实际IP和端口
         executor.submit(() -> initialize(s));
     }
     public String getText(){