xfy911
|
4105aec916
|
feat(websocket): 实现 WebSocket 空闲超时处理 + 跨平台 poll/select 抽象
- platform.h / platform.c: 新增 cocoon_socket_poll_readable() 跨平台 socket 可读等待
- POSIX: poll() + POLLIN
- Windows: select() + fd_set（readfds）
- websocket.c: ws_handle_connection() 实现 timeout_ms 空闲超时处理
- 每次循环前调用 poll_readable() 等待数据或超时
- 超时时发送 1001 Idle timeout 关闭帧，清理连接资源
- 解决遗留 TODO: /* TODO: 超时处理 */
- tests/websocket_test.py: 新增 test_timeout() 测试
- 连接后不发帧，验证服务端 2 秒后发送 1001 关闭帧
- tests/integration_test.sh: 新增 WebSocket 空闲超时集成测试
- 启动 -o 2000 短超时服务器验证超时行为
- Makefile: 补全 test_websocket 编译规则，加入 platform.c
- 修复 undefined reference 错误
- 全部 142 单元测试 + 77 集成测试通过，编译零警告
|
2026-06-06 21:16:54 +08:00 |
|
xfy911
|
035e4bebb4
|
feat(websocket): 实现 WebSocket 广播与频道路由系统
新增功能：
- ws_registry_add/remove: 连接注册/注销，自动管理活跃连接链表
- ws_broadcast(): 向所有活跃连接广播文本消息
- ws_broadcast_to_path(): 按握手路径（频道）定向广播
- ws_connection_count(): 获取当前 WebSocket 连接数
- ws_handle_connection() 新增 path 参数，用于频道标识
实现细节：
- 全局链表 + pthread_mutex 保证多线程安全
- 原子计数器统计连接数
- 连接建立时自动注册，关闭/异常时自动注销
- 默认行为保持 echo 不变
编译零警告，61 项集成测试 + 127 个单元测试全部通过。
|
2026-06-05 18:12:46 +08:00 |
|
xfy911
|
2775033198
|
feat(websocket): 实现 RFC 6455 WebSocket 支持
- 新增 websocket.h / websocket.c：帧解析、编码、握手、连接管理
- server.c: 检测 Upgrade: websocket 请求，执行握手后进入 ws_handle_connection
- 支持文本/二进制帧 echo、ping/pong、close 帧
- 使用 OpenSSL SHA1 计算 Sec-WebSocket-Accept
- 集成测试：新增 2 项 WebSocket 测试（Python 标准库实现）
- 61 项集成测试全部通过，127 项单元测试全部通过
|
2026-06-05 15:18:01 +08:00 |
|