File tree Expand file tree Collapse file tree 3 files changed +25
-7
lines changed
external/external-netty/src/main/java/com/iohao/game/external/core/netty/handler/check
widget/light-profile/src/main/java/com/iohao/game/widget/light/profile Expand file tree Collapse file tree 3 files changed +25
-7
lines changed Original file line number Diff line number Diff line change @@ -86,4 +86,5 @@ docs.tar
8686hs_err_pid *
8787/target /
8888
89- doc_game.txt
89+ doc_game.txt
90+ .claude
Original file line number Diff line number Diff line change 2222import io .netty .channel .ChannelHandlerContext ;
2323import io .netty .channel .SimpleChannelInboundHandler ;
2424import io .netty .handler .codec .http .*;
25+ import io .netty .util .ReferenceCountUtil ;
2526
2627/**
2728 * @author 渔民小镇
@@ -33,11 +34,16 @@ public final class HttpFallbackHandler extends SimpleChannelInboundHandler<FullH
3334
3435 @ Override
3536 protected void channelRead0 (ChannelHandlerContext ctx , FullHttpRequest req ) {
36- // 检查是否是 WebSocket 升级请求
37- if ("websocket" .equalsIgnoreCase (req .headers ().get (HttpHeaderNames .UPGRADE ))) {
38- ctx .fireChannelRead (req .retain ());
39- } else {
40- ctx .close ();
37+ try {
38+ // 检查是否是 WebSocket 升级请求
39+ if ("websocket" .equalsIgnoreCase (req .headers ().get (HttpHeaderNames .UPGRADE ))) {
40+ ctx .fireChannelRead (req .retain ());
41+ } else {
42+ ctx .close ();
43+ }
44+ } finally {
45+ // 释放当前 handler 的引用
46+ ReferenceCountUtil .release (req );
4147 }
4248 }
4349
Original file line number Diff line number Diff line change 2020
2121import lombok .experimental .UtilityClass ;
2222import lombok .extern .slf4j .Slf4j ;
23+ import org .apache .commons .lang .StringUtils ;
2324
2425import java .net .URL ;
2526import java .util .*;
3536@ Slf4j
3637@ UtilityClass
3738public final class ProfileManager {
38- /** 主配置key */
39+ /**
40+ * 主配置key
41+ */
3942 final String MAIN_CONFIG = "main_config" ;
4043 /**
4144 * <pre>
@@ -100,6 +103,14 @@ public void loadMainProfile(String profileConfigName) {
100103 Profile profile = profile ();
101104 profile .load (urlList );
102105
106+ // 检查环境变量是否同名的参数 如果有则覆盖
107+ profile .map .forEach ((key , value ) -> {
108+ String envValue = System .getenv (key );
109+ if (StringUtils .isNotEmpty (envValue )) {
110+ profile .map .put (key , envValue );
111+ }
112+ });
113+
103114 log .debug ("配置内容 - size:{} - {}" , ProfileManager .profile ().map .size (), ProfileManager .profile ());
104115
105116 }
You can’t perform that action at this time.
0 commit comments