fix stun server

test quic
lager to logger
2026-02-11 17:00:15 +08:00 · 2026-02-11 15:51:35 +08:00 · 2026-02-11 15:44:53 +08:00 · 2026-02-11 15:42:44 +08:00 · 2026-02-11 15:38:43 +08:00 · 2026-02-11 15:23:22 +08:00
31 changed files with 547 additions and 228 deletions
--- a/apps/sdlan/src/dns_proxy/dns_cache.erl
+++ b/apps/sdlan/src/dns_proxy/dns_cache.erl
@ -41,7 +41,7 @@ insert(#dns_query{name = Qname, type = QType, class = QClass},
        true ->
            TTL = lists:min(TTLs),
            ExpireAt = os:system_time(second) + TTL,
-            lager:debug("min ttl is: ~p, expire_at: ~p", [TTL, ExpireAt]),
+            logger:debug("min ttl is: ~p, expire_at: ~p", [TTL, ExpireAt]),
            Key = {Qname, QType, QClass},
            Cache = #dns_cache{
                key = Key,
--- a/apps/sdlan/src/dns_proxy/dns_handler.erl
+++ b/apps/sdlan/src/dns_proxy/dns_handler.erl
@ -82,10 +82,10 @@ handle_cast({handle_ip_packet, Sock, SrcIp, SrcPort, IpPacket}, State) ->
                    RespIpPacket = build_ip_packet(ReqDAddr, ReqSAddr, ReqDPort, ReqSPort, DnsResp),
                    gen_udp:send(Sock, SrcIp, SrcPort, RespIpPacket);
                {error, Reason} ->
-                    lager:notice("[dns_handler] resolver get error: ~p", [Reason])
+                    logger:notice("[dns_handler] resolver get error: ~p", [Reason])
            end;
        false ->
-            lager:notice("[dns_handler] resolver invalid protocol: ~p", [Protocol])
+            logger:notice("[dns_handler] resolver invalid protocol: ~p", [Protocol])
    end,
    {stop, normal, State}.

@ -146,45 +146,45 @@ resolver0(Packet, QueryMsg = #dns_message{qc = 1, questions = [Question = #dns_q
                authority = [],
                additional = []
            },
-            lager:debug("[dns_handler] punchnet inbuilt qnanme: ~p, ip: ~p", [QName, Ip]),
+            logger:debug("[dns_handler] punchnet inbuilt qnanme: ~p, ip: ~p", [QName, Ip]),
            {ok, dns:encode_message(RespMsg)};
        error ->
            %% 是否命中内部的域名后缀
            EmptyDnsResp = dns:encode_message(build_nxdomain_response(QueryMsg)),
            case sdlan_domain_regedit:maybe_domain(QName) of
                true ->
-                    lager:debug("[dns_handler] punchnet inbuilt qnanme: ~p, nxdomain", [QName]),
+                    logger:debug("[dns_handler] punchnet inbuilt qnanme: ~p, nxdomain", [QName]),
                    {ok, EmptyDnsResp};
                false ->
                    case dns_cache:lookup(Question) of
                        {hit, Cache} ->
-                            lager:debug("[dns_handler] qname: ~p, hit cache answers: ~p", [QName, Cache#dns_cache.answers]),
+                            logger:debug("[dns_handler] qname: ~p, hit cache answers: ~p", [QName, Cache#dns_cache.answers]),
                            RespMsg = build_response(QueryMsg, Cache),
                            {ok, dns:encode_message(RespMsg)};
                        miss ->
                            Ref = make_ref(),
                            forward_to_upstream(Ref, Packet, QueryMsg),
-                            lager:debug("[dns_handler] cache is miss, forward_to_upstream"),
+                            logger:debug("[dns_handler] cache is miss, forward_to_upstream"),
                            receive
                                {dns_resolver_reply, Ref, Resp} ->
                                    case dns:decode_message(Resp) of
                                        RespMsg = #dns_message{answers = Answers} ->
-                                            lager:debug("[dns_handler] get a response answers: ~p", [Answers]),
+                                            logger:debug("[dns_handler] get a response answers: ~p", [Answers]),
                                            dns_cache:insert(Question, RespMsg),
                                            {ok, Resp};
                                        Error ->
-                                            lager:debug("[dns_handler] parse reply get error: ~p", [Error]),
+                                            logger:debug("[dns_handler] parse reply get error: ~p", [Error]),
                                            {ok, EmptyDnsResp}
                                    end
                            after 5000 ->
-                                lager:debug("[dns_handler] forward_to_upstream timeout"),
+                                logger:debug("[dns_handler] forward_to_upstream timeout"),
                                {ok, EmptyDnsResp}
                            end
                    end
            end
    end;
 resolver0(_, Error) ->
-    lager:warning("[dns_handler] decode dns_query get error: ~p", [Error]),
+    logger:warning("[dns_handler] decode dns_query get error: ~p", [Error]),
    {error, Error}.

 -spec forward_to_upstream(Ref :: reference(), Request :: binary(), QueryMsg :: #dns_message{}) -> no_return().
--- a/apps/sdlan/src/dns_proxy/dns_resolver.erl
+++ b/apps/sdlan/src/dns_proxy/dns_resolver.erl
@ -81,7 +81,7 @@ handle_cast({forward, ReceiverPid, Ref, Request, #dns_message{id = TxId, questio
    lists:foreach(fun({DnsIp, DnsPort}) ->
        ok = gen_udp:send(Socket, DnsIp, DnsPort, Request),
        Key = {Idx, TxId, DnsIp, DnsPort, QName, QType, QClass},
-        lager:debug("[dns_resolver] key: ~p, send to: ~p, packet: ~p", [Key, {DnsIp, DnsPort}, Request]),
+        logger:debug("[dns_resolver] key: ~p, send to: ~p, packet: ~p", [Key, {DnsIp, DnsPort}, Request]),
        dns_pending_wheel:insert(Key, {Ref, ReceiverPid})
                  end, DnsServers),

--- a/apps/sdlan/src/dns_proxy/dns_server.erl
+++ b/apps/sdlan/src/dns_proxy/dns_server.erl
@ -7,18 +7,18 @@ start_link(Port) when is_integer(Port) ->
 init(Port) ->
    dns_cache:init(),
    {ok, Sock} = gen_udp:open(Port, [binary, {active, true}]),
-    lager:debug("[dns_server] DNS Forwarder started on UDP port ~p~n", [Port]),
+    logger:debug("[dns_server] DNS Forwarder started on UDP port ~p~n", [Port]),
    loop(Sock).

 loop(Sock) ->
    receive
        {udp, Sock, Ip, Port, Packet} ->
-            lager:debug("[dns_server] ip: ~p, get a packet: ~p", [{Ip, Port}, Packet]),
+            logger:debug("[dns_server] ip: ~p, get a packet: ~p", [{Ip, Port}, Packet]),
            case dns_handler_sup:start_handler() of
                {ok, HandlerPid} ->
                    dns_handler:handle_ip_packet(HandlerPid, Sock, Ip, Port, Packet);
                Error ->
-                    lager:debug("[dns_server] start handler get error: ~p", [Error])
+                    logger:debug("[dns_server] start handler get error: ~p", [Error])
            end,
            loop(Sock)
    end.
--- a/apps/sdlan/src/dns_proxy/dns_utils.erl
+++ b/apps/sdlan/src/dns_proxy/dns_utils.erl
@ -126,6 +126,6 @@ test() ->

    X = udp_checksum(SAddr, DAddr, SPort, DPort, UDPPayload),

-    lager:debug("ip_sum: ~p, =: ~p, udp: ~p, checkSum: ~p, =: ~p", [IpSum, ip_checksum(IPPacket), UDP, CheckSum, X]),
+    logger:debug("ip_sum: ~p, =: ~p, udp: ~p, checkSum: ~p, =: ~p", [IpSum, ip_checksum(IPPacket), UDP, CheckSum, X]),

    dns:decode_message(UDPPayload).
--- a/apps/sdlan/src/http_handler/api_handler.erl
+++ b/apps/sdlan/src/http_handler/api_handler.erl
@ -18,7 +18,7 @@

 %% 重新加载对应的主机信息
 handle_request("POST", "/test/auth_token", _, PostParams) ->
-    lager:debug("[test_handler] get post params: ~p", [PostParams]),
+    logger:debug("[test_handler] get post params: ~p", [PostParams]),
    [Id | _] = network_bo:get_all_networks(),
    Data = #{
        <<"network_id">> => Id
--- a/apps/sdlan/src/http_handler/http_protocol.erl
+++ b/apps/sdlan/src/http_handler/http_protocol.erl
@ -21,7 +21,7 @@ init(Req0, Opts = [Mod|_]) ->

    try Mod:handle_request(Method, Path, GetParams, PostParams) of
        {ok, StatusCode, Resp} ->
-            %lager:debug("[http_protocol] request path: ~p, get_params: ~p, post_params: ~p, response: ~ts",
+            %logger:debug("[http_protocol] request path: ~p, get_params: ~p, post_params: ~p, response: ~ts",
            %    [Path, GetParams, PostParams, Resp]),
            AcceptEncoding = cowboy_req:header(<<"accept-encoding">>, Req1, <<>>),
            Req2 = case iolist_size(Resp) >= 1024 andalso supported_gzip(AcceptEncoding) of
@ -44,7 +44,7 @@ init(Req0, Opts = [Mod|_]) ->
            }, Error, Req1),
            {ok, Req2, Opts};
        _:Error:Stack ->
-            lager:warning("[http_handler] get error: ~p, stack: ~p", [Error, Stack]),
+            logger:warning("[http_handler] get error: ~p, stack: ~p", [Error, Stack]),
            Req2 = cowboy_req:reply(500, #{
                <<"Content-Type">> => <<"text/html;charset=utf-8">>
            }, <<"Internal Server Error">>, Req1),
--- a/apps/sdlan/src/http_handler/network_handler.erl
+++ b/apps/sdlan/src/http_handler/network_handler.erl
@ -17,7 +17,7 @@ handle_request("POST", "/network/create", _, #{<<"id">> := NetworkId}) when Netw
        {ok, Pid} when is_pid(Pid) ->
            {ok, 200, sdlan_util:json_data(<<"success">>)};
        {error, Reason} ->
-            lager:debug("[network_handler] create network: ~p, get error: ~p", [NetworkId, Reason]),
+            logger:debug("[network_handler] create network: ~p, get error: ~p", [NetworkId, Reason]),
            {ok, 200, sdlan_util:json_error(-1, <<"error">>)}
    end;

@ -29,7 +29,7 @@ handle_request("POST", "/network/reload", _, #{<<"id">> := NetworkId}) when Netw
                    sdlan_network_sup:reallocate_bind_width(),
                    {ok, 200, sdlan_util:json_data(<<"success">>)};
                {error, Reason} ->
-                    lager:debug("[network_handler] start network: ~p, get error: ~p", [NetworkId, Reason]),
+                    logger:debug("[network_handler] start network: ~p, get error: ~p", [NetworkId, Reason]),
                    {ok, 200, sdlan_util:json_error(-1, <<"error">>)}
            end;
        NetworkPid when is_pid(NetworkPid) ->
@ -37,7 +37,7 @@ handle_request("POST", "/network/reload", _, #{<<"id">> := NetworkId}) when Netw
                ok ->
                    {ok, 200, sdlan_util:json_data(<<"success">>)};
                {error, Reason} ->
-                    lager:debug("[network_handler] reload network: ~p, get error: ~p", [NetworkId, Reason]),
+                    logger:debug("[network_handler] reload network: ~p, get error: ~p", [NetworkId, Reason]),
                    {ok, 200, sdlan_util:json_error(-1, <<"error">>)}
            end
    end;
@ -51,7 +51,7 @@ handle_request("POST", "/network/delete", _, #{<<"id">> := NetworkId}) when Netw
                ok ->
                    {ok, 200, sdlan_util:json_data(<<"success">>)};
                {error, Reason} ->
-                    lager:debug("[network_handler] delete network: ~p, get error: ~p", [NetworkId, Reason]),
+                    logger:debug("[network_handler] delete network: ~p, get error: ~p", [NetworkId, Reason]),
                    {ok, 200, sdlan_util:json_error(-1, <<"error">>)}
            end
    end;
--- a/apps/sdlan/src/http_handler/node_handler.erl
+++ b/apps/sdlan/src/http_handler/node_handler.erl
@ -49,7 +49,7 @@ handle_request("POST", "/node/move", _, #{<<"client_id">> := ClientId, <<"from_n
                    Ref = sdlan_channel:move_network(ChannelPid, self(), ToPid, HostName),
                    receive
                        {command_reply, Ref, {error, Reason}} ->
-                            lager:warning("[node_handler] client_id: ~p, move network from: ~p, to: ~p, get error: ~p", [ClientId, FromPid, ToPid, Reason]),
+                            logger:warning("[node_handler] client_id: ~p, move network from: ~p, to: ~p, get error: ~p", [ClientId, FromPid, ToPid, Reason]),
                            {ok, 200, sdlan_util:json_error(-1, <<"move failed">>)};
                        {command_reply, Ref, #sdl_command_ack{status = true}} ->
                            {ok, 200, sdlan_util:json_data(<<"success">>)};
--- a/apps/sdlan/src/http_handler/test_handler.erl
+++ b/apps/sdlan/src/http_handler/test_handler.erl
@ -18,7 +18,7 @@

 %% 重新加载对应的主机信息
 handle_request("POST", "/test/auth_token", _, PostParams) ->
-    lager:debug("[test_handler] get post params: ~p", [PostParams]),
+    logger:debug("[test_handler] get post params: ~p", [PostParams]),
    Data = #{
        <<"network_id">> => 8,
        <<"upgrade_type">> => 0,
@ -28,7 +28,7 @@ handle_request("POST", "/test/auth_token", _, PostParams) ->
    {ok, 200, sdlan_util:json_data(Data)};

 handle_request("POST", "/test/upgrade", _, PostParams) ->
-    lager:debug("[test_handler] get post params: ~p", [PostParams]),
+    logger:debug("[test_handler] get post params: ~p", [PostParams]),
    Data = #{
        <<"upgrade_type">> => 1,
        <<"upgrade_prompt">> => <<"prompt需要升级"/utf8>>,
--- a/apps/sdlan/src/mnesia/client_model.erl
+++ b/apps/sdlan/src/mnesia/client_model.erl
@ -156,7 +156,7 @@ debug(NetworkId) when is_integer(NetworkId) ->
        end,
    case mnesia:transaction(F) of
        {'atomic', Records} ->
-            lists:foreach(fun(C) -> lager:debug("client: ~p", [C]) end, Records);
+            lists:foreach(fun(C) -> logger:debug("client: ~p", [C]) end, Records);
        {'aborted', Reason} ->
-            lager:warning("read clients get error: ~p", [Reason])
+            logger:warning("read clients get error: ~p", [Reason])
    end.
--- a/apps/sdlan/src/mysql/mysql_provider.erl
+++ b/apps/sdlan/src/mysql/mysql_provider.erl
@ -16,49 +16,49 @@
 %% 从数据库中查找一行记录
 -spec get_row(ConnPid :: pid(), Sql::binary()) -> {ok, Record::map()} | undefined.
 get_row(ConnPid, Sql) when is_pid(ConnPid), is_binary(Sql) ->
-    lager:debug("[mysql_client] get_row sql is: ~p", [Sql]),
+    logger:debug("[mysql_client] get_row sql is: ~p", [Sql]),
    case mysql:query(ConnPid, Sql) of
        {ok, Names, [Row | _]} ->
            {ok, maps:from_list(lists:zip(Names, Row))};
        {ok, _, []} ->
            undefined;
        Error ->
-            lager:warning("[mysql_client] get error: ~p", [Error]),
+            logger:warning("[mysql_client] get error: ~p", [Error]),
            undefined
    end.

 -spec get_row(ConnPid :: pid(), Sql::binary(), Params::list()) -> {ok, Record::map()} | undefined.
 get_row(ConnPid, Sql, Params) when is_pid(ConnPid), is_binary(Sql), is_list(Params) ->
-    lager:debug("[mysql_client] get_row sql is: ~p, params: ~p", [Sql, Params]),
+    logger:debug("[mysql_client] get_row sql is: ~p, params: ~p", [Sql, Params]),
    case mysql:query(ConnPid, Sql, Params) of
        {ok, Names, [Row | _]} ->
            {ok, maps:from_list(lists:zip(Names, Row))};
        {ok, _, []} ->
            undefined;
        Error ->
-            lager:warning("[mysql_client] get error: ~p", [Error]),
+            logger:warning("[mysql_client] get error: ~p", [Error]),
            undefined
    end.

 -spec get_all(ConnPid :: pid(), Sql::binary()) -> {ok, Rows::list()} | {error, Reason :: any()}.
 get_all(ConnPid, Sql) when is_pid(ConnPid), is_binary(Sql) ->
-    lager:debug("[mysql_client] get_all sql is: ~p", [Sql]),
+    logger:debug("[mysql_client] get_all sql is: ~p", [Sql]),
    case mysql:query(ConnPid, Sql) of
        {ok, Names, Rows} ->
            {ok, lists:map(fun(Row) -> maps:from_list(lists:zip(Names, Row)) end, Rows)};
        {error, Reason} ->
-            lager:warning("[mysql_client] get error: ~p", [Reason]),
+            logger:warning("[mysql_client] get error: ~p", [Reason]),
            {error, Reason}
    end.

 -spec get_all(ConnPid :: pid(), Sql::binary(), Params::list()) -> {ok, Rows::list()} | {error, Reason::any()}.
 get_all(ConnPid, Sql, Params) when is_pid(ConnPid), is_binary(Sql), is_list(Params) ->
-    lager:debug("[mysql_client] get_all sql is: ~p, params: ~p", [Sql, Params]),
+    logger:debug("[mysql_client] get_all sql is: ~p, params: ~p", [Sql, Params]),
    case mysql:query(ConnPid, Sql, Params) of
        {ok, Names, Rows} ->
            {ok, lists:map(fun(Row) -> maps:from_list(lists:zip(Names, Row)) end, Rows)};
        {error, Reason} ->
-            lager:warning("[mysql_client] get error: ~p", [Reason]),
+            logger:warning("[mysql_client] get error: ~p", [Reason]),
            {error, Reason}
    end.

@ -74,7 +74,7 @@ insert(ConnPid, Table, Fields, FetchInsertId) when is_pid(ConnPid), is_binary(Ta
    ValuesPlaceholder = iolist_to_binary(lists:join(<<", ">>, Placeholders)),

    Sql = <<"INSERT INTO ", Table/binary, "(", FieldSql/binary, ") VALUES(", ValuesPlaceholder/binary, ")">>,
-    lager:debug("[mysql_client] insert sql is: ~p, params: ~p", [Sql, Values]),
+    logger:debug("[mysql_client] insert sql is: ~p, params: ~p", [Sql, Values]),
    case mysql:query(ConnPid, Sql, Values) of
        ok ->
            case FetchInsertId of
@ -90,7 +90,7 @@ insert(ConnPid, Table, Fields, FetchInsertId) when is_pid(ConnPid), is_binary(Ta

 -spec update_by(ConnPid :: pid(), UpdateSql :: binary()) -> {ok, AffectedRows :: integer()} | {error, Reason :: any()}.
 update_by(ConnPid, UpdateSql) when is_pid(ConnPid), is_binary(UpdateSql) ->
-    lager:debug("[mysql_client] updateBySql sql: ~p", [UpdateSql]),
+    logger:debug("[mysql_client] updateBySql sql: ~p", [UpdateSql]),
    case mysql:query(ConnPid, UpdateSql) of
        ok ->
            AffectedRows = mysql:affected_rows(ConnPid),
@ -101,7 +101,7 @@ update_by(ConnPid, UpdateSql) when is_pid(ConnPid), is_binary(UpdateSql) ->

 -spec update_by(ConnPid :: pid(), UpdateSql :: binary(), Params :: list()) -> {ok, AffectedRows :: integer()} | {error, Reason :: any()}.
 update_by(ConnPid, UpdateSql, Params) when is_pid(ConnPid), is_binary(UpdateSql) ->
-    lager:debug("[mysql_client] updateBySql sql: ~p, params: ~p", [UpdateSql, Params]),
+    logger:debug("[mysql_client] updateBySql sql: ~p, params: ~p", [UpdateSql, Params]),
    case mysql:query(ConnPid, UpdateSql, Params) of
        ok ->
            AffectedRows = mysql:affected_rows(ConnPid),
@ -126,13 +126,13 @@ update(ConnPid, Table, Fields, WhereFields) when is_pid(ConnPid), is_binary(Tabl
    Params = SetVals ++ WhereVals,

    Sql = <<"UPDATE ", Table/binary, " SET ",  SetSql/binary, " WHERE ", WhereSql/binary>>,
-    lager:debug("[mysql_client] update sql is: ~p, params: ~p", [Sql, Params]),
+    logger:debug("[mysql_client] update sql is: ~p, params: ~p", [Sql, Params]),
    case mysql:query(ConnPid, Sql, Params) of
        ok ->
            AffectedRows = mysql:affected_rows(ConnPid),
            {ok, AffectedRows};
        Error ->
-            lager:error("[mysql_client] update sql: ~p, params: ~p, get a error: ~p", [Sql, Params, Error]),
+            logger:error("[mysql_client] update sql: ~p, params: ~p, get a error: ~p", [Sql, Params, Error]),
            Error
    end.

--- a/apps/sdlan/src/sdlan.app.src
+++ b/apps/sdlan/src/sdlan.app.src
@ -6,7 +6,6 @@
  {applications,
   [
    sync,
-    lager,
    cowboy,
    ranch,
    poolboy,
@ -17,7 +16,7 @@
    throttle,
    dns_erlang,
    pkt,
-    parse_trans,
+    quicer,
    mnesia,
    erts,
    public_key,
--- a/apps/sdlan/src/sdlan_app.erl
+++ b/apps/sdlan/src/sdlan_app.erl
@ -57,7 +57,7 @@ start_http_server() ->

    {ok, Pid} = cowboy:start_clear(http_listener, TransOpts, #{env => #{dispatch => Dispatcher}}),

-    lager:debug("[iot_app] the http server start at: ~p, pid is: ~p", [Port, Pid]).
+    logger:debug("[iot_app] the http server start at: ~p, pid is: ~p", [Port, Pid]).

 %% 启动tcp服务
 start_tcp_server() ->
@ -78,4 +78,4 @@ start_tcp_server() ->
    },
    {ok, _} = ranch:start_listener('sdlan/tcp_server', ranch_tcp, TransOpts, sdlan_channel, []),

-    lager:debug("[sdlan_app] the tcp server start at: ~p", [Port]).
+    logger:debug("[sdlan_app] the tcp server start at: ~p", [Port]).
--- a/apps/sdlan/src/sdlan_channel.erl
+++ b/apps/sdlan/src/sdlan_channel.erl
@ -104,7 +104,7 @@ start_link(Ref, _Socket, Transport, Opts) ->

 init([Ref, Transport, _Opts = []]) ->
    {ok, Socket} = ranch:handshake(Ref),
-    lager:debug("[sdlan_channel] get a new connection: ~p", [Socket]),
+    logger:debug("[sdlan_channel] get a new connection: ~p", [Socket]),
    Transport:setopts(Socket, [{active, true}, {packet, 2}]),
    erlang:start_timer(?PING_TICKER, self(), ping_ticker),
    gen_server:enter_loop(?MODULE, [], #state{transport = Transport, socket = Socket}).
@ -120,23 +120,23 @@ handle_info({tcp, Sock, <<PacketId:32, ?PACKET_REGISTER_SUPER, Body/binary>>}, S
    #sdl_register_super{version = Version, client_id = ClientId, hostname = HostName, dev_addr = #sdl_dev_addr{net_addr = NetAddr0, mac = Mac}, network_code = NetworkCode, token = Token, pub_key = PubKey} = sdlan_pb:decode_msg(Body, sdl_register_super),

    %% 参数检查
-    lager:debug("[sdlan_channel] client_id: ~p, public_key: ~p, token: ~p, network_code: ~p", [ClientId, PubKey, Token, NetworkCode]),
+    logger:debug("[sdlan_channel] client_id: ~p, public_key: ~p, token: ~p, network_code: ~p", [ClientId, PubKey, Token, NetworkCode]),
    true = (Mac =/= <<>> andalso PubKey =/= <<>> andalso ClientId =/= <<>>),
    %% Mac地址不能是广播地址
    true = not (sdlan_util:is_multicast_mac(Mac) orelse sdlan_util:is_broadcast_mac(Mac)),

    AuthResult = if
                     Token /= <<>> ->
-                         lager:debug("[sdlan_channel] auth token: ~p", [Token]),
+                         logger:debug("[sdlan_channel] auth token: ~p", [Token]),
                         sdlan_api:auth_token(ClientId, Token, Version);
                     NetworkCode /= <<>> ->
-                         lager:debug("[sdlan_channel] auth network code: ~p", [NetworkCode]),
+                         logger:debug("[sdlan_channel] auth network code: ~p", [NetworkCode]),
                         sdlan_api:auth_network_code(ClientId, NetworkCode, Version)
                 end,

    case AuthResult of
        {ok, #{<<"result">> := #{<<"network_id">> := NetworkId, <<"upgrade_type">> := UpgradeType, <<"upgrade_prompt">> := UpgradePrompt, <<"upgrade_address">> := UpgradeAddress}}} when is_integer(NetworkId) ->
-            lager:debug("[sdlan_channel] client_id: ~p, mac: ~p, token: ~p, version: ~p, registerd, alloc network_id: ~p", [ClientId, sdlan_util:format_mac(Mac), Token, Version, NetworkId]),
+            logger:debug("[sdlan_channel] client_id: ~p, mac: ~p, token: ~p, version: ~p, registerd, alloc network_id: ~p", [ClientId, sdlan_util:format_mac(Mac), Token, Version, NetworkId]),
            %% 建立到network的对应关系
            case sdlan_network:get_pid(NetworkId) of
                NetworkPid when is_pid(NetworkPid) ->
@ -162,52 +162,52 @@ handle_info({tcp, Sock, <<PacketId:32, ?PACKET_REGISTER_SUPER, Body/binary>>}, S
                            %% 发送确认信息
                            Reply = <<PacketId:32, ?PACKET_REGISTER_SUPER_ACK, RegisterSuperAck/binary>>,
                            Transport:send(Sock, Reply),
-                            lager:debug("[sdlan_channel] client_id: ~p, mac: ~p, alloc ip: ~p, register will send ack, aes_key: ~p, enc_aes_key: ~p",
+                            logger:debug("[sdlan_channel] client_id: ~p, mac: ~p, alloc ip: ~p, register will send ack, aes_key: ~p, enc_aes_key: ~p",
                                [ClientId, sdlan_util:format_mac(Mac), sdlan_ipaddr:int_to_ipv4(NetAddr), AesKey, EncodedAesKey]),

                            %% 设置节点的在线状态
                            Result = sdlan_api:node_online(ClientId, NetworkId, sdlan_ipaddr:int_to_ipv4(NetAddr)),
-                            lager:debug("[sdlan_channel] client_id: ~p, set none online, result is: ~p", [ClientId, Result]),
+                            logger:debug("[sdlan_channel] client_id: ~p, set none online, result is: ~p", [ClientId, Result]),
                            case UpgradeType =:= ?UPGRADE_FORCE of
                                true ->
-                                    lager:warning("[sdlan_channel] client_id: ~p, need upgrade force!", [ClientId]),
+                                    logger:warning("[sdlan_channel] client_id: ~p, need upgrade force!", [ClientId]),
                                    {stop, normal, State};
                                false ->
                                    {noreply, State#state{client_id = ClientId, mac = Mac, assign_ip = NetAddr, network_pid = NetworkPid, pub_key = PubKey, is_registered = true}}
                            end;
                        {error, no_ip} ->
-                            lager:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: no_ip", [ClientId, Token]),
+                            logger:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: no_ip", [ClientId, Token]),
                            Transport:send(Sock, register_nak_reply(PacketId, ?NAK_NO_IP, <<"No Ip address">>)),
                            {stop, normal, State};
                        {error, host_name_used} ->
-                            lager:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: host_name_used", [ClientId, Token]),
+                            logger:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: host_name_used", [ClientId, Token]),
                            Transport:send(Sock, register_nak_reply(PacketId, ?NAK_HOSTNAME_USED, <<"Host Name Used">>)),
                            {stop, normal, State};
                        {error, client_disabled} ->
-                            lager:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: client_disabled", [ClientId, Token]),
+                            logger:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: client_disabled", [ClientId, Token]),
                            Transport:send(Sock, register_nak_reply(PacketId, ?NAK_NODE_DISABLE, <<"Client Connection Disable">>)),
                            {stop, normal, State}
                    catch _:Error:Stack ->
-                        lager:warning("[sdlan_channel] get error: ~p, stack: ~p", [Error, Stack])
+                        logger:warning("[sdlan_channel] get error: ~p, stack: ~p", [Error, Stack])
                    end;
                undefined ->
-                    lager:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: network not found", [ClientId, Token]),
+                    logger:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: network not found", [ClientId, Token]),
                    Transport:send(Sock, register_nak_reply(PacketId, ?NAK_INTERNAL_FAULT, <<"Internal Error">>)),

                    {stop, normal, State}
            end;
        {ok, #{<<"error">> := #{<<"code">> := 1, <<"message">> := Message}}} ->
-            lager:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: ~ts, error_code: 1", [ClientId, Token, Message]),
+            logger:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: ~ts, error_code: 1", [ClientId, Token, Message]),
            Transport:send(Sock, register_nak_reply(PacketId, ?NAK_INVALID_TOKEN, Message)),
            {stop, normal, State};

        {ok, #{<<"error">> := #{<<"code">> := 2, <<"message">> := Message}}} ->
-            lager:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: ~p, error_code: 2", [ClientId, Token, Message]),
+            logger:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: ~p, error_code: 2", [ClientId, Token, Message]),
            Transport:send(Sock, register_nak_reply(PacketId, ?NAK_NODE_DISABLE, Message)),
            {stop, normal, State};

        {error, Reason} ->
-            lager:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: ~p", [ClientId, Token, Reason]),
+            logger:warning("[sdlan_channel] client_id: ~p, token: ~p, register get error: ~p", [ClientId, Token, Reason]),
            Transport:send(Sock, register_nak_reply(PacketId, ?NAK_NETWORK_FAULT, <<"Network Error">>)),
            {stop, normal, State}
    end;
@ -216,13 +216,13 @@ handle_info({tcp, Sock, <<PacketId:32, ?PACKET_QUERY_INFO, Body/binary>>}, State
    #sdl_query_info{dst_mac = DstMac} = sdlan_pb:decode_msg(Body, sdl_query_info),
    case sdlan_network:peer_info(NetworkPid, SrcMac, DstMac) of
        error ->
-            lager:debug("[sdlan_channel] query_info src_mac is: ~p, dst_mac: ~p, nat_peer not found",
+            logger:debug("[sdlan_channel] query_info src_mac is: ~p, dst_mac: ~p, nat_peer not found",
                [sdlan_util:format_mac(SrcMac), sdlan_util:format_mac(DstMac)]),

            Transport:send(Sock, <<PacketId:32, ?PACKET_EMPTY>>),
            {noreply, State};
        {ok, {NatPeer = {{Ip0, Ip1, Ip2, Ip3}, NatPort}, NatType}, V6Info} ->
-            lager:debug("[sdlan_channel] query_info src_mac is: ~p, dst_mac: ~p, nat_peer: ~p",
+            logger:debug("[sdlan_channel] query_info src_mac is: ~p, dst_mac: ~p, nat_peer: ~p",
                [sdlan_util:format_mac(SrcMac), sdlan_util:format_mac(DstMac), NatPeer]),

            PeerInfo = sdlan_pb:encode_msg(#sdl_peer_info{
@ -239,7 +239,7 @@ handle_info({tcp, Sock, <<PacketId:32, ?PACKET_QUERY_INFO, Body/binary>>}, State
    end;

 handle_info({tcp, _Sock, <<0:32, ?PACKET_PING>>}, State = #state{transport = Transport, socket = Sock, ping_counter = PingCounter}) ->
-    %lager:debug("[sdlan_channel] client_id: ~p, get ping", [ClientId]),
+    %logger:debug("[sdlan_channel] client_id: ~p, get ping", [ClientId]),
    Transport:send(Sock, <<0:32, ?PACKET_PONG>>),
    {noreply, State#state{ping_counter = PingCounter + 1}};

@ -250,7 +250,7 @@ handle_info({timeout, _, ping_ticker}, State = #state{client_id = ClientId, ping
        true ->
            {noreply, State#state{ping_counter = 0}};
        false ->
-            lager:debug("[sdlan_channel] client_id: ~p, ping losted", [ClientId]),
+            logger:debug("[sdlan_channel] client_id: ~p, ping losted", [ClientId]),
            {stop, normal, State#state{ping_counter = 0}}
    end;

@ -281,10 +281,10 @@ handle_info({move_network, ReceiverPid, Ref, NetworkPid, HostName},
            %% 设置节点的在线状态
            sdlan_api:node_online(ClientId, NetworkId, sdlan_ipaddr:int_to_ipv4(NetAddr)),

-            lager:debug("[sdlan_channel] client_id: ~p, move_network will send command: ~p", [ClientId, Command]),
+            logger:debug("[sdlan_channel] client_id: ~p, move_network will send command: ~p", [ClientId, Command]),
            {noreply, State#state{packet_id = PacketId + 1, assign_ip = NetAddr, network_pid = NetworkPid, inflight = maps:put(PacketId, {ReceiverPid, Ref}, Inflight)}};
        {error, Reason} ->
-            lager:debug("[sdlan_channel] client_id: ~p, move_network get error: ~p", [ClientId, Reason]),
+            logger:debug("[sdlan_channel] client_id: ~p, move_network get error: ~p", [ClientId, Reason]),
            Transport:send(Sock, register_nak_reply(0, ?NAK_NO_IP, <<"No Ip address">>)),
            ReceiverPid ! {command_reply, Ref, {error, <<"assign_ip error, no ip free">>}},
            {noreply, State}
@ -292,7 +292,7 @@ handle_info({move_network, ReceiverPid, Ref, NetworkPid, HostName},

 %% 发送指令信息
 handle_info({send_event, EventType, Event}, State = #state{transport = Transport, socket = Sock, client_id = ClientId, is_registered = true}) ->
-    lager:debug("[sdlan_channel] client_id: ~p, will send eventType: ~p, event: ~p", [ClientId, EventType, Event]),
+    logger:debug("[sdlan_channel] client_id: ~p, will send eventType: ~p, event: ~p", [ClientId, EventType, Event]),
    Transport:send(Sock, <<0:32, ?PACKET_EVENT, EventType, Event/binary>>),
    {noreply, State};

@ -301,18 +301,18 @@ handle_info({tcp, _Sock, <<0:32, ?PACKET_FLOW_TRACER, Body/binary>>}, State = #s
    #sdl_flows{forward_num = ForwardNum, p2p_num = P2PNum, inbound_num = InboundNum} = sdlan_pb:decode_msg(Body, sdl_flows),
    {ok, NetworkId} = sdlan_network:get_network_id(NetworkPid),
    ReportResult = sdlan_api:flow_report(ClientId, NetworkId, ForwardNum, P2PNum, InboundNum),
-    lager:debug("[sdlan_channel] flow_tracer, forward: ~p, p2p: ~p, inbound: ~p, result: ~p", [ClientId, ForwardNum, P2PNum, InboundNum, ReportResult]),
+    logger:debug("[sdlan_channel] flow_tracer, forward: ~p, p2p: ~p, inbound: ~p, result: ~p", [ClientId, ForwardNum, P2PNum, InboundNum, ReportResult]),
    {noreply, State};

 %% 取消注册
 handle_info({tcp, _Sock, <<0:32, ?PACKET_UNREGISTER>>}, State = #state{client_id = ClientId, network_pid = NetworkPid, is_registered = true}) when is_pid(NetworkPid) ->
-    lager:warning("[sdlan_channel] unregister client_id: ~p", [ClientId]),
+    logger:warning("[sdlan_channel] unregister client_id: ~p", [ClientId]),
    % sdlan_network:unregister(NetworkPid, ClientId),
    {stop, normal, State};

 %% 发送指令信息
 handle_info({publish_command, ReceiverPid, Ref, CommandType, Msg}, State = #state{transport = Transport, socket = Sock, client_id = ClientId, packet_id = PacketId, inflight = Inflight, is_registered = true}) ->
-    lager:warning("[sdlan_channel] client_id: ~p, will publish: ~p, message: ~p", [ClientId, CommandType, Msg]),
+    logger:warning("[sdlan_channel] client_id: ~p, will publish: ~p, message: ~p", [ClientId, CommandType, Msg]),
    Transport:send(Sock, <<PacketId:32, ?PACKET_COMMAND, CommandType, Msg/binary>>),
    {noreply, State#state{packet_id = PacketId + 1, inflight = maps:put(PacketId, {ReceiverPid, Ref}, Inflight)}};

@ -320,27 +320,27 @@ handle_info({publish_command, ReceiverPid, Ref, CommandType, Msg}, State = #stat
 handle_info({tcp, _Sock, <<PacketId:32, ?PACKET_COMMAND_ACK, Body/binary>>}, State = #state{client_id = ClientId, inflight = Inflight}) when PacketId > 0 ->
    CommandAck = #sdl_command_ack{} = sdlan_pb:decode_msg(Body, sdl_command_ack),

-    lager:debug("[sdlan_channel] client_id: ~p, get publish response message: ~p, packet_id: ~p", [ClientId, CommandAck, PacketId]),
+    logger:debug("[sdlan_channel] client_id: ~p, get publish response message: ~p, packet_id: ~p", [ClientId, CommandAck, PacketId]),
    case maps:take(PacketId, Inflight) of
        error ->
-            lager:warning("[sdlan_channel] get unknown publish response message: ~p, packet_id: ~p", [CommandAck, PacketId]),
+            logger:warning("[sdlan_channel] get unknown publish response message: ~p, packet_id: ~p", [CommandAck, PacketId]),
            {ok, State};
        {{ReceiverPid, Ref}, NInflight} ->
            case is_pid(ReceiverPid) andalso is_process_alive(ReceiverPid) of
                true ->
                    ReceiverPid ! {command_reply, Ref, CommandAck};
                false ->
-                    lager:warning("[sdlan_channel] get publish response message: ~p, packet_id: ~p, but receiver_pid is deaded", [CommandAck, PacketId])
+                    logger:warning("[sdlan_channel] get publish response message: ~p, packet_id: ~p, but receiver_pid is deaded", [CommandAck, PacketId])
            end,
            {noreply, State#state{inflight = NInflight}}
    end;

 handle_info({tcp_error, Sock, Reason}, State = #state{socket = Sock, client_id = ClientId}) ->
-    lager:notice("[sdlan_channel] client_id: ~p, tcp_error: ~p", [ClientId, Reason]),
+    logger:notice("[sdlan_channel] client_id: ~p, tcp_error: ~p", [ClientId, Reason]),
    {stop, normal, State};

 handle_info({tcp_closed, Sock}, State = #state{socket = Sock, client_id = ClientId}) ->
-    lager:notice("[sdlan_channel] client_id: ~p, tcp_closed", [ClientId]),
+    logger:notice("[sdlan_channel] client_id: ~p, tcp_closed", [ClientId]),
    {stop, normal, State};

 %% 关闭当前通道
@ -348,7 +348,7 @@ handle_info({stop, Reason}, State) ->
    {stop, Reason, State};

 handle_info(Info, State) ->
-    lager:warning("[sdlan_channel] get a unknown message: ~p, channel will closed", [Info]),
+    logger:warning("[sdlan_channel] get a unknown message: ~p, channel will closed", [Info]),
    {noreply, State}.

 terminate(Reason, #state{client_id = ClientId, network_pid = NetworkPid}) ->
@ -356,11 +356,11 @@ terminate(Reason, #state{client_id = ClientId, network_pid = NetworkPid}) ->
        true ->
            {ok, NetworkId} = sdlan_network:get_network_id(NetworkPid),
            Result = sdlan_api:node_offline(ClientId, NetworkId),
-            lager:debug("[sdlan_channel] client_id: ~p, set none offline, result is: ~p", [ClientId, Result]);
+            logger:debug("[sdlan_channel] client_id: ~p, set none offline, result is: ~p", [ClientId, Result]);
        false ->
            ok
    end,
-    lager:warning("[sdlan_channel] client_id: ~p, stop with reason: ~p", [ClientId, Reason]),
+    logger:warning("[sdlan_channel] client_id: ~p, stop with reason: ~p", [ClientId, Reason]),
    ok.

 code_change(_OldVsn, State, _Extra) ->
--- a/apps/sdlan/src/sdlan_cipher.erl
+++ b/apps/sdlan/src/sdlan_cipher.erl
@ -17,7 +17,7 @@
 test() ->
    Key = <<"abcdabcdabcdabcd">>,
    X = aes_encrypt(Key, Key, <<"hello world">>),
-    lager:debug("x is: ~p, raw: ~p", [X, aes_decrypt(Key, Key, X)]),
+    logger:debug("x is: ~p, raw: ~p", [X, aes_decrypt(Key, Key, X)]),


    ok.
--- a/apps/sdlan/src/sdlan_network.erl
+++ b/apps/sdlan/src/sdlan_network.erl
@ -173,13 +173,13 @@ init([Id]) when is_integer(Id) ->
            %% 创建数据库表
            create_mnesia_table(Id),

-            lager:debug("[sdlan_network] network: ~p, ips: ~p", [Id, lists:map(fun sdlan_ipaddr:int_to_ipv4/1, Ips)]),
+            logger:debug("[sdlan_network] network: ~p, ips: ~p", [Id, lists:map(fun sdlan_ipaddr:int_to_ipv4/1, Ips)]),

            sdlan_domain_regedit:insert(Domain),

            {ok, #state{network_id = Id, name = Name, domain = Domain, ipaddr = IpAddr, owner_id = OwnerId, mask_len = MaskLen, ips = Ips, aes_key = AesKey, throttle_key = ThrottleKey}};
        {error, Reason} ->
-            lager:warning("[sdlan_network] load network: ~p, get error: ~p", [Id, Reason]),
+            logger:warning("[sdlan_network] load network: ~p, get error: ~p", [Id, Reason]),
            ignore
    end.

@ -202,7 +202,7 @@ handle_call(reload, _From, State = #state{network_id = Id, ipaddr = OldIpAddr, m
                true ->
                    {reply, ok, State#state{name = Name, owner_id = OwnerId}};
                false ->
-                    lager:debug("[sdlan_networkd] network_id: ~p, reload will close all channels", [Id]),
+                    logger:debug("[sdlan_networkd] network_id: ~p, reload will close all channels", [Id]),
                    Ips = sdlan_ipaddr:ips(IpAddr, MaskLen),
                    %% 整个网络下的设备都需要重新连接
                    maps:foreach(fun(_, #host{channel_pid = ChannelPid, monitor_ref = MRef}) ->
@ -216,7 +216,7 @@ handle_call(reload, _From, State = #state{network_id = Id, ipaddr = OldIpAddr, m
                        owner_id = OwnerId, mask_len = MaskLen, ips = Ips, used_map = maps:new()}}
            end;
        {error, Reason} ->
-            lager:warning("[sdlan_network] reload network: ~p, get error: ~p", [Id, Reason]),
+            logger:warning("[sdlan_network] reload network: ~p, get error: ~p", [Id, Reason]),
            {reply, {error, Reason}, State}
    end;

@ -225,7 +225,7 @@ handle_call({assign_ip_addr, ChannelPid, ClientId, Mac, NetAddr0, HostName}, _Fr
    State = #state{network_id = NetworkId, domain = Domain, ips = Ips, used_map = UsedMap, mask_len = MaskLen, aes_key = AesKey}) ->

    %% 分配ip地址的时候，以mac地址为唯一基准
-    lager:debug("[sdlan_network] alloc_ip, network_id: ~p, ips: ~p, client_id: ~p, mac: ~p, net_addr: ~p",
+    logger:debug("[sdlan_network] alloc_ip, network_id: ~p, ips: ~p, client_id: ~p, mac: ~p, net_addr: ~p",
        [NetworkId, Ips, ClientId, sdlan_util:format_mac(Mac), sdlan_ipaddr:int_to_ipv4(NetAddr0)]),

    case client_model:alloc_ip(NetworkId, Ips, ClientId, Mac, NetAddr0, HostName) of
@ -377,7 +377,7 @@ handle_cast({forward, Sock, SrcMac, DstMac, Packet}, State = #state{network_id =
            case throttle:check(sdlan_network, ThrottleKey) of
                {ok, _RestCount, _LeftToReset} ->
                    %% client和stun之间必须有心跳机制保持nat映射可用，并且通过服务转发的udp包肯定可以到达对端的nat
-                    lager:debug("[sdlan_network] forward data networkd_id: ~p, src_mac: ~p, dst_mac: ~p, hole: ~p",
+                    logger:debug("[sdlan_network] forward data networkd_id: ~p, src_mac: ~p, dst_mac: ~p, hole: ~p",
                        [NetworkId, sdlan_util:format_mac(SrcMac), sdlan_util:format_mac(DstMac), Peer]),

                    gen_udp:send(Sock, Ip, Port, Packet),
@ -386,23 +386,23 @@ handle_cast({forward, Sock, SrcMac, DstMac, Packet}, State = #state{network_id =
                    %% 尝试获取其他网络是否有让渡的资源
                    case sdlan_network_coordinator:checkout() of
                        ok ->
-                            lager:debug("[sdlan_network] use release forward data networkd_id: ~p, src_mac: ~p, dst_mac: ~p, hole: ~p",
+                            logger:debug("[sdlan_network] use release forward data networkd_id: ~p, src_mac: ~p, dst_mac: ~p, hole: ~p",
                                [NetworkId, sdlan_util:format_mac(SrcMac), sdlan_util:format_mac(DstMac), Peer]),

                            gen_udp:send(Sock, Ip, Port, Packet),
                            {noreply, State#state{forward_bytes = ForwardBytes + PacketBytes}};
                        error ->
-                            lager:notice("[sdlan_network] networkd_id: ~p, src_mac: ~p, dst_mac: ~p, rate limited, discard",
+                            logger:notice("[sdlan_network] networkd_id: ~p, src_mac: ~p, dst_mac: ~p, rate limited, discard",
                                [NetworkId, sdlan_util:format_mac(SrcMac), sdlan_util:format_mac(DstMac)]),
                            {noreply, State}
                    end
            end;
        {ok, _} ->
-            lager:debug("[sdlan_network] networkd_id: ~p, src_mac: ~p, dst_mac: ~p, hole not found",
+            logger:debug("[sdlan_network] networkd_id: ~p, src_mac: ~p, dst_mac: ~p, hole not found",
                [NetworkId, sdlan_util:format_mac(SrcMac), sdlan_util:format_mac(DstMac)]),
            {noreply, State};
        error ->
-            lager:debug("[sdlan_network] networkd_id: ~p, src_mac: ~p, dst_mac: ~p not found",
+            logger:debug("[sdlan_network] networkd_id: ~p, src_mac: ~p, dst_mac: ~p not found",
                [NetworkId, sdlan_util:format_mac(SrcMac), sdlan_util:format_mac(DstMac)]),
            {noreply, State}
    end;
@ -418,7 +418,7 @@ handle_cast({forward, Sock, SrcMac, DstMac, Packet}, State = #state{network_id =
            maps:foreach(fun(Mac, #host{hole = Hole}) ->
                case {Mac =/= SrcMac, Hole} of
                    {true, #hole{peer = {NatIp, NatPort}}} ->
-                        lager:debug("[sdlan_network] call me here"),
+                        logger:debug("[sdlan_network] call me here"),
                        gen_udp:send(Sock, NatIp, NatPort, Packet);
                    _ ->
                        ok
@ -426,24 +426,24 @@ handle_cast({forward, Sock, SrcMac, DstMac, Packet}, State = #state{network_id =
                         end, UsedMap),

            %% client和stun之间必须有心跳机制保持nat映射可用，并且通过服务转发的udp包肯定可以到达对端的nat
-            lager:debug("[sdlan_network] broadcast data networkd_id: ~p, src_mac: ~p, dst_mac: ~p",
+            logger:debug("[sdlan_network] broadcast data networkd_id: ~p, src_mac: ~p, dst_mac: ~p",
                [NetworkId, sdlan_util:format_mac(SrcMac), sdlan_util:format_mac(DstMac)]),

            {noreply, State#state{forward_bytes = ForwardBytes + PacketBytes}};
        false ->
-            lager:debug("[sdlan_network] networkd_id: ~p, src_mac: ~p, dst_mac: ~p, forward discard 1",
+            logger:debug("[sdlan_network] networkd_id: ~p, src_mac: ~p, dst_mac: ~p, forward discard 1",
                [NetworkId, sdlan_util:format_mac(SrcMac), sdlan_util:format_mac(DstMac)]),
            {noreply, State}
    end;

 handle_cast({forward, _Sock, SrcMac, DstMac, _Packet}, State = #state{network_id = NetworkId}) ->
-    lager:debug("[sdlan_network] networkd_id: ~p, src_mac: ~p, dst_mac: ~p, forward discard 2",
+    logger:debug("[sdlan_network] networkd_id: ~p, src_mac: ~p, dst_mac: ~p, forward discard 2",
        [NetworkId, sdlan_util:format_mac(SrcMac), sdlan_util:format_mac(DstMac)]),
    {noreply, State};

 %% 删除ip的占用并关闭channel
 handle_cast({unregister, _ClientId, Mac}, State = #state{network_id = NetworkId, used_map = UsedMap}) ->
-    lager:debug("[sdlan_network] networkd_id: ~p, unregister Mac: ~p", [NetworkId, sdlan_util:format_mac(Mac)]),
+    logger:debug("[sdlan_network] networkd_id: ~p, unregister Mac: ~p", [NetworkId, sdlan_util:format_mac(Mac)]),
    case maps:take(Mac, UsedMap) of
        error ->
            {noreply, State};
@ -486,12 +486,12 @@ handle_info({timeout, _, flow_report_ticker}, State = #state{network_id = Networ
    {noreply, State#state{forward_bytes = 0}};

 handle_info({'EXIT', _Pid, shutdown}, State = #state{network_id = NetworkId, used_map = UsedMap}) ->
-    lager:warning("[sdlan_network] network: ~p, get shutdown message", [NetworkId]),
+    logger:warning("[sdlan_network] network: ~p, get shutdown message", [NetworkId]),
    broadcast_shutdown(UsedMap),
    {stop, shutdown, State};
 %% Channel进程退出, hole里面的数据也需要清理
 handle_info({'DOWN', _MRef, process, ChannelPid, Reason}, State = #state{network_id = NetworkId, used_map = UsedMap}) ->
-    lager:notice("[sdlan_network] network_id: ~p, channel_pid: ~p, close with reason: ~p", [NetworkId, ChannelPid, Reason]),
+    logger:notice("[sdlan_network] network_id: ~p, channel_pid: ~p, close with reason: ~p", [NetworkId, ChannelPid, Reason]),
    NUsedMap = maps:filter(fun(_, #host{channel_pid = ChannelPid0}) -> ChannelPid =/= ChannelPid0 end, UsedMap),
    {noreply, State#state{used_map = NUsedMap}}.

@ -503,7 +503,7 @@ handle_info({'DOWN', _MRef, process, ChannelPid, Reason}, State = #state{network
 -spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()),
    State :: #state{}) -> term()).
 terminate(Reason, #state{network_id = NetworkId, used_map = UsedMap}) ->
-    lager:debug("[sdlan_network] network: ~p, will terminate with reason: ~p", [NetworkId, Reason]),
+    logger:debug("[sdlan_network] network: ~p, will terminate with reason: ~p", [NetworkId, Reason]),
    broadcast_shutdown(UsedMap),
    ok.

@ -529,7 +529,7 @@ create_mnesia_table(NetworkId) when is_integer(NetworkId) ->
            ok;
        false ->
            Res = client_model:create_table(Tab),
-            lager:debug("[sdlan_network] create table result: ~p", [Res])
+            logger:debug("[sdlan_network] create table result: ~p", [Res])
    end.

 -spec maybe_close_channel(undefined | #host{}) -> no_return().
--- a/apps/sdlan/src/sdlan_network_coordinator.erl
+++ b/apps/sdlan/src/sdlan_network_coordinator.erl
@ -104,10 +104,10 @@ handle_info({timeout, _, release_ticker}, State = #state{network_map = ChannelMa
                Acc
        end
                                  end, 0, maps:keys(ChannelMap)),
-    % lager:debug("[sdlan_network_coordinator] can release count is: ~p", [AccReleaseCount]),
+    % logger:debug("[sdlan_network_coordinator] can release count is: ~p", [AccReleaseCount]),
    {noreply, State#state{release_count = AccReleaseCount}};
 handle_info({'DOWN', _, process, NetworkPid, Reason}, State = #state{network_map = NetworkMap}) ->
-    lager:debug("[sdlan_network_coordinator] network_pid close with reason: ~p", [Reason]),
+    logger:debug("[sdlan_network_coordinator] network_pid close with reason: ~p", [Reason]),
    {noreply, State#state{network_map = maps:remove(NetworkPid, NetworkMap)}}.

 %% @private
--- a/apps/sdlan/src/sdlan_network_sup.erl
+++ b/apps/sdlan/src/sdlan_network_sup.erl
@ -41,7 +41,7 @@ start_link() ->
 init([]) ->
    SupFlags = #{strategy => one_for_one, intensity => 1000, period => 3600},
    {ok, NetworkIds} = sdlan_api:get_all_networks(),
-    Specs = lists:map(fun child_spec/1, NetworkIds),
+    Specs = lists:map(fun child_spec/1, []),

    set_network_bind(length(Specs)),

@ -110,6 +110,8 @@ child_spec(Id) when is_integer(Id) ->
        modules => ['sdlan_network']
    }.

+set_network_bind(0) ->
+    ok;
 set_network_bind(Count) when is_integer(Count) ->
    {ok, BindWidth} = application:get_env(sdlan, band_width),
    NetworkBindWidth = BindWidth div Count,
--- a/apps/sdlan/src/sdlan_stun.erl
+++ b/apps/sdlan/src/sdlan_stun.erl
@ -23,8 +23,7 @@
 -define(SERVER, ?MODULE).

 -record(state, {
-    socket,
-    stun_assist
+    socket
 }).

 %%%===================================================================
@ -52,18 +51,20 @@ start_link(Name, Port) when is_atom(Name), is_integer(Port) ->
    {stop, Reason :: term()} | ignore).
 init([Port]) ->
    %% 需要提高进程的调度优先级
-    erlang:process_flag(priority, max),
-
-    {ok, Socket} = gen_udp:open(Port, [binary, {active, true}, {recbuf, 5 * 1024 * 1024}, {sndbuf, 5 * 1024 * 1024}]),
+    erlang:process_flag(priority, high),
+    Opts = [
+        binary,
+        {reuseaddr, true},
+        {reuseport, true},
+        {active, true},
+        {recbuf, 5 * 1024 * 1024},
+        {sndbuf, 5 * 1024 * 1024}
+    ],
+    {ok, Socket} = gen_udp:open(Port, Opts),
    inet_udp:controlling_process(Socket, self()),
-    lager:debug("[sdlan_stun] start at port: ~p", [Port]),

-    case application:get_env(sdlan, stun_assist) of
-        undefined ->
-            {ok, #state{socket = Socket, stun_assist = undefined}};
-        {ok, StunAssist} ->
-            {ok, #state{socket = Socket, stun_assist = StunAssist}}
-    end.
+    logger:debug("[sdlan_stun] start at port: ~p", [Port]),
+    {ok, #state{socket = Socket}}.

 %% @private
 %% @doc Handling call messages
@ -103,7 +104,7 @@ handle_info({udp, Sock, Ip, Port, <<?PACKET_STUN_REQUEST:8, Body/binary>>}, Stat

    case sdlan_network:get_pid(NetworkId) of
        undefined ->
-            lager:debug("[sdlan_stun] stun_request network_id: ~p, client_id: ~p, not found", [NetworkId, ClientId]),
+            logger:debug("[sdlan_stun] stun_request network_id: ~p, client_id: ~p, not found", [NetworkId, ClientId]),
            {noreply, State};
        NetworkPid when is_pid(NetworkPid) ->
            sdlan_network:update_hole(NetworkPid, ClientId, Mac, {Ip, Port}, NatType, V6Info),
@ -111,48 +112,44 @@ handle_info({udp, Sock, Ip, Port, <<?PACKET_STUN_REQUEST:8, Body/binary>>}, Stat
                cookie = Cookie
            }),
            ok = gen_udp:send(Sock, Ip, Port, <<?PACKET_STUN_REPLY, StunReply/binary>>),
-            lager:debug("[sdlan_stun] stun_request network_id: ~p, client_id: ~p, hole: ~p", [NetworkId, ClientId, {Ip, Port}]),
+            logger:debug("[sdlan_stun] stun_request network_id: ~p, client_id: ~p, hole: ~p", [NetworkId, ClientId, {Ip, Port}]),
            {noreply, State}
    end;

 %% 网络nat类型的探测机制, 需要借助其他服务一起才能实现
 %% 辅助节点没有assist的配置，不支持attr = 2的探测
-handle_info({udp, Sock, Ip = {Ip0, Ip1, Ip2, Ip3}, Port, <<?PACKET_STUN_PROBE:8, Body/binary>>}, State = #state{socket = Sock, stun_assist = StunAssist}) ->
+handle_info({udp, Sock, ClientIp, ClientPort, <<?PACKET_STUN_PROBE:8, Body/binary>>}, State = #state{socket = Sock}) ->
    #sdl_stun_probe{cookie = Cookie, attr = Attr} = sdlan_pb:decode_msg(Body, sdl_stun_probe),
-    lager:debug("[sdlan_stun] get stun_probe request, att: ~p", [Attr]),
+    logger:debug("[sdlan_stun] get stun_probe request, att: ~p", [Attr]),

-    ProbeReply = sdlan_pb:encode_msg(#sdl_stun_probe_reply {
+    ProbeReplyPkt = sdlan_pb:encode_msg(#sdl_stun_probe_reply {
        cookie = Cookie,
-        port = Port,
-        ip = int_ip(Ip)
+        port = ClientPort,
+        ip = int_ip(ClientIp)
    }),
-    Packet = <<?PACKET_STUN_PROBE_REPLY, ProbeReply/binary>>,

    case Attr of
        ?STUN_ATTR_CHANGE_NONE ->
-            ok = gen_udp:send(Sock, Ip, Port, Packet);
+            ok = gen_udp:send(Sock, ClientIp, ClientPort, <<?PACKET_STUN_PROBE_REPLY, ProbeReplyPkt/binary>>);
        ?STUN_ATTR_CHANGE_PORT ->
-            gen_server:cast('sdlan_stun:1:2', {stun_relay, Ip, Port, Packet});
+            %% 切换端口和ip
+            sdlan_stun_peer_assist:stun_relay(ClientIp, ClientPort, ProbeReplyPkt);
        ?STUN_ATTR_CHANGE_PEER ->
-            case StunAssist of
-                {AssistIp, AssistPort} ->
-                    gen_udp:send(Sock, AssistIp, AssistPort, <<?PACKET_STUN_PROBE_RELAY, Ip0, Ip1, Ip2, Ip3, Port:16, Packet/binary>>);
-                undefined ->
-                    ok
-            end
+            %% 切换端口返回
+            sdlan_stun_port_assist:stun_relay(ClientIp, ClientPort, ProbeReplyPkt)
    end,
    {noreply, State};

 %% 转发消息, 跨服务器的stun_reply的转发通过socket来转发
 handle_info({udp, Sock, _, _, <<?PACKET_STUN_PROBE_RELAY:8, Ip0, Ip1, Ip2, Ip3, Port:16, Reply/binary>>}, State = #state{socket = Sock}) ->
-    lager:debug("[sdlan_stun] get stun_probe_replay request, reply: ~p", [Reply]),
+    logger:debug("[sdlan_stun] get stun_probe_replay request, reply: ~p", [Reply]),
    gen_udp:send(Sock, {Ip0, Ip1, Ip2, Ip3}, Port, Reply),
    {noreply, State};

 handle_info({udp, _, _Ip, _Port, <<?PACKET_STUN_DATA, Body/binary>>}, State = #state{socket = Sock}) ->
    Data = #sdl_data{network_id = NetworkId, src_mac = SrcMac, dst_mac = DstMac, ttl = TTL} = sdlan_pb:decode_msg(Body, sdl_data),

-    lager:debug("[sdlan_stun] stun data, src_mac: ~p, dst_mac: ~p", [sdlan_util:format_mac(SrcMac), sdlan_util:format_mac(DstMac)]),
+    logger:debug("[sdlan_stun] stun data, src_mac: ~p, dst_mac: ~p", [sdlan_util:format_mac(SrcMac), sdlan_util:format_mac(DstMac)]),

    %% 重新打包数据ttl需要减1
    case sdlan_network:get_pid(NetworkId) of
@ -166,7 +163,7 @@ handle_info({udp, _, _Ip, _Port, <<?PACKET_STUN_DATA, Body/binary>>}, State = #s
    {noreply, State};

 handle_info(Info, State) ->
-    lager:error("[sdlan_stun] get a unknown message: ~p, channel will closed", [Info]),
+    logger:error("[sdlan_stun] get a unknown message: ~p, channel will closed", [Info]),
    {noreply, State}.

 %% @private
--- a/apps/sdlan/src/sdlan_stun_peer_assist.erl
+++ b/apps/sdlan/src/sdlan_stun_peer_assist.erl
@ -0,0 +1,117 @@
+%%%-------------------------------------------------------------------
+%%% @author anlicheng
+%%% @copyright (C) 2026, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 22. 1月 2026 16:01
+%%%-------------------------------------------------------------------
+-module(sdlan_stun_peer_assist).
+-author("anlicheng").
+
+-behaviour(gen_server).
+
+%% API
+-export([start_link/0]).
+-export([stun_relay/3]).
+
+%% gen_server callbacks
+-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]).
+
+-define(SERVER, ?MODULE).
+
+-record(state, {
+    socket :: inet:socket(),
+    assist_ip :: inet:ip4_address(),
+    assist_port :: integer()
+}).
+
+%%%===================================================================
+%%% API
+%%%===================================================================
+
+-spec stun_relay(Ip :: inet:ip_address(), Port :: integer(), Reply :: binary()) -> no_return().
+stun_relay(Ip, Port, Reply) when is_integer(Port), is_binary(Reply) ->
+    gen_server:cast(?SERVER, {stun_relay, Ip, Port, Reply}).
+
+%% @doc Spawns the server and registers the local name (unique)
+-spec(start_link() ->
+    {ok, Pid :: pid()} | ignore | {error, Reason :: term()}).
+start_link() ->
+    gen_server:start_link({local, ?SERVER}, ?MODULE, [], []).
+
+%%%===================================================================
+%%% gen_server callbacks
+%%%===================================================================
+
+%% @private
+%% @doc Initializes the server
+-spec(init(Args :: term()) ->
+    {ok, State :: #state{}} | {ok, State :: #state{}, timeout() | hibernate} |
+    {stop, Reason :: term()} | ignore).
+init([]) ->
+    {ok, Props} = application:get_env(sdlan, stun_peer_assist),
+    AssistIp = proplists:get_value(ip, Props),
+    AssistPort = proplists:get_value(port, Props),
+
+    Opts = [binary, {reuseaddr, true}],
+    {ok, Socket} = gen_udp:open(0, Opts),
+    inet_udp:controlling_process(Socket, self()),
+    logger:debug("[sdlan_stun_peer_assist] started"),
+
+    {ok, #state{socket = Socket, assist_ip = AssistIp, assist_port = AssistPort}}.
+
+%% @private
+%% @doc Handling call messages
+-spec(handle_call(Request :: term(), From :: {pid(), Tag :: term()},
+    State :: #state{}) ->
+    {reply, Reply :: term(), NewState :: #state{}} |
+    {reply, Reply :: term(), NewState :: #state{}, timeout() | hibernate} |
+    {noreply, NewState :: #state{}} |
+    {noreply, NewState :: #state{}, timeout() | hibernate} |
+    {stop, Reason :: term(), Reply :: term(), NewState :: #state{}} |
+    {stop, Reason :: term(), NewState :: #state{}}).
+handle_call(_Request, _From, State = #state{}) ->
+    {reply, ok, State}.
+
+%% @private
+%% @doc Handling cast messages
+-spec(handle_cast(Request :: term(), State :: #state{}) ->
+    {noreply, NewState :: #state{}} |
+    {noreply, NewState :: #state{}, timeout() | hibernate} |
+    {stop, Reason :: term(), NewState :: #state{}}).
+handle_cast({stun_relay, _Ip = {Ip0, Ip1, Ip2, Ip3}, Port, Reply}, State = #state{socket = Sock, assist_ip = AssistIp, assist_port = AssistPort}) ->
+    Packet = <<Ip0, Ip1, Ip2, Ip3, Port:16, Reply/binary>>,
+    ok = gen_udp:send(Sock, AssistIp, AssistPort, Packet),
+    {noreply, State}.
+
+%% @private
+%% @doc Handling all non call/cast messages
+-spec(handle_info(Info :: timeout() | term(), State :: #state{}) ->
+    {noreply, NewState :: #state{}} |
+    {noreply, NewState :: #state{}, timeout() | hibernate} |
+    {stop, Reason :: term(), NewState :: #state{}}).
+handle_info(_Info, State = #state{}) ->
+    {noreply, State}.
+
+%% @private
+%% @doc This function is called by a gen_server when it is about to
+%% terminate. It should be the opposite of Module:init/1 and do any
+%% necessary cleaning up. When it returns, the gen_server terminates
+%% with Reason. The return value is ignored.
+-spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()),
+    State :: #state{}) -> term()).
+terminate(_Reason, _State = #state{}) ->
+    ok.
+
+%% @private
+%% @doc Convert process state when code is changed
+-spec(code_change(OldVsn :: term() | {down, term()}, State :: #state{},
+    Extra :: term()) ->
+    {ok, NewState :: #state{}} | {error, Reason :: term()}).
+code_change(_OldVsn, State = #state{}, _Extra) ->
+    {ok, State}.
+
+%%%===================================================================
+%%% Internal functions
+%%%===================================================================
--- a/apps/sdlan/src/sdlan_stun_port_assist.erl
+++ b/apps/sdlan/src/sdlan_stun_port_assist.erl
@ -0,0 +1,113 @@
+%%%-------------------------------------------------------------------
+%%% @author anlicheng
+%%% @copyright (C) 2026, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 22. 1月 2026 16:01
+%%%-------------------------------------------------------------------
+-module(sdlan_stun_port_assist).
+-author("anlicheng").
+
+-behaviour(gen_server).
+
+%% API
+-export([start_link/0]).
+-export([stun_relay/3]).
+
+%% gen_server callbacks
+-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]).
+
+-define(SERVER, ?MODULE).
+
+-record(state, {
+    socket :: inet:socket()
+}).
+
+%%%===================================================================
+%%% API
+%%%===================================================================
+
+-spec stun_relay(Ip :: inet:ip_address(), Port :: integer(), Reply :: binary()) -> no_return().
+stun_relay(Ip, Port, Reply) when is_integer(Port), is_binary(Reply) ->
+    gen_server:cast(?SERVER, {stun_relay, Ip, Port, Reply}).
+
+%% @doc Spawns the server and registers the local name (unique)
+-spec(start_link() ->
+    {ok, Pid :: pid()} | ignore | {error, Reason :: term()}).
+start_link() ->
+    gen_server:start_link({local, ?SERVER}, ?MODULE, [], []).
+
+%%%===================================================================
+%%% gen_server callbacks
+%%%===================================================================
+
+%% @private
+%% @doc Initializes the server
+-spec(init(Args :: term()) ->
+    {ok, State :: #state{}} | {ok, State :: #state{}, timeout() | hibernate} |
+    {stop, Reason :: term()} | ignore).
+init([]) ->
+    {ok, Props} = application:get_env(sdlan, stun_port_assist),
+    Port = proplists:get_value(port, Props),
+
+    Opts = [binary, {reuseaddr, true}],
+    {ok, Socket} = gen_udp:open(Port, Opts),
+    inet_udp:controlling_process(Socket, self()),
+    logger:debug("[sdlan_stun_port_assist] start at port: ~p", [Port]),
+
+    {ok, #state{socket = Socket}}.
+
+%% @private
+%% @doc Handling call messages
+-spec(handle_call(Request :: term(), From :: {pid(), Tag :: term()},
+    State :: #state{}) ->
+    {reply, Reply :: term(), NewState :: #state{}} |
+    {reply, Reply :: term(), NewState :: #state{}, timeout() | hibernate} |
+    {noreply, NewState :: #state{}} |
+    {noreply, NewState :: #state{}, timeout() | hibernate} |
+    {stop, Reason :: term(), Reply :: term(), NewState :: #state{}} |
+    {stop, Reason :: term(), NewState :: #state{}}).
+handle_call(_Request, _From, State = #state{}) ->
+    {reply, ok, State}.
+
+%% @private
+%% @doc Handling cast messages
+-spec(handle_cast(Request :: term(), State :: #state{}) ->
+    {noreply, NewState :: #state{}} |
+    {noreply, NewState :: #state{}, timeout() | hibernate} |
+    {stop, Reason :: term(), NewState :: #state{}}).
+handle_cast({stun_relay, Ip, Port, Reply}, State = #state{socket = Sock}) ->
+    ok = gen_udp:send(Sock, Ip, Port, Reply),
+    {noreply, State}.
+
+%% @private
+%% @doc Handling all non call/cast messages
+-spec(handle_info(Info :: timeout() | term(), State :: #state{}) ->
+    {noreply, NewState :: #state{}} |
+    {noreply, NewState :: #state{}, timeout() | hibernate} |
+    {stop, Reason :: term(), NewState :: #state{}}).
+handle_info(_Info, State = #state{}) ->
+    {noreply, State}.
+
+%% @private
+%% @doc This function is called by a gen_server when it is about to
+%% terminate. It should be the opposite of Module:init/1 and do any
+%% necessary cleaning up. When it returns, the gen_server terminates
+%% with Reason. The return value is ignored.
+-spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()),
+    State :: #state{}) -> term()).
+terminate(_Reason, _State = #state{}) ->
+    ok.
+
+%% @private
+%% @doc Convert process state when code is changed
+-spec(code_change(OldVsn :: term() | {down, term()}, State :: #state{},
+    Extra :: term()) ->
+    {ok, NewState :: #state{}} | {error, Reason :: term()}).
+code_change(_OldVsn, State = #state{}, _Extra) ->
+    {ok, State}.
+
+%%%===================================================================
+%%% Internal functions
+%%%===================================================================
--- a/apps/sdlan/src/sdlan_stun_sup.erl
+++ b/apps/sdlan/src/sdlan_stun_sup.erl
@ -0,0 +1,65 @@
+%%%-------------------------------------------------------------------
+%% @doc sdlan top level supervisor.
+%% @end
+%%%-------------------------------------------------------------------
+-module(sdlan_stun_sup).
+
+-behaviour(supervisor).
+
+-export([start_link/0]).
+
+-export([init/1]).
+
+-define(SERVER, ?MODULE).
+
+start_link() ->
+    supervisor:start_link({local, ?SERVER}, ?MODULE, []).
+
+%% sup_flags() = #{strategy => strategy(),         % optional
+%%                 intensity => non_neg_integer(), % optional
+%%                 period => pos_integer()}        % optional
+%% child_spec() = #{id => child_id(),       % mandatory
+%%                  start => mfargs(),      % mandatory
+%%                  restart => restart(),   % optional
+%%                  shutdown => shutdown(), % optional
+%%                  type => worker(),       % optional
+%%                  modules => modules()}   % optional
+init([]) ->
+    SupFlags = #{strategy => one_for_one, intensity => 1000, period => 3600},
+    Specs = [
+        #{
+            id => sdlan_stun_port_assist,
+            start => {sdlan_stun_port_assist, start_link, []},
+            restart => permanent,
+            shutdown => 2000,
+            type => worker,
+            modules => ['sdlan_stun_port_assist']
+        },
+        #{
+            id => sdlan_stun_peer_assist,
+            start => {sdlan_stun_peer_assist, start_link, []},
+            restart => permanent,
+            shutdown => 2000,
+            type => worker,
+            modules => ['sdlan_stun_peer_assist']
+        }
+    ],
+
+    {ok, {SupFlags, Specs ++ stun_acceptors()}}.
+
+stun_acceptors() ->
+    {ok, StunServers} = application:get_env(sdlan, stun_servers),
+    Port = proplists:get_value(port, StunServers),
+    AcceptorNums = proplists:get_value(acceptor_nums, StunServers),
+
+    lists:map(fun(Id) ->
+        Name = sdlan_stun:get_name(Id),
+        #{
+            id => Name,
+            start => {sdlan_stun, start_link, [Name, Port]},
+            restart => permanent,
+            shutdown => 2000,
+            type => worker,
+            modules => ['sdlan_stun']
+        }
+              end, lists:seq(1, AcceptorNums)).
--- a/apps/sdlan/src/sdlan_sup.erl
+++ b/apps/sdlan/src/sdlan_sup.erl
@ -52,10 +52,19 @@ init([]) ->
            shutdown => 2000,
            type => supervisor,
            modules => ['sdlan_network_sup']
+        },
+
+        #{
+            id => sdlan_stun_sup,
+            start => {sdlan_stun_sup, start_link, []},
+            restart => permanent,
+            shutdown => 2000,
+            type => supervisor,
+            modules => ['sdlan_stun_sup']
        }
    ],

-    {ok, {SupFlags, pools() ++ Specs ++ stun_specs()}}.
+    {ok, {SupFlags, pools() ++ Specs}}.

 %% internal functions

@ -64,16 +73,3 @@ pools() ->
    lists:map(fun({Name, PoolArgs, WorkerArgs}) ->
        poolboy:child_spec(Name, [{name, {local, Name}}|PoolArgs], WorkerArgs)
              end, Pools).
-
-stun_specs() ->
-    {ok, StunServers} = application:get_env(sdlan, stun_servers),
-    lists:map(fun({Name, Port}) ->
-        #{
-            id => Name,
-            start => {sdlan_stun, start_link, [Name, Port]},
-            restart => permanent,
-            shutdown => 2000,
-            type => worker,
-            modules => ['sdlan_stun']
-        }
-              end, StunServers).
--- a/apps/sdlan/src/test/sdlan_quicer_test.erl
+++ b/apps/sdlan/src/test/sdlan_quicer_test.erl
@ -0,0 +1,20 @@
+%%%-------------------------------------------------------------------
+%%% @author anlicheng
+%%% @copyright (C) 2026, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 11. 2月 2026 15:49
+%%%-------------------------------------------------------------------
+-module(sdlan_quicer_test).
+-author("anlicheng").
+
+%% API
+-export([test/0]).
+
+test() ->
+    {ok, Conn} = quicer:connect("http3.is", 443, [{alpn, ["h3"]},
+        {verify, verify_peer},
+        {peer_unidi_stream_count, 3}], 5000),
+    logger:debug("conn is: ~p", [Conn]),
+    quicer:shutdown_connection(Conn).
--- a/apps/sdlan/src/test/sdlan_udp_wget.erl
+++ b/apps/sdlan/src/test/sdlan_udp_wget.erl
@ -86,7 +86,7 @@ handle_cast(_Info, State) ->
 handle_info({udp, Sock, _Ip, _Port, Data}, State = #state{socket = Sock, bytes = Bytes}) ->
    {noreply, State#state{bytes = Bytes + byte_size(Data)}};
 handle_info({timeout, _, qps_ticker}, State = #state{bytes = Bytes}) ->
-    lager:debug("[sdlan_udp_wget] qps is: ~p(M)", [Bytes / 1024 / 1024]),
+    logger:debug("[sdlan_udp_wget] qps is: ~p(M)", [Bytes / 1024 / 1024]),
    erlang:start_timer(5000, self(), qps_ticker),
    {noreply, State#state{bytes = 0}}.

--- a/apps/sdlan/src/test/stun_client.erl
+++ b/apps/sdlan/src/test/stun_client.erl
@ -111,7 +111,7 @@ handle_call(register, _From, State = #state{socket = Socket, client_id = ClientI
        token = <<"1234567890">>
    },

-    lager:debug("register is: ~p", [Register]),
+    logger:debug("register is: ~p", [Register]),

    Packet = jiffy:encode(Req, [force_utf8]),
    ok = gen_tcp:send(Socket, <<1:32, 101, Packet/binary>>),
@ -145,7 +145,7 @@ handle_info({tcp, Socket, <<1:32, 5, Data/binary>>}, State = #state{socket = Soc
        <<"lifetime">> := Lifetime
    } = Response,

-    lager:debug("[stun_client] get a register super response: ~p, alloc ip addr: ~p", [Response, sdlan_ipaddr:int_to_ipv4(NetAddr)]),
+    logger:debug("[stun_client] get a register super response: ~p, alloc ip addr: ~p", [Response, sdlan_ipaddr:int_to_ipv4(NetAddr)]),

    %% 开始注册自己的tun信息
    gen_udp:send(TunSocket, "localhost", 1265, <<1, Cookie:32, ClientId/binary, NetworkId:32, NetAddr:32>>),
@ -153,36 +153,36 @@ handle_info({tcp, Socket, <<1:32, 5, Data/binary>>}, State = #state{socket = Soc
    {noreply, State#state{network_id = NetworkId, net_addr = NetAddr, mask_len = NetBitLen, aes_key = AesKey, cookie = Cookie + 1}};

 handle_info({udp, _, _, _, <<2, Cookie:32, Family, Port:16, Ip0, Ip1, Ip2, Ip3>>}, State = #state{}) ->
-    lager:debug("[stun_client] tun register ack, cookie: ~p, ack: ~p", [Cookie, {Family, Port, {Ip0, Ip1, Ip2, Ip3}}]),
+    logger:debug("[stun_client] tun register ack, cookie: ~p, ack: ~p", [Cookie, {Family, Port, {Ip0, Ip1, Ip2, Ip3}}]),
    {noreply, State};

 handle_info({udp, _, Ip, Port, <<?STUN_REGISTER:8, NetworkId:32, SrcIp:32, DstIp:32>>}, State = #state{tun_socket = TunSocket, sessions = Sessions}) ->
    Packet = <<?STUN_REGISTER_ACK, NetworkId:32, DstIp:32, SrcIp:32>>,
-    lager:debug("[stun_client] will send stun reply: ~p, peer: ~p", [Packet, {Ip, Port}]),
+    logger:debug("[stun_client] will send stun reply: ~p, peer: ~p", [Packet, {Ip, Port}]),
    ok = gen_udp:send(TunSocket, Ip, Port, Packet),

    NSessions = maps:put(SrcIp, {Ip, Port}, Sessions),
    {noreply, State#state{sessions = NSessions}};

 handle_info({udp, _, Ip, Port, <<?STUN_REGISTER_ACK, NetworkId:32, SrcIp:32, DstIp:32>>}, State = #state{sessions = Sessions}) ->
-    lager:debug("[stun_client] stun_data: network_id: ~p, src: ~p, dst: ~p, register_ack!!!", [NetworkId, SrcIp, DstIp]),
+    logger:debug("[stun_client] stun_data: network_id: ~p, src: ~p, dst: ~p, register_ack!!!", [NetworkId, SrcIp, DstIp]),
    NSessions = maps:put(SrcIp, {Ip, Port}, Sessions),
    {noreply, State#state{sessions = NSessions}};

 handle_info({udp, _, _Ip0, _Port0, <<?STUN_DATA, NetworkId:32, SrcIp:32, DstIp:32, TTL:8, Data/binary>>}, State = #state{tun_socket = TunSocket, sessions = Sessions}) ->
-    lager:debug("[stun_client] stun_data: network_id: ~p, src: ~p, dst: ~p, data!!!", [NetworkId, SrcIp, DstIp]),
+    logger:debug("[stun_client] stun_data: network_id: ~p, src: ~p, dst: ~p, data!!!", [NetworkId, SrcIp, DstIp]),
    case maps:is_key(SrcIp, Sessions) of
        true ->
            {Ip, Port} = maps:get(SrcIp, Sessions),
            ok = gen_udp:send(TunSocket, Ip, Port, <<?STUN_DATA, NetworkId:32, DstIp:32, SrcIp:32, 255, Data/binary>>),
-            lager:debug("[stun_client] stun_data: network_id: ~p, src: ~p, dst: ~p, reply data!!!", [NetworkId, SrcIp, DstIp]);
+            logger:debug("[stun_client] stun_data: network_id: ~p, src: ~p, dst: ~p, reply data!!!", [NetworkId, SrcIp, DstIp]);
        false ->
-            lager:debug("[stun_client] stun_data: network_id: ~p, src: ~p, dst: ~p, no session", [NetworkId, SrcIp, DstIp])
+            logger:debug("[stun_client] stun_data: network_id: ~p, src: ~p, dst: ~p, no session", [NetworkId, SrcIp, DstIp])
    end,
    {noreply, State};

 handle_info(Info, State = #state{}) ->
-    lager:debug("[stun_client] get info: ~p", [Info]),
+    logger:debug("[stun_client] get info: ~p", [Info]),
    {noreply, State}.

 %% @private
--- a/config/sys-dev.config
+++ b/config/sys-dev.config
@ -18,10 +18,20 @@
    %% 网络带宽, 单位为: kb
    {band_width, 2048},

-    {stun_servers, [{'sdlan_stun:1:1', 1265}, {'sdlan_stun:1:2', 1266}]},
-    {stun_assist, {{47,98,178,3}, 1266}},
+    %% stun类型探测相当于有个类型
+    {stun_servers, [
+      {port, 1265},
+      {acceptor_nums, 5}
+    ]},

-    % {stun_servers, [{'sdlan_stun:2:1', 1265}, {'sdlan_stun:2:2', 1266}]},
+    {stun_port_assist, [
+      {port, 1266}
+    ]},
+
+    {stun_peer_assist, [
+      {ip, {47,98,178,3}},
+      {port, 1266}
+    ]},

    %% 公共的dns域名解析服务
    {public_dns_servers, [
@ -61,37 +71,29 @@
  ]},

  %% 系统日志配置，系统日志为lager, 支持日志按日期自动分割
-  {lager, [
-    {colored, true},
-    %% Whether to write a crash log, and where. Undefined means no crash logger.
-    {crash_log, "trade_hub.crash.log"},
-    %% Maximum size in bytes of events in the crash log - defaults to 65536
-    {crash_log_msg_size, 65536},
-    %% Maximum size of the crash log in bytes, before its rotated, set
-    %% to 0 to disable rotation - default is 0
-    {crash_log_size, 10485760},
-    %% What time to rotate the crash log - default is no time
-    %% rotation. See the README for a description of this format.
-    {crash_log_date, "$D0"},
-    %% Number of rotated crash logs to keep, 0 means keep only the
-    %% current one - default is 0
-    {crash_log_count, 5},
-    %% Whether to redirect error_logger messages into lager - defaults to true
-    {error_logger_redirect, true},
+  {kernel, [
+    %% 设置 Logger 的 primary log level
+    {logger_level, debug},
+    {logger, [
+      {handler, default, logger_std_h,
+        #{
+          level => debug,
+          formatter => {logger_formatter, #{template => [time, " [", level, "] ", msg, "\n"]}}
+        }
+      },

-    %% How big the gen_event mailbox can get before it is switched into sync mode
-    {async_threshold, 20},
-    %% Switch back to async mode, when gen_event mailbox size decrease from `async_threshold'
-    %% to async_threshold - async_threshold_window
-    {async_threshold_window, 5},
+      {handler, disk, logger_disk_log_h,
+        #{
+          level => debug,
+          config => #{
+          file => "log/debug.log",
+          max_no_files => 10,
+          max_no_bytes => 524288000
+        },
+          formatter => {logger_formatter, #{template => [time, " [", level, "] ", msg, "\n"]}}
+        }
+      }

-    {handlers, [
-      %% debug | info | warning | error, 日志级别
-      {lager_console_backend, debug},
-      {lager_file_backend, [{file, "debug.log"}, {level, debug}, {size, 314572800}]},
-      {lager_file_backend, [{file, "notice.log"}, {level, notice}, {size, 314572800}]},
-      {lager_file_backend, [{file, "error.log"}, {level, error}, {size, 314572800}]},
-      {lager_file_backend, [{file, "info.log"}, {level, info}, {size, 314572800}]}
    ]}
  ]}
 ].
--- a/config/sys-prod.config
+++ b/config/sys-prod.config
@ -18,10 +18,20 @@
    %% 网络带宽, 单位为: kb
    {band_width, 2048},

-    {stun_servers, [{'sdlan_stun:1:1', 1265}, {'sdlan_stun:1:2', 1266}]},
-    {stun_assist, {{47,98,178,3}, 1266}},
+    %% stun类型探测相当于有个类型
+    {stun_servers, [
+      {port, 1265},
+      {acceptor_nums, 1}
+    ]},

-    % {stun_servers, [{'sdlan_stun:2:1', 1265}, {'sdlan_stun:2:2', 1266}]},
+    {stun_port_assist, [
+      {port, 1266}
+    ]},
+
+    {stun_peer_assist, [
+      {ip, {47,98,178,3}},
+      {port, 1266}
+    ]},

    %% 公共的dns域名解析服务
    {public_dns_servers, [
@ -62,37 +72,29 @@
  ]},

  %% 系统日志配置，系统日志为lager, 支持日志按日期自动分割
-  {lager, [
-    {colored, true},
-    %% Whether to write a crash log, and where. Undefined means no crash logger.
-    {crash_log, "trade_hub.crash.log"},
-    %% Maximum size in bytes of events in the crash log - defaults to 65536
-    {crash_log_msg_size, 65536},
-    %% Maximum size of the crash log in bytes, before its rotated, set
-    %% to 0 to disable rotation - default is 0
-    {crash_log_size, 10485760},
-    %% What time to rotate the crash log - default is no time
-    %% rotation. See the README for a description of this format.
-    {crash_log_date, "$D0"},
-    %% Number of rotated crash logs to keep, 0 means keep only the
-    %% current one - default is 0
-    {crash_log_count, 5},
-    %% Whether to redirect error_logger messages into lager - defaults to true
-    {error_logger_redirect, true},
+  {kernel, [
+    %% 设置 Logger 的 primary log level
+    {logger_level, debug},
+    {logger, [
+      {handler, default, logger_std_h,
+        #{
+          level => debug,
+          formatter => {logger_formatter, #{template => [time, " [", level, "] ", msg, "\n"]}}
+        }
+      },

-    %% How big the gen_event mailbox can get before it is switched into sync mode
-    {async_threshold, 20},
-    %% Switch back to async mode, when gen_event mailbox size decrease from `async_threshold'
-    %% to async_threshold - async_threshold_window
-    {async_threshold_window, 5},
+      {handler, disk, logger_disk_log_h,
+        #{
+          level => debug,
+          config => #{
+          file => "log/debug.log",
+          max_no_files => 10,
+          max_no_bytes => 524288000
+        },
+          formatter => {logger_formatter, #{template => [time, " [", level, "] ", msg, "\n"]}}
+        }
+      }

-    {handlers, [
-      %% debug | info | warning | error, 日志级别
-      {lager_console_backend, debug},
-      {lager_file_backend, [{file, "debug.log"}, {level, debug}, {size, 314572800}]},
-      {lager_file_backend, [{file, "notice.log"}, {level, notice}, {size, 314572800}]},
-      {lager_file_backend, [{file, "error.log"}, {level, error}, {size, 314572800}]},
-      {lager_file_backend, [{file, "info.log"}, {level, info}, {size, 314572800}]}
    ]}
  ]}
 ].
--- a/rebar.config
+++ b/rebar.config
@ -1,4 +1,6 @@
-{erl_opts, [debug_info]}.
+{erl_opts, [
+    debug_info
+]}.
 {deps, [
    {poolboy, ".*", {git, "https://github.com/devinus/poolboy.git", {tag, "1.5.1"}}},
    {hackney, ".*", {git, "https://github.com/benoitc/hackney.git", {tag, "1.16.0"}}},
@ -8,10 +10,9 @@
    {gpb, ".*", {git, "https://github.com/tomas-abrahamsson/gpb.git", {tag, "4.21.1"}}},
    {throttle, ".*", {git, "https://github.com/lambdaclass/throttle.git", {tag, "0.3.0"}}},
    {dns_erlang, ".*", {git, "https://github.com/dnsimple/dns_erlang.git", {tag, "v4.4.0"}}},
+    {quicer, ".*", {git, "https://github.com/emqx/quic.git", {tag, "0.4.0"}}},
    {pkt, ".*", {git, "https://github.com/msantos/pkt.git", {tag, "0.6.0"}}},
-    {sync, ".*", {git, "https://github.com/rustyio/sync.git", {branch, "master"}}},
-    {parse_trans, ".*", {git, "https://github.com/uwiger/parse_trans", {tag, "3.0.0"}}},
-    {lager, ".*", {git,"https://github.com/erlang-lager/lager.git", {tag, "3.9.2"}}}
+    {sync, ".*", {git, "https://github.com/rustyio/sync.git", {branch, "master"}}}
 ]}.

 {relx, [{release, {sdlan, "0.1.0"},
@ -44,6 +45,4 @@
                     ]
            }]}]}.

-{erl_opts, [{parse_transform,lager_transform}]}.
-
 {rebar_packages_cdn, "https://hexpm.upyun.com"}.
--- a/rebar.lock
+++ b/rebar.lock
@ -54,10 +54,15 @@
  {git,"https://github.com/devinus/poolboy.git",
       {ref,"3bb48a893ff5598f7c73731ac17545206d259fac"}},
  0},
+ {<<"quicer">>,
+  {git,"https://github.com/emqx/quic.git",
+       {ref,"c2962fd732caa29d513de7c645ea307cf89aaa9c"}},
+  0},
 {<<"ranch">>,
  {git,"https://github.com/ninenines/ranch",
       {ref,"a692f44567034dacf5efcaa24a24183788594eb7"}},
  1},
+ {<<"snabbkaffe">>,{pkg,<<"snabbkaffe">>,<<"1.0.10">>},1},
 {<<"ssl_verify_fun">>,{pkg,<<"ssl_verify_fun">>,<<"1.1.6">>},1},
 {<<"sync">>,
  {git,"https://github.com/rustyio/sync.git",
@ -77,6 +82,7 @@
 {<<"idna">>, <<"1D038FB2E7668CE41FBF681D2C45902E52B3CB9E9C77B55334353B222C2EE50C">>},
 {<<"metrics">>, <<"25F094DEA2CDA98213CECC3AEFF09E940299D950904393B2A29D191C346A8486">>},
 {<<"mimerl">>, <<"67E2D3F571088D5CFD3E550C383094B47159F3EEE8FFA08E64106CDF5E981BE3">>},
+ {<<"snabbkaffe">>, <<"9BE2F54F61FC6862391B666B2B5B76C3FA53598E2989A17CEF1B48CF347A8A63">>},
 {<<"ssl_verify_fun">>, <<"CF344F5692C82D2CD7554F5EC8FD961548D4FD09E7D22F5B62482E5AEAEBD4B0">>},
 {<<"unicode_util_compat">>, <<"8516502659002CEC19E244EBD90D312183064BE95025A319A6C7E89F4BCCD65B">>}]},
 {pkg_hash_ext,[
@ -87,6 +93,7 @@
 {<<"idna">>, <<"A02C8A1C4FD601215BB0B0324C8A6986749F807CE35F25449EC9E69758708122">>},
 {<<"metrics">>, <<"69B09ADDDC4F74A40716AE54D140F93BEB0FB8978D8636EADED0C31B6F099F16">>},
 {<<"mimerl">>, <<"F278585650AA581986264638EBF698F8BB19DF297F66AD91B18910DFC6E19323">>},
+ {<<"snabbkaffe">>, <<"70A98DF36AE756908D55B5770891D443D63C903833E3E87D544036E13D4FAC26">>},
 {<<"ssl_verify_fun">>, <<"BDB0D2471F453C88FF3908E7686F86F9BE327D065CC1EC16FA4540197EA04680">>},
 {<<"unicode_util_compat">>, <<"D48D002E15F5CC105A696CF2F1BBB3FC72B4B770A184D8420C8DB20DA2674B38">>}]}
 ].
Author	SHA1	Message	Date
anlicheng	2e7e84193c	fix stun server	2026-02-11 17:00:15 +08:00
anlicheng	e7af8a6019	test quic	2026-02-11 15:51:35 +08:00
anlicheng	eb015f1a67	lager to logger	2026-02-11 15:44:53 +08:00
anlicheng	de71af2dbf	replace lager	2026-02-11 15:42:44 +08:00
anlicheng	4b3c0eda73	remove rebar3	2026-02-11 15:38:43 +08:00
anlicheng	019c68684d	add git quicer	2026-02-11 15:23:22 +08:00