59 lines
1.8 KiB
Java
59 lines
1.8 KiB
Java
|
package com.github.paicoding.forum.web.front.test;
|
|||
|
|
|
|||
|
|
import lombok.extern.slf4j.Slf4j;
|
|||
|
|
import org.springframework.stereotype.Component;
|
|||
|
|
|
|||
|
|
import javax.annotation.PostConstruct;
|
|||
|
|
import javax.annotation.PreDestroy;
|
|||
|
|
import java.net.DatagramSocket;
|
|||
|
|
import java.net.DatagramPacket;
|
|||
|
|
import java.util.concurrent.ExecutorService;
|
|||
|
|
import java.util.concurrent.Executors;
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* UDP 服务器
|
|||
|
|
* 本类使用单线程的线程池实现一个简单的UDP服务器，用于接收客户端发送的心跳信息。
|
|||
|
|
* 实现方法多种多样，需要根据具体的业务场景进行选择。
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
@Slf4j
|
|||
|
|
@Component
|
|||
|
|
public class UdpServer {
|
|||
|
|
|
|||
|
|
|
|||
|
|
private static final int PORT = 10002;
|
|||
|
|
private volatile boolean isRunning = true; // 标志变量
|
|||
|
|
private final ExecutorService executor = Executors.newSingleThreadExecutor();
|
|||
|
|
|
|||
|
|
@PostConstruct
|
|||
|
|
public void startServer() {
|
|||
|
|
executor.submit(this::listenUdpPackets);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@PreDestroy
|
|||
|
|
public void stopServer() {
|
|||
|
|
isRunning = false;
|
|||
|
|
executor.shutdown();
|
|||
|
|
log.info("UDP服务器已停止");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
private void listenUdpPackets() {
|
|||
|
|
try (DatagramSocket socket = new DatagramSocket(PORT)) {
|
|||
|
|
log.info("UDP Server started on port {}", PORT);
|
|||
|
|
byte[] buffer = new byte[102400];
|
|||
|
|
DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
|
|||
|
|
while (isRunning) {
|
|||
|
|
socket.receive(packet);
|
|||
|
|
String message = new String(packet.getData(), 0, packet.getLength()).trim();
|
|||
|
|
log.info("❤️ Heartbeat from: {} ", packet.getAddress());
|
|||
|
|
log.info("📦 Data received: {}", message);
|
|||
|
|
}
|
|||
|
|
} catch (Exception e) {
|
|||
|
|
log.error("UDP Server error: {}", e.getMessage(), e);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|