src/main/java/com/fzzy/gateway/GatewayRunner.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/fzzy/protocol/ProtocolRunner.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/fzzy/protocol/weightyh/YhScaleServerEngine.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/fzzy/gateway/GatewayRunner.java
@@ -26,6 +26,8 @@ @Autowired private GatewayTimerScheduled scheduled; @Override public void run(String... args) throws Exception { mqttPublishService.init(); src/main/java/com/fzzy/protocol/ProtocolRunner.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,22 @@ package com.fzzy.protocol; import com.fzzy.protocol.weightyh.YhScaleServerEngine; import lombok.extern.slf4j.Slf4j; import org.springframework.boot.CommandLineRunner; import org.springframework.core.annotation.Order; import org.springframework.stereotype.Service; /** * é ç½®éç³»ç»å¯å¨é»è®¤é ç½® */ @Service @Slf4j @Order(value = 3) public class ProtocolRunner implements CommandLineRunner { @Override public void run(String... args) throws Exception { YhScaleServerEngine.start(); } } src/main/java/com/fzzy/protocol/weightyh/YhScaleServerEngine.java
@@ -35,7 +35,7 @@ log.info("* ========================"); log.info("* "); log.info("* å°ç£ -èååçæå¡å¯å¨ï¼ç«¯å£å·={}", YhScaleServerEngine.port); log.info("* WEIGHT-SERVER-STARTï¼PORT={}", YhScaleServerEngine.port); log.info("* "); log.info("* ========================"); }