api-service/pom.xml

@@ -30,15 +30,6 @@
             <groupId>org.springframework.amqp</groupId>
             <artifactId>spring-amqp</artifactId>
         </dependency>
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-data-jpa</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>mysql</groupId>
-            <artifactId>mysql-connector-java</artifactId>
-            <version>8.0.29</version>
-        </dependency>
         <dependency>
             <groupId>org.springframework.amqp</groupId>
             <artifactId>spring-rabbit</artifactId>

api-service/src/main/java/cn/edu/zjvtit/cloudstorage/apiservice/rabbitmq/topic/Receiver.java

@@ -12,6 +12,7 @@ import javax.annotation.Resource;
 @Component
 @RabbitListener(queues = "apiServers")
 public class Receiver {
+    //心跳接收端关键代码
     @Autowired
     private DataServerStore dataServerStore;
     @RabbitHandler

api-service/src/main/java/cn/edu/zjvtit/cloudstorage/apiservice/store/DataServerStore.java

@@ -13,12 +13,14 @@ public class DataServerStore {
 
     public synchronized void receivedHeart(String addr) {
         this.serverHeart.put(addr, System.currentTimeMillis() / 1000);
+        // 保存服务端心跳
     }
     public Map<String,Long> getServerHeart(){
         return this.serverHeart;
     }
     Set<String> getServerList() {
         return this.serverHeart.keySet();
+        // 获取服务器列表
     }
 
     public String selectRandomServer() {
@@ -28,5 +30,6 @@ public class DataServerStore {
         }
         int index = (int) (Math.random() * serverList.size());
         return serverList.toArray()[index].toString();
+        //随机选择一个服务器
     }
 }

api-service/src/main/resources/application.properties

@@ -0,0 +1,7 @@
+spring.servlet.multipart.enabled=true
+spring.servlet.multipart.max-file-size=100MB
+spring.servlet.multipart.max-request-size=100MB
+spring.rabbitmq.host=172.20.80.100
+spring.rabbitmq.port=5672
+spring.rabbitmq.username=test
+spring.rabbitmq.password=test

data-service/src/main/java/cn/edu/zjvtit/cloudstorage/dataservice/rabbitmq/topic/Sender.java

@@ -9,6 +9,7 @@ import java.net.InetAddress;
 
 @Component
 public class Sender {
+    // 心跳发送端关键代码
     @Autowired
     private RabbitTemplate rabbitTemplate;
     @Autowired

distributed-object-storage/api-service/src/main/resources/application.properties

@@ -1,14 +0,0 @@
-spring.servlet.multipart.enabled=true
-spring.servlet.multipart.max-file-size=100MB
-spring.servlet.multipart.max-request-size=100MB
-spring.rabbitmq.host=172.20.80.100
-spring.rabbitmq.port=5672
-spring.rabbitmq.username=test
-spring.rabbitmq.password=test
-spring.datasource.url=jdbc:mysql://172.20.80.100:3306/object?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai
-spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
-spring.datasource.username=root
-spring.datasource.password=123456
-spring.jpa.database=MySQL
-spring.jpa.show-sql=true
-spring.jpa.hibernate.ddl-auto=update