基于 Netty-SocketIO 实现实时告警推送：告别轮询，迎接事件驱动

CSDN北京话事人:默语

36001人浏览 · 2025-08-08 08:45:00

CSDN北京话事人:默语 · 2025-08-08 08:45:00 发布

⚡基于 Netty-SocketIO 实现实时告警推送：告别轮询，迎接事件驱动

✍️ 作者：默语｜微信：Solitudemind
📬 公众号：默语摸鱼

在这里插入图片描述

📌 摘要

在构建企业级系统（如：电力监控、安防平台、IoT 平台）中，实时告警通知 是一个高频需求。传统的轮询机制不仅性能低下，还难以实现毫秒级响应。

在本文中，我们将通过 Netty-SocketIO 实现 服务器向前端实时推送告警消息，告别前端频繁轮询，真正做到事件驱动、实时响应。

🔍 什么是 Netty-SocketIO？

Netty-SocketIO 是对 Socket.IO 协议的 Java 服务端实现，底层基于 Netty 网络框架，支持客户端与服务端之间的长连接通信。

它具备如下优势：

支持 WebSocket、XHR 多种传输方式；
基于事件模型（Event-Driven）；
支持房间、命名空间、客户端识别等高级特性；
与 Spring Boot 配合使用简单高效。

🧱 项目使用场景

在 BjcyGdxxCfsqServiceImpl 中，我们需要将告警信息对象 AlarmIndidentVo 推送给所有已连接的前端客户端。

🖼️ 实时效果预期：

客户端无需轮询；
服务端主动推送；
前端监听指定事件名，即可接收消息。

⚙️ 项目结构简图

src/
└── service/
    └── BjcyGdxxCfsqServiceImpl.java
└── config/
    └── NettySocketIOConfig.java

📦 核心代码实战：服务端主动推送告警

✅ Step 1：注入 SocketIOServer 实例

@Autowired
private SocketIOServer server; // 注入 Netty-SocketIO 服务实例

说明：该实例在 Spring 项目中由配置类统一创建（见下文配置）

✅ Step 2：遍历已连接客户端，逐个推送事件

public void socketPush(List<AlarmIndidentVo> alarmIndidentVos) {
    for (String clientId : socketClientMap.keySet()) {
        SocketIOClient client = server.getClient(UUID.fromString(clientId));
        if (client != null) {
            // 事件名：onVarsChangedPowerCut，数据为告警VO的JSON字符串
            client.sendEvent("onVarsChangedPowerCut", JSON.toJSONString(alarmIndidentVos));
        }
    }
}

🔍 参数说明：

参数	说明
`socketClientMap`	存储所有已连接客户端的 `clientId` 映射
`SocketIOServer#getClient(UUID)`	获取具体客户端连接
`client.sendEvent(eventName, data)`	向客户端推送指定事件及数据

🧠 进阶：Netty-SocketIO 的配置方式

为了在 Spring 中使用 Netty-SocketIO，需要配置一个 SocketIOServer Bean。

✅ Netty 配置类（`NettySocketIOConfig.java`）

@Configuration
public class NettySocketIOConfig {

    @Value("${socketio.host:localhost}")
    private String host;

    @Value("${socketio.port:9092}")
    private Integer port;

    @Bean
    public SocketIOServer socketIOServer() {
        Configuration config = new Configuration();
        config.setHostname(host);
        config.setPort(port);
        config.setOrigin("*"); // 允许跨域访问
        return new SocketIOServer(config);
    }
}

🌐 客户端监听逻辑（前端示例）

const socket = io("http://localhost:9092");

socket.on("connect", () => {
  console.log("Connected to server");
});

// 监听服务端推送的事件
socket.on("onVarsChangedPowerCut", function (data) {
  const alarmList = JSON.parse(data);
  console.log("实时告警：", alarmList);
});

🔒 常见问题与最佳实践

问题	建议
如何管理连接用户？	在连接事件中维护 `socketClientMap`（UUID 与用户绑定）
客户端断线如何处理？	监听 `disconnect` 事件清除 map
支持分组推送吗？	支持房间（Rooms）机制，可实现“房间维度推送”
如何保护接口安全？	加入 Token 校验机制，通过 handshake 验证身份