From ebcaba4a1419e6c03000fbfd417bd0e2f2b21a71 Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Fri, 9 May 2025 21:30:57 +0800
Subject: [PATCH] fix tcp server

---
 apps/efka/src/efka_sup.erl        |  2 +-
 apps/efka/src/efka_tcp_server.erl | 11 +++++++----
 config/sys.config                 |  4 ++++
 3 files changed, 12 insertions(+), 5 deletions(-)

diff --git a/apps/efka/src/efka_sup.erl b/apps/efka/src/efka_sup.erl
index 5eb869b..923c37a 100644
--- a/apps/efka/src/efka_sup.erl
+++ b/apps/efka/src/efka_sup.erl
@@ -66,7 +66,7 @@ init([]) ->
 
         #{
             id => 'efka_tcp_server',
-            start => {'efka_tcp_server', start_link, [18080]},
+            start => {'efka_tcp_server', start_link, []},
             restart => permanent,
             shutdown => 2000,
             type => worker,
diff --git a/apps/efka/src/efka_tcp_server.erl b/apps/efka/src/efka_tcp_server.erl
index 45c03a9..e47eb8a 100644
--- a/apps/efka/src/efka_tcp_server.erl
+++ b/apps/efka/src/efka_tcp_server.erl
@@ -10,13 +10,16 @@
 -author("anlicheng").
 
 %% API
--export([start_link/1, init/1]).
+-export([start_link/0, init/0]).
 
-start_link(Port) ->
-    {ok, spawn_link(?MODULE, init, [Port])}.
+start_link() ->
+    {ok, spawn_link(?MODULE, init, [])}.
 
 %% 监听循环
-init(Port) ->
+init() ->
+    {ok, TcpServerProps} = application:get_env(efka, tcp_server),
+    Port = proplists:get_value(port, TcpServerProps),
+
     case gen_tcp:listen(Port, [binary, {packet, 4}, {active, false}, {reuseaddr, true}]) of
         {ok, ListenSocket} ->
             efka_logger:debug("Server started on port ~p~n", [Port]),
diff --git a/config/sys.config b/config/sys.config
index 872982f..4c8b6fd 100644
--- a/config/sys.config
+++ b/config/sys.config
@@ -2,6 +2,10 @@
   {efka, [
     {root_dir, "/tmp/efka/"},
 
+    {tcp_server, [
+      {port, 18080}
+    ]},
+
     {tls_server, [
       {host, "localhost"},
       {port, 443}