refactor(ai): 调整公司ID查询逻辑和端口配置

Administrator

4 days ago cb78ad5f3aa9436cf32ae74f07dd1a5d18b8f046

 src/main/java/cc/mrbird/febs/common/websocket/WebSocketServer.java

@@ -13,33 +13,33 @@
@Component
public class WebSocketServer {

    @Value("${netty.websocket.port:8090}")
    private int port;

    @Autowired
    private ServerBootstrap serverBootstrap;

    @Autowired
    private EventLoopGroup bossGroup;

    @Autowired
    private EventLoopGroup workerGroup;

    private ChannelFuture channelFuture;

    @PostConstruct
    public void start() throws InterruptedException {
        channelFuture = serverBootstrap.bind(port).sync();
        System.out.println("Netty WebSocket服务器启动在端口:" + port);
    }

    @PreDestroy
    public void stop() {
        if (channelFuture != null) {
            channelFuture.channel().close();
        }
        bossGroup.shutdownGracefully();
        workerGroup.shutdownGracefully();
        System.out.println("Netty WebSocket服务器已停止");
    }
//    @Value("${netty.websocket.port:9102}")
//    private int port;
//
//    @Autowired
//    private ServerBootstrap serverBootstrap;
//
//    @Autowired
//    private EventLoopGroup bossGroup;
//
//    @Autowired
//    private EventLoopGroup workerGroup;
//
//    private ChannelFuture channelFuture;
//
//    @PostConstruct
//    public void start() throws InterruptedException {
//        channelFuture = serverBootstrap.bind(port).sync();
//        System.out.println("Netty WebSocket服务器启动在端口:" + port);
//    }
//
//    @PreDestroy
//    public void stop() {
//        if (channelFuture != null) {
//            channelFuture.channel().close();
//        }
//        bossGroup.shutdownGracefully();
//        workerGroup.shutdownGracefully();
//        System.out.println("Netty WebSocket服务器已停止");
//    }
}