|
|
@@ -15,7 +15,6 @@ import org.apache.commons.lang3.StringUtils; |
|
|
|
import org.slf4j.Logger; |
|
|
|
import org.slf4j.LoggerFactory; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.beans.factory.annotation.Value; |
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
@@ -27,8 +26,8 @@ public class TcpServer { |
|
|
|
|
|
|
|
private final Logger log = LoggerFactory.getLogger(this.getClass()); |
|
|
|
|
|
|
|
@Value("${tcp.server.port}") // Configure port in application.properties |
|
|
|
private int port; |
|
|
|
@Autowired |
|
|
|
private int tcpServerPort; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
HKPeopleNumberFactory peopleNumberFactory; |
|
|
@@ -36,8 +35,8 @@ public class TcpServer { |
|
|
|
@PostConstruct |
|
|
|
public void start() { |
|
|
|
new Thread(() -> { |
|
|
|
try (ServerSocket serverSocket = new ServerSocket(port)) { |
|
|
|
log.info("TCP Server started on port {}", port); |
|
|
|
try (ServerSocket serverSocket = new ServerSocket(tcpServerPort)) { |
|
|
|
log.info("TCP Server started on port {}", tcpServerPort); |
|
|
|
|
|
|
|
while (true) { |
|
|
|
Socket clientSocket = serverSocket.accept(); |
|
|
|