From cb78ad5f3aa9436cf32ae74f07dd1a5d18b8f046 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Thu, 08 Jan 2026 13:44:41 +0800
Subject: [PATCH] refactor(ai): 调整公司ID查询逻辑和端口配置
---
src/main/java/cc/mrbird/febs/common/websocket/NettyWebSocketConfig.java | 66 ++++++++++++++++----------------
1 files changed, 33 insertions(+), 33 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/common/websocket/NettyWebSocketConfig.java b/src/main/java/cc/mrbird/febs/common/websocket/NettyWebSocketConfig.java
index 4e9ef6c..da21b70 100644
--- a/src/main/java/cc/mrbird/febs/common/websocket/NettyWebSocketConfig.java
+++ b/src/main/java/cc/mrbird/febs/common/websocket/NettyWebSocketConfig.java
@@ -18,37 +18,37 @@
@Configuration
public class NettyWebSocketConfig {
- @Value("${netty.websocket.port:8090}")
- private int port;
-
- @Bean(name = "bossGroup", destroyMethod = "shutdownGracefully")
- public EventLoopGroup bossGroup() {
- return new NioEventLoopGroup(1);
- }
-
- @Bean(name = "workerGroup", destroyMethod = "shutdownGracefully")
- public EventLoopGroup workerGroup() {
- return new NioEventLoopGroup();
- }
-
- @Bean
- public ServerBootstrap serverBootstrap(EventLoopGroup bossGroup, EventLoopGroup workerGroup) {
- ServerBootstrap bootstrap = new ServerBootstrap();
- bootstrap.group(bossGroup, workerGroup)
- .channel(NioServerSocketChannel.class)
- .option(ChannelOption.SO_BACKLOG, 128)
- .childOption(ChannelOption.SO_KEEPALIVE, true)
- .handler(new LoggingHandler(LogLevel.INFO))
- .childHandler(new io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>() {
- @Override
- protected void initChannel(io.netty.channel.socket.SocketChannel ch) throws Exception {
- ch.pipeline().addLast(new HttpServerCodec());
- ch.pipeline().addLast(new ChunkedWriteHandler());
- ch.pipeline().addLast(new HttpObjectAggregator(65536));
- ch.pipeline().addLast(new WebSocketServerProtocolHandler("/ws"));
- ch.pipeline().addLast(new cc.mrbird.febs.common.websocket.WebSocketServerHandler());
- }
- });
- return bootstrap;
- }
+// @Value("${netty.websocket.port:9109}")
+// private int port;
+//
+// @Bean(name = "bossGroup", destroyMethod = "shutdownGracefully")
+// public EventLoopGroup bossGroup() {
+// return new NioEventLoopGroup(1);
+// }
+//
+// @Bean(name = "workerGroup", destroyMethod = "shutdownGracefully")
+// public EventLoopGroup workerGroup() {
+// return new NioEventLoopGroup();
+// }
+//
+// @Bean
+// public ServerBootstrap serverBootstrap(EventLoopGroup bossGroup, EventLoopGroup workerGroup) {
+// ServerBootstrap bootstrap = new ServerBootstrap();
+// bootstrap.group(bossGroup, workerGroup)
+// .channel(NioServerSocketChannel.class)
+// .option(ChannelOption.SO_BACKLOG, 128)
+// .childOption(ChannelOption.SO_KEEPALIVE, true)
+// .handler(new LoggingHandler(LogLevel.INFO))
+// .childHandler(new io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>() {
+// @Override
+// protected void initChannel(io.netty.channel.socket.SocketChannel ch) throws Exception {
+// ch.pipeline().addLast(new HttpServerCodec());
+// ch.pipeline().addLast(new ChunkedWriteHandler());
+// ch.pipeline().addLast(new HttpObjectAggregator(65536));
+// ch.pipeline().addLast(new WebSocketServerProtocolHandler("/ws"));
+// ch.pipeline().addLast(new cc.mrbird.febs.common.websocket.WebSocketServerHandler());
+// }
+// });
+// return bootstrap;
+// }
}
\ No newline at end of file
--
Gitblit v1.9.1